rpc

Jun 16, 2022

Changes in this version

+ const BaseServicePath

+ func NewRoundRobinSelector() client.Selector

+ type BaseClient struct

+ func NewBaseClient(options *ClientOptions) (*BaseClient, error)

+ func (c *BaseClient) Broadcast(fn string, request, reply interface{}) error

+ func (c *BaseClient) Call(ctx context.Context, fn string, arg interface{}, reply interface{}) error

+ func (c *BaseClient) Call2(fn string, arg interface{}, reply interface{}) error

+ func (c *BaseClient) Close() error

+ func (c *BaseClient) Run() error

+ type BaseGRpcClient struct

+ AppId int64

+ Conn *grpc.ClientConn

+ Options *ClientOptions

+ func NewBaseGRpcClient(options *ClientOptions) *BaseGRpcClient

+ func (b *BaseGRpcClient) Init(options *ClientOptions)

+ func (b *BaseGRpcClient) Run() error

+ type BaseGRpcServer struct

+ AppId int64

+ Options *ServerOptions

+ RpcServer *grpc.Server

+ Socket net.Listener

+ func NewBaseGRpcServer(options *ServerOptions) *BaseGRpcServer

+ func (s *BaseGRpcServer) Run() error

+ type BaseServer struct

+ Options *ServerOptions

+ Srv *server.Server

+ func NewBaseServer(options *ServerOptions) *BaseServer

+ func (s *BaseServer) GetServerID() string

+ func (s *BaseServer) Register(name string, sv interface{})

+ func (s *BaseServer) Run() error

+ type Cli interface

+ Broadcast func(fn string, request, reply interface{}) error

+ Call func(ctx context.Context, fn string, request, reply interface{}) error

+ Close func() error

+ Run func() error

+ type ClientOptions struct

+ Addr string

+ EtcdServers []string

+ Name string

+ Port int

+ Selector client.Selector

+ type ExtraContext struct

+ func NewContext() *ExtraContext

+ func NewContextFrom(c context.Context) *ExtraContext

+ func (c *ExtraContext) GetReqExtra(k string) (string, bool)

+ func (c *ExtraContext) GetResExtra(k string) (string, bool)

+ func (c *ExtraContext) PutReqExtra(k string, v string) *ExtraContext

+ func (c *ExtraContext) PutResExtra(k string, v string) *ExtraContext

+ type RoundRobinSelector struct

+ func (s *RoundRobinSelector) Select(ctx context.Context, servicePath, serviceMethod string, args interface{}) string

+ func (s *RoundRobinSelector) SelectNext() string

+ func (s *RoundRobinSelector) UpdateServer(servers map[string]string)

+ type Runnable interface

+ Run func() error

+ type ServerOptions struct

+ Addr string

+ EtcdServers []string

+ MaxRecvMsgSize int

+ MaxSendMsgSize int

+ Name string

+ Network string

+ Port int