watermillqueue

Documentation

Index

• func New(redisClient *redis.Client, cfg config.Config, logger *zap.Logger, ...) (queue.QueueHandler, error)
• type WatermillClient
  • func (t *WatermillClient) Add(ctx context.Context, topic string, msg *queue.Message) error
  • func (t *WatermillClient) Close() error
  • func (t *WatermillClient) Start(context.Context)

Functions

func New

func New(redisClient *redis.Client,
	cfg config.Config,
	logger *zap.Logger,
	emailClient email.Client,
	userRepo malak.UserRepository,
	workspaceRepo malak.WorkspaceRepository,
	updateRepo malak.UpdateRepository,
	contactRepo malak.ContactRepository) (queue.QueueHandler, error)

Types

type WatermillClient

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

func (*WatermillClient) Add

func (t *WatermillClient) Add(ctx context.Context,
	topic string, msg *queue.Message) error

func (*WatermillClient) Close

func (t *WatermillClient) Close() error

func (*WatermillClient) Start

func (t *WatermillClient) Start(context.Context)