core

type CircuitBreaker interface {
	NewCircuitBreaker(name string) CircuitBreaker
	Run(fun func() error) error
	Available() bool
}

type CliOption interface {
	// contains filtered or unexported methods
}

type CliOptionFunc func(cli *Client)

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

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

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

type Encoder interface {
	Encode(v interface{}) ([]byte, error)
	Decode(data []byte, v interface{}) error
	String() string
	Value() uint8
}

type EndPoint struct {
	ServiceName string
	Host        string
	Port        string
	Proto       string
	Weight      int32
	IsAlive     bool
}

type Handler interface {
	Handler(ctx context.Context, _impl interface{}, enc Encoder, msg *Message, opt ...map[string]string)
}

type Message struct {
	ReqId      uint32
	Obj        string
	Func       string
	ReqData    []byte
	ReqHeader  map[string]string
	RespData   []byte
	RespHeader map[string]string
	Code       int32
	Desc       string
}

type Register interface {
	Register() error
	Deregister() error
}

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

type SrvOption interface {
	// contains filtered or unexported methods
}

type SrvOptionFun func(srv *Service)

type WKHeader struct{}

type WkError struct {
	Service string
	Code    int32
	Desc    string
}