rpc

package

Go to main page

Versions in this module

v1

v1.3.0

Dec 13, 2020

v1.2.10

Jul 31, 2020

v1.2.9

Jun 23, 2020

v1.2.8

Apr 17, 2020

v1.2.7

Apr 1, 2020

v1.2.6

Mar 2, 2020

v1.2.5

Feb 15, 2020

v1.2.4

Feb 13, 2020

v1.2.3

Feb 10, 2020

v1.2.2

Jan 11, 2020

Changes in this version

type CallType

+ const CT_UNKNOWN

type GettyRPCRequestHeader

+ func (m *GettyRPCRequestHeader) XXX_DiscardUnknown()

+ func (m *GettyRPCRequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GettyRPCRequestHeader) XXX_Merge(src proto.Message)

+ func (m *GettyRPCRequestHeader) XXX_Size() int

+ func (m *GettyRPCRequestHeader) XXX_Unmarshal(b []byte) error

type GettyRPCResponseHeader

+ func (m *GettyRPCResponseHeader) XXX_DiscardUnknown()

+ func (m *GettyRPCResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GettyRPCResponseHeader) XXX_Merge(src proto.Message)

+ func (m *GettyRPCResponseHeader) XXX_Size() int

+ func (m *GettyRPCResponseHeader) XXX_Unmarshal(b []byte) error

v1.2.1

Sep 7, 2019

v1.2.0

Sep 7, 2019

v1.1.1

Sep 4, 2019

v1.1.0

Jul 27, 2019

Changes in this version

+ type RPCClientMap struct

+ func (m *RPCClientMap) Delete(key string)

+ func (m *RPCClientMap) Load(key string) (value *rpcClientArray, ok bool)

+ func (m *RPCClientMap) LoadOrStore(key string, value *rpcClientArray) (actual *rpcClientArray, loaded bool)

+ func (m *RPCClientMap) Range(f func(key string, value *rpcClientArray) bool)

+ func (m *RPCClientMap) Store(key string, value *rpcClientArray)

v1.0.5

Jun 8, 2019

v1.0.4

Mar 25, 2019

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