queue

Apr 30, 2024

Changes in this version

type Options

+ func DefaultOptions() *Options

type TaskInfo

+ GetMeta func() metadata.Metadata

Mar 8, 2024

Changes in this version

type TaskInfo

+ GetBufferSize func() int

+ GetVisibilityTimeout func() int

Jan 31, 2024

Changes in this version

+ type DelayCallback func(key string, msgList ...Message) error

+ type DelayProcessor interface

+ AppendMessage func(msg Message, delaySeconds int64) error

+ Start func(done chan struct{})

type MsgItem

+ BodyBytes json.RawMessage

+ ItemBytes json.RawMessage

+ func (w MsgItem) MarshalBinary() (data []byte, err error)

type MsgWrap

+ BodyBytes json.RawMessage

+ func (w MsgWrap) MarshalBinary() (data []byte, err error)

Nov 28, 2023

Changes in this version

+ const QueueKey

+ var MaxRetrtCount int64 = 3

+ type MqcResover interface

+ Name func() string

+ Resolve func(configName string, setting config.Config) (IMQC, error)

+ type MqpResover interface

+ Name func() string

+ Resolve func(setting config.Config, opts ...Option) (IMQP, error)

Nov 24, 2023

Changes in this version

+ type MsgOption func(m *MsgWrap)

type Option

+ func WithDBIndex(idx int) Option

+ func WithOption(key string, val any) Option

+ func WithPoolSize(size int) Option

+ type Options struct

+ CfgData map[string]any

Jan 9, 2024

Changes in this version

type IMQCMessage

+ MessageId func() string

Sep 19, 2023

Changes in this version

type Message

+ func NewMsg(obj interface{}, opts ...Option) (msg Message, err error)

+ type MsgWrap struct

+ BodyMap xtypes.XMap

+ HeaderMap xtypes.SMap

+ func (w *MsgWrap) Body() map[string]interface{}

+ func (w *MsgWrap) Header() map[string]string

+ func (w *MsgWrap) String() string

+ type Option func(m *MsgWrap)

+ func WithHeader(key, val string) Option

+ func WithXRequestID(reqId string) Option

Aug 2, 2023

Changes in this version

+ var DefaultMaxQueueLen = 100

+ type TaskInfo interface

+ GetConcurrency func() int

+ GetQueue func() string

Sep 1, 2022

Changes in this version

type IMQP

+ DelayPush func(key string, value Message, delaySeconds int64) error

type IQueue

+ DelaySend func(ctx context.Context, key string, value interface{}, delaySeconds int64) error

Aug 1, 2022

Changes in this version

type IMQCMessage

+ RetryCount func() int64

Jun 30, 2022

Changes in this version

+ const TypeNode

+ var Nil error = errors.New("Queue Nil")

+ func DeregisterProducer(name string)

+ func DeregisterrConsumer(name string)

+ func NewBuilder() container.StandardBuilder

+ func RegisterConsumer(resolver mqcResover)

+ func RegisterProducer(resolver imqpResover)

+ type ConsumeCallback func(IMQCMessage)

+ type IComponentQueue interface

+ GetQueue func(name string) (q IQueue)

+ type IMQC interface

+ Close func()

+ Connect func() error

+ Consume func(queue string, callback ConsumeCallback) (err error)

+ Start func()

+ Unconsume func(queue string)

+ func NewMQC(proto string, setting config.Config) (IMQC, error)

+ type IMQCMessage interface

+ Ack func() error

+ GetMessage func() Message

+ Nack func(error) error

+ Original func() string

+ type IMQP interface

+ Close func() error

+ Count func(key string) (int64, error)

+ Push func(key string, value Message) error

+ func NewMQP(proto string, setting config.Config) (IMQP, error)

+ type IQueue interface

+ Count func(key string) (int64, error)

+ Send func(ctx context.Context, key string, value interface{}) error

+ type Message interface

+ Body func() map[string]interface{}

+ Header func() map[string]string

+ String func() string

+ type MsgItem struct

+ BodyMap xtypes.XMap

+ HeaderMap xtypes.SMap

+ func (w *MsgItem) Body() map[string]interface{}

+ func (w *MsgItem) Header() map[string]string

+ func (w *MsgItem) String() string

+ type StandardQueue interface

+ GetQueue func(name ...string) (q IQueue)

+ func NewStandardQueue(c container.Container) StandardQueue