Function assertNoRedshiftSubResult

tests/redshift_surface_test.go:222–229

(t *testing.T, m *core.Member, timeout time.Duration)

}

func assertNoRedshiftSubResult(t *testing.T, m *core.Member, timeout time.Duration) {
	t.Helper()
	select {
	case msg := <-m.Result:
		t.Fatalf("unexpected idle subscription result: %s", msg.Data)
	case <-time.After(timeout):
	}
}

func TestRedshiftMutationInsertWithSuppliedPK(t *testing.T) {
	if dbType != "redshift" {