eventconsumer

Documentation

Index

• type Config
• type Service
  • func New(config Config, send func(event model.WsEvent) error, log *logrus.Logger) (*Service, error)
  • func (s *Service) ConsumeEvents()
  • func (s *Service) Run(ctx context.Context) error
  • func (s *Service) Shutdown(ctx context.Context) error

Types

type Config

type Config struct {
	QueueConnection    string `env:"RABBITMQ_CONNECTION,default=amqp://guest:guest@localhost:5672/"`
	QueueRoutingKey    string `env:"QUEUE_RKEY,default=00000"`
	QueueEventExchange string `env:"RABBITMQ_EVENT_EXCHANGE,default=Events"`
	QueueEventPrefix   string `env:"RABBITMQ_EVENT_QUEUE,default=Events"`
}

type Service

type Service struct {
	// contains filtered or unexported fields
}

func New

func New(config Config, send func(event model.WsEvent) error, log *logrus.Logger) (*Service, error)

func (*Service) ConsumeEvents

func (s *Service) ConsumeEvents()

func (*Service) Run

func (s *Service) Run(ctx context.Context) error

Run Group task

func (*Service) Shutdown

func (s *Service) Shutdown(ctx context.Context) error

Shutdown Group task gracefull shutdown