queue

type ConsumeCallback func(IMQCMessage)

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

type DelayProcessor interface {
	Start(done chan struct{})
	AppendMessage(msg Message, delaySeconds int64) error
}

type IComponentQueue interface {
	GetQueue(name string) (q IQueue)
}

type IMQC interface {
	Connect() error
	Consume(task TaskInfo, callback ConsumeCallback) (err error)
	Unconsume(queue string)
	Start()
	Close()
}

type IMQCMessage interface {
	MessageId() string
	RetryCount() int64
	Ack() error
	Nack(error) error
	Original() string
	GetMessage() Message
}

type IMQP interface {
	Push(key string, value Message) error
	DelayPush(key string, value Message, delaySeconds int64) error
	Count(key string) (int64, error)
	Close() error
}

type IQueue interface {
	Send(ctx context.Context, key string, value interface{}) error
	DelaySend(ctx context.Context, key string, value interface{}, delaySeconds int64) error
	Count(key string) (int64, error)
}

type Message interface {
	encoding.BinaryMarshaler
	Header() map[string]string
	Body() []byte
	String() string
}

type MqcResover interface {
	Name() string
	Resolve(configName string, setting config.Config) (IMQC, error)
}

type MqpResover interface {
	Name() string
	Resolve(setting config.Config, opts ...Option) (IMQP, error)
}

type MsgItem struct {
	HeaderMap xtypes.SMap     `json:"header"`
	BodyBytes json.RawMessage `json:"body"`
	ItemBytes json.RawMessage `json:"-"`
}

type MsgOption func(m *MsgWrap)

type MsgWrap struct {
	HeaderMap xtypes.SMap     `json:"header,omitempty"`
	BodyBytes json.RawMessage `json:"body"`
	// contains filtered or unexported fields
}

type Option func(*Options)

type Options struct {
	CfgData map[string]any
}

type StandardQueue interface {
	GetQueue(name string, opts ...Option) (q IQueue)
}

type TaskInfo interface {
	GetQueue() string
	GetConcurrency() int
	GetVisibilityTimeout() int
	GetBufferSize() int
}