Documentation
¶
Index ¶
- func Check(ctx context.Context, etcdServers []string, etcdRoot string, ...) error
- type CfgOption
- type SvcDiscoveryRegistryImpl
- func (cp SvcDiscoveryRegistryImpl) AddOption(opts ...grpc.DialOption)
- func (r *SvcDiscoveryRegistryImpl) Close()
- func (h SvcDiscoveryRegistryImpl) DelData(ctx context.Context, key string) error
- func (r *SvcDiscoveryRegistryImpl) GetClient() *clientv3.Client
- func (cp SvcDiscoveryRegistryImpl) GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (grpc.ClientConnInterface, error)
- func (cp SvcDiscoveryRegistryImpl) GetConns(ctx context.Context, serviceName string, opts ...grpc.DialOption) ([]grpc.ClientConnInterface, error)
- func (h SvcDiscoveryRegistryImpl) GetKey(ctx context.Context, key string) ([]byte, error)
- func (h SvcDiscoveryRegistryImpl) GetKeyWithPrefix(ctx context.Context, key string) ([][]byte, error)
- func (r SvcDiscoveryRegistryImpl) GetSelfConnTarget() string
- func (r SvcDiscoveryRegistryImpl) IsSelfNode(cc grpc.ClientConnInterface) bool
- func (r SvcDiscoveryRegistryImpl) Register(ctx context.Context, serviceName, host string, port int, ...) error
- func (h SvcDiscoveryRegistryImpl) SetKey(ctx context.Context, key string, data []byte) error
- func (h SvcDiscoveryRegistryImpl) SetWithLease(ctx context.Context, key string, val []byte, ttl int64) error
- func (r SvcDiscoveryRegistryImpl) UnRegister() error
- func (h SvcDiscoveryRegistryImpl) WatchKey(ctx context.Context, key string, fn discovery.WatchKeyHandler) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type CfgOption ¶
CfgOption defines a function type for modifying clientv3.Config
func WithDialTimeout ¶
WithDialTimeout sets a custom dial timeout for the etcd client
func WithMaxCallSendMsgSize ¶
WithMaxCallSendMsgSize sets a custom max call send message size for the etcd client
func WithUsernameAndPassword ¶
WithUsernameAndPassword sets a username and password for the etcd client
type SvcDiscoveryRegistryImpl ¶
type SvcDiscoveryRegistryImpl struct {
// contains filtered or unexported fields
}
SvcDiscoveryRegistryImpl implementation
func NewSvcDiscoveryRegistry ¶
func NewSvcDiscoveryRegistry(rootDirectory string, endpoints []string, watchNames []string, options ...CfgOption) (*SvcDiscoveryRegistryImpl, error)
NewSvcDiscoveryRegistry creates a new service discovery registry implementation
func (SvcDiscoveryRegistryImpl) AddOption ¶
func (cp SvcDiscoveryRegistryImpl) AddOption(opts ...grpc.DialOption)
AddOption appends gRPC dial options to the existing options
func (*SvcDiscoveryRegistryImpl) Close ¶
func (r *SvcDiscoveryRegistryImpl) Close()
func (*SvcDiscoveryRegistryImpl) GetClient ¶
func (r *SvcDiscoveryRegistryImpl) GetClient() *clientv3.Client
func (SvcDiscoveryRegistryImpl) GetConn ¶
func (cp SvcDiscoveryRegistryImpl) GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (grpc.ClientConnInterface, error)
GetConn returns a single gRPC client connection for a given service name
func (SvcDiscoveryRegistryImpl) GetConns ¶
func (cp SvcDiscoveryRegistryImpl) GetConns(ctx context.Context, serviceName string, opts ...grpc.DialOption) ([]grpc.ClientConnInterface, error)
GetConns returns gRPC client connections for a given service name
func (SvcDiscoveryRegistryImpl) GetKeyWithPrefix ¶
func (SvcDiscoveryRegistryImpl) GetSelfConnTarget ¶
func (r SvcDiscoveryRegistryImpl) GetSelfConnTarget() string
GetSelfConnTarget returns the connection target for the current service
func (SvcDiscoveryRegistryImpl) IsSelfNode ¶
func (r SvcDiscoveryRegistryImpl) IsSelfNode(cc grpc.ClientConnInterface) bool
IsSelfNode checks if the given client conn connects to the current service
func (SvcDiscoveryRegistryImpl) Register ¶
func (r SvcDiscoveryRegistryImpl) Register(ctx context.Context, serviceName, host string, port int, opts ...grpc.DialOption) error
Register registers a new service endpoint with etcd
func (SvcDiscoveryRegistryImpl) SetWithLease ¶
func (SvcDiscoveryRegistryImpl) UnRegister ¶
func (r SvcDiscoveryRegistryImpl) UnRegister() error
UnRegister removes the service endpoint from etcd
Source Files