queue

type ConsumerMany interface {
	Consume(events []orm.Event) error
	GetQueueName() string
	GetGroupName(suffix *string) string
}

type ConsumerManyByModulo interface {
	GetMaxModulo() int
	Consume(events []orm.Event) error
	GetQueueName(moduloID int) string
	GetGroupName(moduloID int, suffix *string) string
}

type ConsumerOne interface {
	Consume(event orm.Event) error
	GetQueueName() string
	GetGroupName(suffix *string) string
}

type ConsumerOneByModulo interface {
	GetMaxModulo() int
	Consume(event orm.Event) error
	GetQueueName(moduloID int) string
	GetGroupName(moduloID int, suffix *string) string
}

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