supervisor

Documentation

Index

• type Supervisor
  • func NewSupervisor(logger *log.Entry, sqs sqsiface.SQSAPI, httpClient httpClient, ...) *Supervisor
  • func (s *Supervisor) Shutdown()
  • func (s *Supervisor) Start(numWorkers int)
  • func (s *Supervisor) Wait()
• type WorkerConfig

Types

type Supervisor

type Supervisor struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSupervisor

func NewSupervisor(logger *log.Entry, sqs sqsiface.SQSAPI, httpClient httpClient, config WorkerConfig) *Supervisor

func (*Supervisor) Shutdown

func (s *Supervisor) Shutdown()

func (*Supervisor) Start

func (s *Supervisor) Start(numWorkers int)

func (*Supervisor) Wait

func (s *Supervisor) Wait()

type WorkerConfig

type WorkerConfig struct {
	QueueURL         string
	QueueMaxMessages int
	QueueWaitTime    int

	HTTPURL         string
	HTTPContentType string

	HTTPHMACHeader string
	HMACSecretKey  []byte
}