gb

Jan 31, 2023

Changes in this version

+ func GetLocalIP() (string, error)

+ type Discovery struct

+ func NewDiscovery(schema, key string, etcdEndpoints []string, dialTimeout int) (*Discovery, error)

+ func (d *Discovery) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOptions) (resolver.Resolver, error)

+ func (d *Discovery) Builder() error

+ func (d *Discovery) Close()

+ func (d *Discovery) DelDiscoveryServiceList(key string)

+ func (d *Discovery) DelServiceList(key string)

+ func (d *Discovery) GetValues() []string

+ func (d *Discovery) ResolveNow(options resolver.ResolveNowOptions)

+ func (d *Discovery) Scheme() string

+ func (d *Discovery) SetDiscoveryServiceList(key, val string)

+ func (d *Discovery) SetServiceList(key, val string)

+ type GrpcClient struct

+ func NewGrpcClient(opt *GrpcClientOption) (*GrpcClient, error)

+ func (c *GrpcClient) GetConn() (*grpc.ClientConn, context.Context, error)

+ type GrpcClientOption struct

+ ClientName string

+ ConnType ConnType

+ EtcdEndpoint []string

+ ServerAddr string

+ ServerName string

+ type GrpcServer struct

+ Listener net.Listener

+ Server *grpc.Server

+ ServerName string

+ func NewGrpcServer(opt *GrpcServerOption) (*GrpcServer, error)

+ func (s *GrpcServer) Run()

+ type GrpcServerOption struct

+ EtcdEndpoints []string

+ IP string

+ IsRegister bool

+ Lease int64

+ Port int

+ ServerName string

+ type Register struct

+ func NewRegister(opt *RegisterOption) (*Register, error)

+ func (s *Register) Close() error

+ func (s *Register) ListenLeaseRespChan()

+ type RegisterOption struct

+ DialTimeout time.Duration

+ EtcdEndpoints []string

+ Key string

+ Lease int64

+ Schema string

+ Val string

Sep 19, 2022

Changes in this version

+ type Client struct

+ func NewClient(opt *ClientOption) (*Client, error)

+ func (c *Client) GetConn() (*grpc.ClientConn, context.Context, error)

+ type ClientOption struct

+ CertFile string

+ ClientName string

+ ConnType ConnType

+ EtcdEndPoint []string

+ ServerAddr string

+ ServiceName string

+ type ConnType uint

+ const BalanceType

+ const DefaultType

+ type Server struct

+ Listener net.Listener

+ Name string

+ Server *grpc.Server

+ func NewServer(opt *ServerOption) (*Server, error)

+ func (s *Server) Run()

+ type ServerOption struct

+ CertFile string

+ EtcdEndPoints []string

+ IP string

+ IsRegister bool

+ KeyFile string

+ Lease int64

+ Name string

+ Port int