queue

Documentation

Index

• type ConsumerMany
• type ConsumerManyByModulo
• type ConsumerOne
• type ConsumerOneByModulo
• type ConsumerRunner
  • func NewConsumerRunner(ctx context.Context) *ConsumerRunner
  • func (r *ConsumerRunner) RunConsumerMany(consumer ConsumerMany, groupNameSuffix *string, prefetchCount int)
  • func (r *ConsumerRunner) RunConsumerManyByModulo(consumer ConsumerManyByModulo, groupNameSuffix *string, prefetchCount int)
  • func (r *ConsumerRunner) RunConsumerOne(consumer ConsumerOne, groupNameSuffix *string, prefetchCount int)
  • func (r *ConsumerRunner) RunConsumerOneByModulo(consumer ConsumerOneByModulo, groupNameSuffix *string, prefetchCount int)
• type ScalableConsumerRunner
  • func NewScalableConsumerRunner(ctx context.Context, redisPool string) *ScalableConsumerRunner
  • func (r *ScalableConsumerRunner) RunScalableConsumerMany(consumer ConsumerMany, groupNameSuffix *string, prefetchCount int)
  • func (r *ScalableConsumerRunner) RunScalableConsumerOne(consumer ConsumerOne, groupNameSuffix *string, prefetchCount int)

Types

type ConsumerMany

type ConsumerMany interface {
	Consume(ormService *beeorm.Engine, events []beeorm.Event) error
	GetQueueName() string
	GetGroupName(suffix *string) string
}

type ConsumerManyByModulo

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

type ConsumerOne

type ConsumerOne interface {
	Consume(ormService *beeorm.Engine, event beeorm.Event) error
	GetQueueName() string
	GetGroupName(suffix *string) string
}

type ConsumerOneByModulo

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

type ConsumerRunner

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

func NewConsumerRunner

func NewConsumerRunner(ctx context.Context) *ConsumerRunner

func (*ConsumerRunner) RunConsumerMany

func (r *ConsumerRunner) RunConsumerMany(consumer ConsumerMany, groupNameSuffix *string, prefetchCount int)

func (*ConsumerRunner) RunConsumerManyByModulo

func (r *ConsumerRunner) RunConsumerManyByModulo(consumer ConsumerManyByModulo, groupNameSuffix *string, prefetchCount int)

func (*ConsumerRunner) RunConsumerOne

func (r *ConsumerRunner) RunConsumerOne(consumer ConsumerOne, groupNameSuffix *string, prefetchCount int)

func (*ConsumerRunner) RunConsumerOneByModulo

func (r *ConsumerRunner) RunConsumerOneByModulo(consumer ConsumerOneByModulo, groupNameSuffix *string, prefetchCount int)

type ScalableConsumerRunner

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

func NewScalableConsumerRunner

func NewScalableConsumerRunner(ctx context.Context, redisPool string) *ScalableConsumerRunner

func (*ScalableConsumerRunner) RunScalableConsumerMany

func (r *ScalableConsumerRunner) RunScalableConsumerMany(consumer ConsumerMany, groupNameSuffix *string, prefetchCount int)

func (*ScalableConsumerRunner) RunScalableConsumerOne

func (r *ScalableConsumerRunner) RunScalableConsumerOne(consumer ConsumerOne, groupNameSuffix *string, prefetchCount int)