dispatcher

Documentation

Index

• type Dispatcher
  • func NewDispatcher(log *zap.SugaredLogger, queue taskqueue.TaskQueue, db *db.DB, ...) *Dispatcher
  • func (d *Dispatcher) Dispatch(ctx context.Context, event *entities.Event) error
  • func (d *Dispatcher) DispatchBatch(ctx context.Context, events []*entities.Event) error
  • func (d *Dispatcher) DispatchEndpoint(ctx context.Context, event *entities.Event, endpoints []*entities.Endpoint) error

Types

type Dispatcher

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

Dispatcher is Event Dispatcher

func NewDispatcher

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

func (*Dispatcher) Dispatch

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

func (*Dispatcher) DispatchBatch

func (d *Dispatcher) DispatchBatch(ctx context.Context, events []*entities.Event) error

func (*Dispatcher) DispatchEndpoint

func (d *Dispatcher) DispatchEndpoint(ctx context.Context, event *entities.Event, endpoints []*entities.Endpoint) error