integration_support

Mar 26, 2024

Changes in this version

type Integration

+ func (s *Integration) TrackingUpdatesFor(namespace string, executionId string, received chan struct{}, ...)

Feb 21, 2024

Changes in this version

+ func GetPackageName(packageNameStruct any) string

type Integration

+ func NewIntegration(trace bool, packageName string, WithTelemetry server2.Exporter) *Integration

+ func NewIntegrationT(t *testing.T, authZFn authz.APIFunc, authNFn authn.Check, trace bool, ...) *Integration

Oct 3, 2023

Changes in this version

+ func WaitForExpectedCompletions(t *testing.T, expectedCompletions int, completion chan struct{}, ...)

Sep 13, 2023

Changes in this version

+ const NATS_PERSIST_ENV_VAR_NAME

+ const NATS_SERVER_IMAGE_URL_ENV_VAR_NAME

+ const SHAR_SERVER_IMAGE_URL_ENV_VAR_NAME

+ func IsNatsContainerised() bool

+ func IsNatsPersist() bool

+ func IsSharContainerised() bool

type Integration

+ TestRunnable func() (bool, string)

Mar 24, 2023

Changes in this version

+ func WaitForChan(t *testing.T, c chan struct{}, d time.Duration)

Mar 2, 2023

Changes in this version

type Integration

+ WithTrace bool

Jan 13, 2023

Changes in this version

type Integration

+ func (s *Integration) AwaitWorkflowComplete(t *testing.T, complete chan *model.WorkflowInstanceComplete, wfiID string) *model.WorkflowInstanceComplete

Dec 19, 2022

Changes in this version

type Integration

+ NatsHost string

+ NatsPort int

+ NatsURL string

Dec 5, 2022

Changes in this version

+ const NatsHost

+ const NatsPort

+ var NatsURL = fmt.Sprintf("nats://%s:%v", NatsHost, NatsPort)

+ type Integration struct

+ Cooldown time.Duration

+ FinalVars map[string]interface{}

+ Mx sync.Mutex

+ Test *testing.T

+ WithTelemetry server2.Exporter

+ func (s *Integration) AssertCleanKV()

+ func (s *Integration) GetJetstream() (nats.JetStreamContext, error)

+ func (s *Integration) GetNats() (*nats.Conn, error)

+ func (s *Integration) Setup(t *testing.T)

+ func (s *Integration) Teardown()