sqs

Documentation

Index

• func NewSQS(appConfig *config.AppConfig) sqsiface.SQSAPI
• type Consumer
  • func NewConsumer(sqsSvc sqsiface.SQSAPI, appConfig *config.AppConfig, d database.Db, ...) Consumer
• type Producer
  • func NewFakeProducer(m monitoring.MetricsI) Producer
  • func NewProducer(appConfig *config.AppConfig, m monitoring.MetricsI) Producer

Functions

func NewSQS

func NewSQS(appConfig *config.AppConfig) sqsiface.SQSAPI

NewSQS - create new SQS instance

Types

type Consumer

type Consumer interface {
	Consume()
	Status(*config.AppConfig, monitoring.MetricsI) error
	// contains filtered or unexported methods
}

Consumer interface

func NewConsumer

func NewConsumer(sqsSvc sqsiface.SQSAPI, appConfig *config.AppConfig, d database.Db, m monitoring.MetricsI) Consumer

NewConsumer - creates new message queue consumer

type Producer

type Producer interface {
	Send(context.Context, *registryv1.Cluster) error
}

Producer interface

func NewFakeProducer

func NewFakeProducer(m monitoring.MetricsI) Producer

NewFakeProducer creates a fake producer

func NewProducer

func NewProducer(appConfig *config.AppConfig, m monitoring.MetricsI) Producer

NewProducer - create new message queue producer