queue

package
v1.3.60 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 11, 2023 License: GPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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 added in v1.1.18

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

func NewScalableConsumerRunner added in v1.1.18

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

func (*ScalableConsumerRunner) RunScalableConsumerMany added in v1.1.18

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

func (*ScalableConsumerRunner) RunScalableConsumerOne added in v1.1.18

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL