delivery

Documentation

Index

• type DeliveryService
  • func NewService(ctx context.Context, wg *sync.WaitGroup, cfg *config.Config, ...) (*DeliveryService, error)
  • func (s *DeliveryService) Run(ctx context.Context) error
  • func (s *DeliveryService) Shutdown(ctx context.Context)

Types

type DeliveryService

type DeliveryService struct {
	Logger      *logging.Logger
	RedisClient *redis.Client
	DeliveryMQ  *deliverymq.DeliveryMQ
	Handler     consumer.MessageHandler
	// contains filtered or unexported fields
}

func NewService

func NewService(ctx context.Context,
	wg *sync.WaitGroup,
	cfg *config.Config,
	logger *logging.Logger,
	handler consumer.MessageHandler,
) (*DeliveryService, error)

func (*DeliveryService) Run

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

func (*DeliveryService) Shutdown

func (s *DeliveryService) Shutdown(ctx context.Context)