bus

type Bridge struct{}

type Callback = func([]byte, error)

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

	Request(name string, data []byte, timeout time.Duration) ([]byte, error)
}

type Context struct {
	chef.Meta

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

	Type string
	Body Map
	// contains filtered or unexported fields
}

type Delegate interface {
	Serve(name string, data []byte, callback Callback)
}

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

type Filter struct {
	Name     string  `json:"name"`
	Text     string  `json:"text"`
	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
}