gorpc

Sep 27, 2020

Changes in this version

+ const DEFAULT_RPC_TIMEOUT

+ func FromContext(ctx context.Context) (md metadata.Metadata)

+ func GetMetadata(ctx context.Context, key string) (value string)

+ func NewContext(md map[string]string, timeout int) context.Context

Sep 15, 2020

Changes in this version

+ const DISCOVERY_DEFAULT_INTERVAL

+ const DISCOVERY_DEFAULT_TTL

+ type Discovery struct

+ Endpoints []string

+ Interval int

+ RpcAddr string

+ ServiceName string

+ TTL int

+ type EndpointType int

+ const EndpointType_CONSUL

+ const EndpointType_ETCD

+ const EndpointType_MDNS

+ const EndpointType_ZOOKEEPER

+ func (t EndpointType) String() string

+ type GoRPC struct

+ func NewGoRPC(endpointType EndpointType) (g *GoRPC)

+ func (g *GoRPC) NewClient(endPoints ...string) (c client.Client)

+ func (g *GoRPC) NewServer(discovery *Discovery) (s server.Server)