model

type Protocol interface {
	RequestPack(*requestf.RequestPacket) ([]byte, error)
	ResponseUnpack([]byte) (*requestf.ResponsePacket, error)
	ParsePackage([]byte) (int, int)
}

type Servant interface {
	Name() string
	TarsInvoke(ctx context.Context, cType byte,
		sFuncName string,
		buf []byte,
		status map[string]string,
		context map[string]string,
		resp *requestf.ResponsePacket) error
	TarsSetTimeout(t int)
	TarsSetProtocol(Protocol)
	Endpoints() []*endpoint.Endpoint
	SetPushCallback(callback func([]byte))
}