queue

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

type Configs map[string]Config

type Connect interface {
	Open() error
	Health() (Health, error)
	Close() error

	Register(Info) error

	Start() error
	Stop() error

	Enqueue(name string, data []byte) error
	DeferredEnqueue(name string, data []byte, delay time.Duration) error
}

type Context struct {
	chef.Meta

	// 以下几个字段必须独立
	// 要不然，Invoke的时候，会被修改掉
	Name    string
	Config  *Queue
	Setting Map

	Value  Map
	Args   Map
	Locals Map

	Body Any
	// contains filtered or unexported fields
}

type Delay = []time.Duration

type Delegate interface {
	Serve(string, []byte)
}

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

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

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

type Health struct {
	Workload int64
}

type Info struct {
	Name   string
	Thread int
	Retry  int
	Delay  []time.Duration
}

type Instance struct {
	Name   string
	Config Config
	// contains filtered or unexported fields
}

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

type Queue struct {
	Name     string   `json:"name"`
	Text     string   `json:"text"`
	Alias    []string `json:"alias"`
	Nullable bool     `json:"-"`
	Args     Vars     `json:"args"`
	Setting  Map      `json:"-"`
	Coding   bool     `json:"-"`

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

	// 路由单独可定义的处理器
	Found  ctxFunc `json:"-"`
	Error  ctxFunc `json:"-"`
	Failed ctxFunc `json:"-"`
	Denied ctxFunc `json:"-"`

	Connect string `json:"connect"`

	//Option
	Thread int `json:"thread"`
	// Attempt  int             `json:"attempt"`
	// Interval time.Duration   `json:"interval"`
	Retry int             `json:"retry"`
	Delay []time.Duration `json:"delay"`
}

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

type Response struct {
	Retry bool
	Delay time.Duration
}