etcd

Documentation

Index

• func Check(ctx context.Context, etcdServers []string, etcdRoot string, ...) error
• type SvcDiscoveryRegistryImpl
  • func NewSvcDiscoveryRegistry(rootDirectory string, endpoints []string, watchNames []string, ...) (*SvcDiscoveryRegistryImpl, error)
  • func (r *SvcDiscoveryRegistryImpl) AddOption(opts ...grpc.DialOption)
  • func (r *SvcDiscoveryRegistryImpl) Close()
  • func (r *SvcDiscoveryRegistryImpl) DelData(ctx context.Context, key string) error
  • func (r *SvcDiscoveryRegistryImpl) GetClient() *clientv3.Client
  • func (r *SvcDiscoveryRegistryImpl) GetConn(ctx context.Context, serviceName string, opts ...grpc.DialOption) (grpc.ClientConnInterface, error)
  • func (r *SvcDiscoveryRegistryImpl) GetConns(ctx context.Context, serviceName string, opts ...grpc.DialOption) ([]grpc.ClientConnInterface, error)
  • func (r *SvcDiscoveryRegistryImpl) GetKey(ctx context.Context, key string) ([]byte, error)
  • func (r *SvcDiscoveryRegistryImpl) GetSelfConnTarget() string
  • func (r *SvcDiscoveryRegistryImpl) GetUserIdHashGatewayHost(ctx context.Context, userId string) (string, error)
  • func (r *SvcDiscoveryRegistryImpl) IsSelfNode(cc grpc.ClientConnInterface) bool
  • func (r *SvcDiscoveryRegistryImpl) Register(ctx context.Context, serviceName, host string, port int, ...) error
  • func (r *SvcDiscoveryRegistryImpl) SetKey(ctx context.Context, key string, data []byte) error
  • func (r *SvcDiscoveryRegistryImpl) UnRegister() error
  • func (r *SvcDiscoveryRegistryImpl) WatchKey(ctx context.Context, key string, fn discovery.WatchKeyHandler) error
• type ZkOption
  • func WithDialTimeout(timeout time.Duration) ZkOption
  • func WithMaxCallSendMsgSize(size int) ZkOption
  • func WithUsernameAndPassword(username, password string) ZkOption

Functions

func Check

func Check(ctx context.Context, etcdServers []string, etcdRoot string, createIfNotExist bool, options ...ZkOption) error

Check verifies if etcd is running by checking the existence of the root node and optionally creates it with a lease

Types

type SvcDiscoveryRegistryImpl

type SvcDiscoveryRegistryImpl struct {
	// contains filtered or unexported fields
}

SvcDiscoveryRegistryImpl implementation

func NewSvcDiscoveryRegistry

func NewSvcDiscoveryRegistry(rootDirectory string, endpoints []string, watchNames []string, options ...ZkOption) (*SvcDiscoveryRegistryImpl, error)

NewSvcDiscoveryRegistry creates a new service discovery registry implementation

func (*SvcDiscoveryRegistryImpl) AddOption

func (r *SvcDiscoveryRegistryImpl) AddOption(opts ...grpc.DialOption)

AddOption appends gRPC dial options to the existing options

func (*SvcDiscoveryRegistryImpl) Close

func (r *SvcDiscoveryRegistryImpl) Close()

Close closes the etcd client connection

func (*SvcDiscoveryRegistryImpl) DelData

func (r *SvcDiscoveryRegistryImpl) DelData(ctx context.Context, key string) error

func (*SvcDiscoveryRegistryImpl) GetClient

func (r *SvcDiscoveryRegistryImpl) GetClient() *clientv3.Client

func (*SvcDiscoveryRegistryImpl) GetConn

func (r *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 (r *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) GetKey

func (r *SvcDiscoveryRegistryImpl) GetKey(ctx context.Context, key string) ([]byte, error)

func (*SvcDiscoveryRegistryImpl) GetSelfConnTarget

func (r *SvcDiscoveryRegistryImpl) GetSelfConnTarget() string

GetSelfConnTarget returns the connection target for the current service

func (*SvcDiscoveryRegistryImpl) GetUserIdHashGatewayHost

func (r *SvcDiscoveryRegistryImpl) GetUserIdHashGatewayHost(ctx context.Context, userId string) (string, error)

GetUserIdHashGatewayHost returns the gateway host for a given user ID hash

func (*SvcDiscoveryRegistryImpl) IsSelfNode

func (r *SvcDiscoveryRegistryImpl) IsSelfNode(cc grpc.ClientConnInterface) bool

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) SetKey

func (r *SvcDiscoveryRegistryImpl) SetKey(ctx context.Context, key string, data []byte) error

func (*SvcDiscoveryRegistryImpl) UnRegister

func (r *SvcDiscoveryRegistryImpl) UnRegister() error

UnRegister removes the service endpoint from etcd

func (*SvcDiscoveryRegistryImpl) WatchKey

func (r *SvcDiscoveryRegistryImpl) WatchKey(ctx context.Context, key string, fn discovery.WatchKeyHandler) error

type ZkOption

type ZkOption func(*clientv3.Config)

ZkOption defines a function type for modifying clientv3.Config

func WithDialTimeout

func WithDialTimeout(timeout time.Duration) ZkOption

WithDialTimeout sets a custom dial timeout for the etcd client

func WithMaxCallSendMsgSize

func WithMaxCallSendMsgSize(size int) ZkOption

WithMaxCallSendMsgSize sets a custom max call send message size for the etcd client

func WithUsernameAndPassword

func WithUsernameAndPassword(username, password string) ZkOption

WithUsernameAndPassword sets a username and password for the etcd client