rpc

package

Go to main page

Versions in this module

v1

v1.0.3

Oct 19, 2018

Changes in this version

+ type AsyncCallback func(response CallResponse)

+ type CallOption func(*CallOptions)

+ func WithCallMeta(k, v interface{}) CallOption

+ func WithCallRequestTimeout(d time.Duration) CallOption

+ func WithCallResponseTimeout(d time.Duration) CallOption

+ type CallOptions struct

+ Meta map[interface{}]interface{}

+ RequestTimeout time.Duration

+ ResponseTimeout time.Duration

+ type CallResponse struct

+ Cause error

+ Opts CallOptions

+ ReadStart time.Time

+ Reply interface{}

+ Start time.Time

type Client

+ func (c *Client) AsyncCall(typ CodecType, addr, service, method string, args interface{}, ...) error

+ func (c *Client) CallOneway(typ CodecType, addr, service, method string, args interface{}, ...) error

type PendingResponse

+ func (r PendingResponse) GetCallResponse() CallResponse

v1.0.2

Aug 19, 2018

Changes in this version

+ type ErrorCode int16

v0

v0.9.3

Aug 7, 2018

Changes in this version

+ const CodecJson

+ const CodecProtobuf

+ const CodecUnknown

+ var CallType_name = map[int32]string

+ var CallType_value = map[string]int32

+ var ErrIllegalConf = "illegal conf: "

+ var ErrIntOverflowCodec = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthCodec = fmt.Errorf("proto: negative length found during unmarshaling")

+ type CallType int32

+ const CT_OneWay

+ const CT_TwoWay

+ const CT_TwoWayNoReply

+ const CT_UNKOWN

+ func (CallType) EnumDescriptor() ([]byte, []int)

+ func (x *CallType) UnmarshalJSON(data []byte) error

+ func (x CallType) Enum() *CallType

+ func (x CallType) MarshalJSON() ([]byte, error)

+ func (x CallType) String() string

type ClientConfig

+ PoolSize int

+ PoolTTL int

+ func (c *ClientConfig) CheckValidity() error

+ type CodecType int16

+ func GetCodecType(codecType string) CodecType

+ func (c CodecType) CheckValidity() bool

+ func (c CodecType) String() string

type GettyPackageHeader

+ PkgLen PkgLenType

type GettyRPCRequestHeader

+ func (*GettyRPCRequestHeader) Descriptor() ([]byte, []int)

+ func (*GettyRPCRequestHeader) ProtoMessage()

+ func (m *GettyRPCRequestHeader) Marshal() (dAtA []byte, err error)

+ func (m *GettyRPCRequestHeader) MarshalTo(dAtA []byte) (int, error)

+ func (m *GettyRPCRequestHeader) Reset()

+ func (m *GettyRPCRequestHeader) Size() (n int)

+ func (m *GettyRPCRequestHeader) Unmarshal(dAtA []byte) error

+ func (this *GettyRPCRequestHeader) Equal(that interface{}) bool

+ func (this *GettyRPCRequestHeader) GoString() string

+ func (this *GettyRPCRequestHeader) String() string

+ func (this *GettyRPCRequestHeader) VerboseEqual(that interface{}) error

type GettyRPCResponseHeader

+ func (*GettyRPCResponseHeader) Descriptor() ([]byte, []int)

+ func (*GettyRPCResponseHeader) ProtoMessage()

+ func (m *GettyRPCResponseHeader) Marshal() (dAtA []byte, err error)

+ func (m *GettyRPCResponseHeader) MarshalTo(dAtA []byte) (int, error)

+ func (m *GettyRPCResponseHeader) Reset()

+ func (m *GettyRPCResponseHeader) Size() (n int)

+ func (m *GettyRPCResponseHeader) Unmarshal(dAtA []byte) error

+ func (this *GettyRPCResponseHeader) Equal(that interface{}) bool

+ func (this *GettyRPCResponseHeader) GoString() string

+ func (this *GettyRPCResponseHeader) String() string

+ func (this *GettyRPCResponseHeader) VerboseEqual(that interface{}) error

+ type GettyRPCService interface

+ Service func() string

+ Version func() string

type GettySessionParam

+ func (c *GettySessionParam) CheckValidity() error

+ type LogIDType int32

+ type MagicType int32

+ type PkgLenType int32

+ type RegistryConfig struct

+ Addr string

+ IDC string

+ KeepaliveTimeout int

+ NodeID string

+ Root string

+ Type string

+ type SequenceType uint64

type Server

+ func (s *Server) Start()

type ServerConfig

+ ProfilePort int

+ func (c *ServerConfig) CheckValidity() error

+ type ServiceIDType int32

v0.9.1

Jul 6, 2018

Changes in this version

+ var Codecs = map[SerializeType]Codec

+ var ErrIllegalMagic = jerrors.New("package magic is not right.")

+ var ErrInvalidPackage = jerrors.New("invalid rpc package")

+ var ErrNotEnoughStream = jerrors.New("packet stream is not enough")

+ var ErrNotFoundServiceOrMethod = jerrors.New("server invalid service or method")

+ var ErrTooLargePackage = jerrors.New("package length is exceed the getty package's legal maximum length.")

+ type Client struct

+ func NewClient(confFile string) *Client

+ func (c *Client) AddPendingResponse(pr *PendingResponse)

+ func (c *Client) Call(service, method string, args interface{}, reply interface{}) error

+ func (c *Client) ClearPendingResponses() map[uint64]*PendingResponse

+ func (c *Client) Close()

+ func (c *Client) PendingResponseCount() int

+ func (c *Client) RemovePendingResponse(seq uint64) *PendingResponse

+ func (c *Client) Sequence() uint64

+ func (c *Client) SetCodecType(st SerializeType)

+ type ClientConfig struct

+ AppName string

+ ConnectionNum int

+ FailFastTimeout string

+ GettySessionParam GettySessionParam

+ HeartbeatPeriod string

+ Host string

+ Ports []string

+ ProfilePort int

+ ServerHost string

+ ServerPort int

+ SessionTimeout string

+ type Codec interface

+ Decode func(data []byte, i interface{}) error

+ Encode func(i interface{}) ([]byte, error)

+ type GettyErrorCode int32

+ const GettyFail

+ const GettyOK

+ type GettyPackage struct

+ B RPCPackage

+ H GettyPackageHeader

+ func (p *GettyPackage) Marshal() (*bytes.Buffer, error)

+ func (p *GettyPackage) Unmarshal(buf *bytes.Buffer) (int, error)

+ func (p GettyPackage) String() string

+ type GettyPackageHeader struct

+ Code GettyErrorCode

+ CodecType SerializeType

+ Command gettyCommand

+ LogID uint32

+ Magic uint32

+ Sequence uint64

+ ServiceID uint32

+ type GettyRPCHeaderLenType uint16

+ type GettyRPCRequest struct

+ func (req *GettyRPCRequest) GetBody() []byte

+ func (req *GettyRPCRequest) GetHeader() interface{}

+ func (req *GettyRPCRequest) Marshal(sz SerializeType, buf *bytes.Buffer) (int, error)

+ func (req *GettyRPCRequest) Unmarshal(sz SerializeType, buf *bytes.Buffer) error

+ type GettyRPCRequestHeader struct

+ CallType gettyCallType

+ Method string

+ Service string

+ type GettyRPCRequestPackage struct

+ H GettyPackageHeader

+ type GettyRPCResponse struct

+ func (resp *GettyRPCResponse) GetBody() []byte

+ func (resp *GettyRPCResponse) GetHeader() interface{}

+ func (resp *GettyRPCResponse) Marshal(sz SerializeType, buf *bytes.Buffer) (int, error)

+ func (resp *GettyRPCResponse) Unmarshal(sz SerializeType, buf *bytes.Buffer) error

+ type GettyRPCResponseHeader struct

+ Error string

+ type GettyRPCResponsePackage struct

+ H GettyPackageHeader

+ type GettySessionParam struct

+ CompressEncoding bool

+ KeepAlivePeriod string

+ MaxMsgLen int

+ PkgRQSize int

+ PkgWQSize int

+ SessionName string

+ TcpKeepAlive bool

+ TcpNoDelay bool

+ TcpRBufSize int

+ TcpReadTimeout string

+ TcpWBufSize int

+ TcpWriteTimeout string

+ WaitTimeout string

+ type JSONCodec struct

+ func (c JSONCodec) Decode(data []byte, i interface{}) error

+ func (c JSONCodec) Encode(i interface{}) ([]byte, error)

+ type PBCodec struct

+ func (c PBCodec) Decode(data []byte, i interface{}) error

+ func (c PBCodec) Encode(i interface{}) ([]byte, error)

+ type PendingResponse struct

+ func NewPendingResponse() *PendingResponse

+ type RPCPackage interface

+ GetBody func() []byte

+ GetHeader func() interface{}

+ Marshal func(SerializeType, *bytes.Buffer) (int, error)

+ Unmarshal func(sz SerializeType, buf *bytes.Buffer) error

+ func NewGettyRPCRequest() RPCPackage

+ func NewGettyRPCResponse() RPCPackage

+ type RpcClientHandler struct

+ func NewRpcClientHandler(client *Client) *RpcClientHandler

+ func (h *RpcClientHandler) OnClose(session getty.Session)

+ func (h *RpcClientHandler) OnCron(session getty.Session)

+ func (h *RpcClientHandler) OnError(session getty.Session, err error)

+ func (h *RpcClientHandler) OnMessage(session getty.Session, pkg interface{})

+ func (h *RpcClientHandler) OnOpen(session getty.Session) error

+ type RpcClientPackageHandler struct

+ func NewRpcClientPackageHandler() *RpcClientPackageHandler

+ func (p *RpcClientPackageHandler) Read(ss getty.Session, data []byte) (interface{}, int, error)

+ func (p *RpcClientPackageHandler) Write(ss getty.Session, pkg interface{}) error

+ type RpcServerHandler struct

+ func NewRpcServerHandler(maxSessionNum int, sessionTimeout time.Duration) *RpcServerHandler

+ func (h *RpcServerHandler) OnClose(session getty.Session)

+ func (h *RpcServerHandler) OnCron(session getty.Session)

+ func (h *RpcServerHandler) OnError(session getty.Session, err error)

+ func (h *RpcServerHandler) OnMessage(session getty.Session, pkg interface{})

+ func (h *RpcServerHandler) OnOpen(session getty.Session) error

+ type RpcServerPackageHandler struct

+ func NewRpcServerPackageHandler(server *Server) *RpcServerPackageHandler

+ func (p *RpcServerPackageHandler) Read(ss getty.Session, data []byte) (interface{}, int, error)

+ func (p *RpcServerPackageHandler) Write(ss getty.Session, pkg interface{}) error

+ type SerializeType byte

+ const JSON

+ const ProtoBuffer

+ type Server struct

+ func NewServer(confFile string) *Server

+ func (s *Server) Init()

+ func (s *Server) Register(rcvr interface{}) error

+ func (s *Server) Run()

+ func (s *Server) Stop()

+ type ServerConfig struct

+ AppName string

+ FailFastTimeout string

+ GettySessionParam GettySessionParam

+ Host string

+ Ports []string

+ SessionNumber int

+ SessionTimeout string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL