worker

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

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

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

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

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