integration_tests

Documentation

Index

• type ContainerResources
• type TestClientWorker
  • func (worker *TestClientWorker) CompleteRun(runId string) error
  • func (worker *TestClientWorker) FailRun(runId string) error
  • func (worker *TestClientWorker) Start(wg *sync.WaitGroup) error
  • func (worker *TestClientWorker) Stop()

Types

type ContainerResources

type ContainerResources struct {
	DbContainer         *mongodb.MongoDBContainer
	MessageBusContainer *rabbitmq.RabbitMQContainer
	DbEnv               resources.DbEnv
	MessageBusEnv       resources.MessageBusEnv
}

type TestClientWorker

type TestClientWorker struct {
	Job               dtos.Job
	MessageBus        messageBus.MessageBus
	HeartbeatDuration time.Duration
	RunStarted        func(runId string)
	RunCanceled       func(runId string)
	// contains filtered or unexported fields
}

func (*TestClientWorker) CompleteRun

func (worker *TestClientWorker) CompleteRun(runId string) error

func (*TestClientWorker) FailRun

func (worker *TestClientWorker) FailRun(runId string) error

func (*TestClientWorker) Start

func (worker *TestClientWorker) Start(wg *sync.WaitGroup) error

func (*TestClientWorker) Stop

func (worker *TestClientWorker) Stop()