dispatcher

Documentation

Index

• type DBDispatcher
  • func (d *DBDispatcher) Dispatch(ctx context.Context, event *entities.Event) error
• type Dispatcher
  • func NewDispatcher(log *zap.SugaredLogger, queue queue.TaskQueue, db *db.DB) Dispatcher

Types

type DBDispatcher

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

func (*DBDispatcher) Dispatch

func (d *DBDispatcher) Dispatch(ctx context.Context, event *entities.Event) error

type Dispatcher

type Dispatcher interface {
	Dispatch(ctx context.Context, event *entities.Event) error
}

Dispatcher is Event Dispatcher

func NewDispatcher

func NewDispatcher(log *zap.SugaredLogger, queue queue.TaskQueue, db *db.DB) Dispatcher