integration_support

Documentation

Index

• func WaitForChan(t *testing.T, c chan struct{}, d time.Duration)
• type Integration
  • 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, authZFn authz.APIFunc, authNFn authn.Check)
  • func (s *Integration) Teardown()

Functions

func WaitForChan

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

WaitForChan waits for a chan struct{} with a duration timeout.

Types

type Integration

type Integration struct {
	FinalVars     map[string]interface{}
	Test          *testing.T
	Mx            sync.Mutex
	Cooldown      time.Duration
	WithTelemetry server2.Exporter

	WithTrace bool

	NatsURL  string // NatsURL is the default testing URL for the NATS host.
	NatsPort int    // NatsPort is the default testing port for the NATS host.
	NatsHost string // NatsHost is the default NATS host.
	// contains filtered or unexported fields
}

Integration - the integration test support framework.

func (*Integration) AssertCleanKV

func (s *Integration) AssertCleanKV()

AssertCleanKV - ensures SHAR has cleans up after itself, and there are no records left in the KV.

func (*Integration) GetJetstream

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

GetJetstream - fetches the test framework jetstream server for making test calls.

func (*Integration) GetNats

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

GetNats - fetches the test framework NATS server for making test calls.

func (*Integration) Setup

func (s *Integration) Setup(t *testing.T, authZFn authz.APIFunc, authNFn authn.Check)

Setup - sets up the test NATS and SHAR servers.

func (*Integration) Teardown

func (s *Integration) Teardown()

Teardown - resposible for shutting down the integration test framework.