integration_support

Documentation

Index

• Constants
• Variables
• 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)
  • func (s *Integration) Teardown()

Constants

const NatsHost = "127.0.0.1"

NatsHost is the default testing ip for the NATS host.

const NatsPort = 4459

NatsPort is the default testing port for the NATS host.

Variables

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

NatsURL is the default testing URL for the NATS host.

Types

type Integration

type Integration struct {
	FinalVars     map[string]interface{}
	Test          *testing.T
	Mx            sync.Mutex
	Cooldown      time.Duration
	WithTelemetry server2.Exporter
	// 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)

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.