event

type Config struct {
	Driver       string
	External     bool
	Codec        string
	Weight       int
	Workers      int
	Queue        int
	QueuePolicy  string
	DrainTimeout time.Duration
	Prefix       string
	Setting      Map
}

type Configs map[string]Config

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

	Register(name, group string) error
	Publish(name string, data []byte) error
}

type Context struct {
	*infra.Meta

	Name    string
	Config  *Event
	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 Driver interface {
	Connect(*Instance) (Connection, error)
}

type Event 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"`
}

type Events map[string]Event

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 PayloadError struct {
	Event  string
	Result Res
}