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(name string) error

	Start() error
	Stop() error

	Enqueue(name string, data []byte) error
}

type Context struct {
	chef.Meta

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

	Body Any
	// contains filtered or unexported fields
}

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 Instance struct {
	Name   string
	Config Config
	// contains filtered or unexported fields
}

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

type Notice struct {
	Name     string `json:"name"`
	Text     string `json:"text"`
	Nullable bool   `json:"nullable"`
	Args     Vars   `json:"args"`
}

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:"-"`

	Line    int    `json:"line"`
	Connect string `json:"connect"`
	Retry   int    `json:"retry"`
}