queue

type Config struct {
	Driver   string
	External bool
	Codec    string
	Weight   int
	Prefix   string
	Setting  Map
}

type Configs map[string]Config

type Connection interface {
	Open() error
	Close() error
	Start() error
	Stop() error

	Register(name string) error
	Publish(name string, data []byte) error
	DeferredPublish(name string, data []byte, delay time.Duration) error
}

type Context struct {
	*infra.Meta

	Name    string
	Config  *Queue
	Setting Map

	Value  Map
	Args   Map
	Locals Map

	Body Any
	// contains filtered or unexported fields
}

type Declare struct {
	Alias    []string `json:"alias"`
	Name     string   `json:"name"`
	Desc     string   `json:"desc"`
	Nullable bool     `json:"-"`
	Args     Vars     `json:"args"`
}

type Delay = []time.Duration

type Driver interface {
	Connect(*Instance) (Connection, error)
}

type Filter struct {
	Name     string  `json:"name"`
	Desc     string  `json:"desc"`
	Serve    ctxFunc `json:"-"`
	Request  ctxFunc `json:"-"`
	Execute  ctxFunc `json:"-"`
	Response ctxFunc `json:"-"`
}

type Handler struct {
	Name   string  `json:"name"`
	Desc   string  `json:"desc"`
	Found  ctxFunc `json:"-"`
	Error  ctxFunc `json:"-"`
	Failed ctxFunc `json:"-"`
	Denied ctxFunc `json:"-"`
}

type Instance struct {
	Name    string
	Config  Config
	Setting base.Map
	// contains filtered or unexported fields
}

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

type Queue struct {
	Alias    []string `json:"alias"`
	Name     string   `json:"name"`
	Desc     string   `json:"desc"`
	Nullable bool     `json:"-"`
	Args     Vars     `json:"args"`
	Setting  Map      `json:"setting"`

	Action  ctxFunc   `json:"-"`
	Actions []ctxFunc `json:"-"`

	Found  ctxFunc `json:"-"`
	Error  ctxFunc `json:"-"`
	Failed ctxFunc `json:"-"`
	Denied ctxFunc `json:"-"`

	Connect string `json:"connect"`
	Thread  int    `json:"thread"`
	Retry   Retry  `json:"retry"`
}

type Queues map[string]Queue

type Request struct {
	Name      string
	Data      []byte
	Attempt   int
	Timestamp time.Time
}

type Response struct {
	Retry bool
	Delay time.Duration
}

type Retry = []time.Duration