worker

Documentation

Index

• type EventRepo
• type Marshaller
• type Notifier
• type Trigger
• type Worker
  • func New(ctx context.Context, wg *sync.WaitGroup, config configuration.Config, ...) (w *Worker, err error)
  • func (this *Worker) Do(msg model.ConsumerMessage) error
  • func (this *Worker) StartStatistics()

Types

type EventRepo

type EventRepo interface {
	Get(message model.ConsumerMessage) (eventDesc []model.EventMessageDesc, err error)
}

type Marshaller

type Marshaller interface {
	Unmarshal(desc model.EventMessageDesc) (value interface{}, err error)
}

type Notifier

type Notifier interface {
	NotifyError(desc model.EventMessageDesc, err error) error
}

type Trigger

type Trigger interface {
	Trigger(desc model.EventMessageDesc, value interface{}) error
}

type Worker

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

func New

func New(ctx context.Context, wg *sync.WaitGroup, config configuration.Config, eventRepo EventRepo, marshaller Marshaller, trigger Trigger, notifier Notifier) (w *Worker, err error)

func (*Worker) Do

func (this *Worker) Do(msg model.ConsumerMessage) error

func (*Worker) StartStatistics

func (this *Worker) StartStatistics()