dogrpc

Dec 20, 2021

Changes in this version

+ func Use(filters []Filter)

type RpcClient

+ RpcCaPemFile string

+ RpcClientKeyFile string

+ RpcClientPemFile string

+ TlsCfg *tls.Config

type RpcServer

+ RpcCaPemFile string

+ RpcServerKeyFile string

+ RpcServerPemFile string

+ UseTls bool

Jan 25, 2021

Changes in this version

type RpcServer

+ Addr int

+ func (s *RpcServer) Close()

+ func (s *RpcServer) Start() error

Aug 6, 2020

Changes in this version

+ const DefaultBufferSize

+ const DefaultConcurrency

+ const DefaultConnectNumbers

+ const DefaultDialNetWork

+ const DefaultDialRetryTime

+ const DefaultFlushDelay

+ const DefaultPendingMessages

+ const DefaultRequestTimeout

+ const EOH

+ const HeaderLen

+ const Padding

+ const SOH

+ const Version

+ var InternalServerError = error.SetCodeType(10003, "interval server error.")

+ var InvalidParam = error.SetCodeType(10004, "invalid param")

+ var OverflowError = error.SetCodeType(10002, "overflow error.")

+ var TimeOutError = error.SetCodeType(10001, "timeout error.")

+ func InitFilters(filters []Filter)

+ func Return(code uint32, message string, err error, result interface{}) (resp []byte)

+ type AsyncResult struct

+ Done chan struct{}

+ Error error

+ Request Packet

+ Response Packet

+ func (m *AsyncResult) Cancel()

+ type Client struct

+ Addr string

+ Conns int

+ Decoder MessageDecoderFunc

+ Dial DialFunc

+ DialRetryTime int

+ Encoder MessageEncoderFunc

+ FlushDelay time.Duration

+ PendingRequests int

+ RecvBufferSize int

+ RequestTimeout time.Duration

+ SendBufferSize int

+ func (c *Client) Call(req Packet) (rsp Packet, err *dogError.CodeError)

+ func (c *Client) CallAsync(req Packet, skipResponse bool) (*AsyncResult, *dogError.CodeError)

+ func (c *Client) CallRetry(req Packet, retryNum uint32) (rsp Packet, err *dogError.CodeError)

+ func (c *Client) CallTimeout(req Packet, timeout time.Duration, retryNum uint32) (rsp Packet, err *dogError.CodeError)

+ func (c *Client) SendUDP(req Packet) (err *dogError.CodeError)

+ func (c *Client) Start()

+ func (c *Client) Stop()

+ type Context struct

+ ClientAddr string

+ Handler RpcHandlerFunc

+ Method string

+ Req []byte

+ Seq uint32

+ type DialFunc func(addr string) (conn io.ReadWriteCloser, err error)

+ type DogPacket struct

+ Body []byte

+ func NewDogPacket(cmd uint32, body []byte) *DogPacket

+ func NewDogPacketWithRet(cmd uint32, body []byte, seq uint32, ret uint32) *DogPacket

+ func NewDogPacketWithSeq(cmd uint32, body []byte, seq uint32) *DogPacket

+ func (p *DogPacket) ID() uint32

+ func (p *DogPacket) SetErrCode(code uint32)

+ type DogPacketDecoder struct

+ func (d *DogPacketDecoder) Decode() (Packet, error)

+ type DogPacketEncoder struct

+ func (e *DogPacketEncoder) Encode(p Packet) error

+ func (e *DogPacketEncoder) Flush() error

+ type Filter interface

+ Handle func(cxt *Context) (uint32, []byte)

+ SetNext func(filter Filter)

+ type Filters struct

+ Filters []Filter

+ func (f *Filters) Handle(ctx *Context) (uint32, []byte)

+ type GlFilter struct

+ IfLogAll bool

+ SlowCostThreshold int

+ func (f *GlFilter) Handle(ctx *Context) (code uint32, rsp []byte)

+ func (f *GlFilter) SetNext(filter Filter)

+ type HandlerFunc func(clientAddr string, req Packet) (rsp Packet)

+ type Header struct

+ CheckSum uint32

+ Cmd uint32

+ EOH uint8

+ ErrCode uint32

+ PacketLen uint32

+ Padding uint8

+ SOH uint8

+ Seq uint32

+ Version uint8

+ type Listener interface

+ Accept func() (conn io.ReadWriteCloser, clientAddr string, err error)

+ Close func() error

+ Init func(addr string) error

+ ListenAddr func() net.Addr

+ type LogFilter struct

+ IfLogAll bool

+ SlowCostThreshold int

+ func (f *LogFilter) Handle(ctx *Context) (code uint32, rsp []byte)

+ func (f *LogFilter) SetNext(filter Filter)

+ type MessageDecoder interface

+ Decode func() (Packet, error)

+ type MessageDecoderFunc func(r io.Reader, bufferSize int) (decoder MessageDecoder, err error)

+ type MessageEncoder interface

+ Encode func(msg Packet) error

+ Flush func() error

+ type MessageEncoderFunc func(w io.Writer, bufferSize int) (encoder MessageEncoder, err error)

+ type Packet interface

+ ID func() uint32

+ SetErrCode func(code uint32)

+ type RpcClient struct

+ Cm map[string]*Client

+ RetryNum uint32

+ Timeout time.Duration

+ func NewClient(timeout time.Duration, retryNum uint32) *RpcClient

+ func (c *RpcClient) AddAddr(addr string)

+ func (c *RpcClient) Connect() (*Client, error)

+ func (c *RpcClient) DogConnect() (*Client, error)

+ func (c *RpcClient) DogInvoke(cmd uint32, req []byte, client ...*Client) (code uint32, rsp []byte, err *dogError.CodeError)

+ func (c *RpcClient) Invoke(cmd uint32, req []byte, client ...*Client) (code uint32, rsp []byte, err *dogError.CodeError)

+ func (c *RpcClient) Stop()

+ type RpcHandlerFunc func([]byte) (uint32, []byte)

+ type RpcPacket struct

+ Body []byte

+ Cmd uint32

+ ErrCode uint32

+ PacketLen uint32

+ Seq uint32

+ func NewRpcPacket(cmd uint32, body []byte) *RpcPacket

+ func NewRpcPacketWithRet(cmd uint32, body []byte, seq uint32, ret uint32) *RpcPacket

+ func NewRpcPacketWithSeq(cmd uint32, body []byte, seq uint32) *RpcPacket

+ func (p *RpcPacket) ID() uint32

+ func (p *RpcPacket) SetErrCode(code uint32)

+ type RpcPacketDecoder struct

+ func (d *RpcPacketDecoder) Decode() (Packet, error)

+ type RpcPacketEncoder struct

+ func (e *RpcPacketEncoder) Encode(p Packet) error

+ func (e *RpcPacketEncoder) Flush() error

+ type RpcServer struct

+ func NewDogRpcServer() *RpcServer

+ func NewRpcServer() *RpcServer

+ func (s *RpcServer) AddDogHandler(headCmd uint32, f interface{})

+ func (s *RpcServer) AddHandler(headCmd uint32, f RpcHandlerFunc)

+ func (s *RpcServer) DogRpcRegister() error

+ func (s *RpcServer) GetAddr() string

+ func (s *RpcServer) Run(port int) error

+ func (s *RpcServer) SetAddr(addr string)

+ func (s *RpcServer) Stop()

+ type Server struct

+ Addr string

+ Concurrency int

+ Decoder MessageDecoderFunc

+ Encoder MessageEncoderFunc

+ FlushDelay time.Duration

+ Handler HandlerFunc

+ Listener Listener

+ PendingResponses int

+ RecvBufferSize int

+ SendBufferSize int

+ func (s *Server) Serve() *dogError.CodeError

+ func (s *Server) Start() *dogError.CodeError

+ func (s *Server) Stop()