constraint

Feb 9, 2023

Changes in this version

+ type RunAfter interface

+ RunAfter func()

May 16, 2022

Changes in this version

+ var QueueGroup = "home_default_stream_group"

+ var QueueName = "home_default_stream"

+ type AfterRegistration interface

+ Boot func()

+ type Broker interface

+ Consumer func(job Job)

+ Loop func()

+ Push func(event interface{}, names ...string)

+ type Construct interface

+ Init func()

+ type Exit interface

+ Exit func()

+ type Job interface

+ Handler func()

+ type JobConfig struct

+ GroupName string

+ Message interface{}

+ QueueName string

+ type KernelServer interface

+ Exit func()

+ Init func()

+ Run func()

+ type RedisClient interface

+ GetClient func() *redis.Client

+ type Route interface

+ GetGroup func() string

+ GetRoutes func() map[*api.Config]func(c *gin.Context)

+ type ServiceProvider interface

+ type SetGroup interface

+ SetGroup func() string

+ type SetQueue interface

+ SetQueue func() string

+ type SetRoute interface

+ SetRoute func() string

+ type SetSerial interface

+ SetSerial func() bool

+ type Task struct

+ Event interface{}

+ Group string

+ ID string

+ Queue string

+ type Worker interface

+ Run func(job Job, task Task)