registry

Documentation

Index

• Variables
• type EtcdOption
  • func WithTLS(tlsConfig *tls.Config) EtcdOption
• type Instance
• type Registry
  • func NewEtcdRegistry(etcdEndpoints []string, tenantID string, opts ...EtcdOption) Registry

Variables

var (
	// DefaultRegisterTTL default register ttl
	DefaultRegisterTTL = time.Second * 60
	// DefaultDialTimeout default dail timeout
	DefaultDialTimeout = time.Second * 5
)

Types

type EtcdOption

type EtcdOption func(*clientv3.Config)

EtcdOption etcd config option

func WithTLS

func WithTLS(tlsConfig *tls.Config) EtcdOption

WithTLS TLS certs

type Instance

type Instance interface {
	GetKey() string
	GetValue() string
}

Instance instance for registry

type Registry

type Registry interface {
	// Register register a instance to the registry.
	Register(ctx context.Context, ins Instance, ttl time.Duration) (context.CancelFunc, error)
}

Registry register or unregister instance to registry

func NewEtcdRegistry

func NewEtcdRegistry(etcdEndpoints []string, tenantID string, opts ...EtcdOption) Registry

NewEtcdRegistry new etcd registry