eventproducer

Documentation

Index

• type Config
• type Service
  • func New(config Config, log *logrus.Logger) (*Service, error)
  • func (s *Service) PublishEvent(ctx context.Context, userId int64, shardId string, event model.Event) error
  • 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/"`
	QueueEventExchange string `env:"RABBITMQ_EVENT_EXCHANGE,default=Events"`
}

type Service

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

func New

func New(config Config, log *logrus.Logger) (*Service, error)

func (*Service) PublishEvent

func (s *Service) PublishEvent(ctx context.Context, userId int64, shardId string, event model.Event) error

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 gracefully shutdown