queue

Feb 20, 2023

Changes in this version

type Info

+ Retry int

Dec 9, 2022

Changes in this version

type Instance

+ func (this *Instance) Submit(next func())

Dec 9, 2022

Changes in this version

+ func DeferredEnqueue(name string, value Map, delay time.Duration) error

+ func DeferredEnqueueTo(conn, name string, value Map, delay time.Duration) error

type Connect

+ DeferredEnqueue func(name string, data []byte, delay time.Duration) error

type Context

+ func (ctx *Context) Finish()

+ type Delay = []time.Duration

+ type Info struct

+ Attempt int

+ Delay []time.Duration

+ Interval time.Duration

+ Name string

+ Thread int

type Module

+ func (this *Module) DeferredEnqueue(name string, value Map, delay time.Duration) error

+ func (this *Module) DeferredEnqueueTo(conn, name string, value Map, delay time.Duration) error

type Queue

+ Attempt int

+ Delay []time.Duration

+ Interval time.Duration

+ Thread int

+ type Request struct

+ Attempt int

+ Data []byte

+ Name string

+ Timestamp time.Time

+ type Response struct

+ Delay time.Duration

+ Retry bool

Oct 28, 2022

Changes in this version

type Context

+ Locals Map

Oct 20, 2022

Changes in this version

+ func EnqueueTo(conn, name string, datas ...[]byte) error

type Connect

+ Stop func() error

type Instance

+ Config Config

+ Name string

type Module

+ func (this *Module) EnqueueTo(conn, name string, datas ...[]byte) error

type Queue

+ Line int

Sep 15, 2022

Changes in this version

type Filter

+ Serve ctxFunc

Sep 14, 2022

Changes in this version

+ const NAME

+ func Configure(cfg Map)

+ func Enqueue(name string, values ...Map) error

+ func Go()

+ func Ready()

+ func Register(name string, value Any, overrides ...bool)

+ type Config struct

+ Codec string

+ Driver string

+ Prefix string

+ Setting Map

+ Weight int

+ type Configs map[string]Config

+ type Connect interface

+ Accept func(Delegate) error

+ Close func() error

+ Enqueue func(name string, data []byte) error

+ Health func() (Health, error)

+ Open func() error

+ Register func(name string) error

+ Start func() error

+ type Context struct

+ Alias string

+ Args Map

+ Body Any

+ Config *Queue

+ Name string

+ Setting Map

+ Value Map

+ func (ctx *Context) Denied(res Res)

+ func (ctx *Context) Erred(res Res)

+ func (ctx *Context) Failed(res Res)

+ func (ctx *Context) Found()

+ func (ctx *Context) Next()

+ func (ctx *Context) Retry()

+ type Delegate interface

+ Serve func(string, []byte)

+ type Driver interface

+ Connect func(name string, config Config) (Connect, error)

+ type Filter struct

+ Execute ctxFunc

+ Name string

+ Request ctxFunc

+ Response ctxFunc

+ Text string

+ type Handler struct

+ Denied ctxFunc

+ Error ctxFunc

+ Failed ctxFunc

+ Found ctxFunc

+ Name string

+ Text string

+ type Health struct

+ Workload int64

+ type Instance struct

+ func (this *Instance) Serve(name string, data []byte)

+ type Module struct

+ func (module *Module) Driver(name string, driver Driver, override bool)

+ func (module *Module) Filter(name string, config Filter, override bool)

+ func (module *Module) Handler(name string, config Handler, override bool)

+ func (module *Module) Notice(name string, config Notice, override bool)

+ func (module *Module) Queue(name string, config Queue, override bool)

+ func (this *Module) Config(name string, config Config, override bool)

+ func (this *Module) Configs(config Configs, override bool)

+ func (this *Module) Configure(global Map)

+ func (this *Module) Connect()

+ func (this *Module) Enqueue(name string, values ...Map) error

+ func (this *Module) Initialize()

+ func (this *Module) Launch()

+ func (this *Module) Register(name string, value Any, override bool)

+ func (this *Module) Terminate()

+ type Notice struct

+ Args Vars

+ Name string

+ Nullable bool

+ Text string

+ type Queue struct

+ Action ctxFunc

+ Actions []ctxFunc

+ Alias []string

+ Args Vars

+ Coding bool

+ Connect string

+ Denied ctxFunc

+ Error ctxFunc

+ Failed ctxFunc

+ Found ctxFunc

+ Name string

+ Nullable bool

+ Retry int

+ Setting Map

+ Text string