cluster

package module

Go to main page

Versions in this module

v1

v1.0.4

Jul 14, 2021

Changes in this version

type RegistrationTLS

+ ToClientTLSConfig func() (config *tls.Config, err error)

+ ToServerTLSConfig func() (config *tls.Config, err error)

type ServiceTLS

+ func (s ServiceTLS) ToClientTLSConfig() (config *tls.Config, err error)

+ func (s ServiceTLS) ToServerTLSConfig() (config *tls.Config, err error)

v1.0.3

Jul 12, 2021

Changes in this version

type Cluster

+ Close func()

v1.0.1

Jul 12, 2021

Changes in this version

type Registration

+ NodeId func() (nodeId string)

+ NodeName func() (nodeName string)

type Service

+ NodeName_ string

+ func (s Service) NodeId() (nodeId string)

+ func (s Service) NodeName() (nodeName string)

v1.0.0

Jul 12, 2021

Changes in this version

+ const ServiceEventTypePut

+ const ServiceEventTypeRem

+ const ServiceStatusClosing

+ const ServiceStatusRunning

+ type Cluster interface

+ Counter func(name string) (counter SharedCounter, err error)

+ GetLock func(name string, timeout time.Duration) (locker SharedLocker)

+ GetMap func(name string) (m SharedMap)

+ Join func() (err error)

+ Leave func() (err error)

+ func NewEtcdCluster(name string, options EtcdConnectOptions, tags ...string) (cluster Cluster, err error)

+ type EtcdConnectOptions struct

+ DialTimeout time.Duration

+ Endpoints []string

+ Password string

+ TLS *tls.Config

+ TTL time.Duration

+ Username string

+ type EtcdSharedCounter struct

+ func (counter *EtcdSharedCounter) AddAndGet(d int64) (v int64, err error)

+ func (counter *EtcdSharedCounter) Close()

+ func (counter *EtcdSharedCounter) CompareAndSet(expected int64, v int64) (ok bool, err error)

+ func (counter *EtcdSharedCounter) DecrementAndGet() (v int64, err error)

+ func (counter *EtcdSharedCounter) Get() (v int64, err error)

+ func (counter *EtcdSharedCounter) IncrementAndGet() (v int64, err error)

+ type EtcdSharedLocker struct

+ func (lock *EtcdSharedLocker) Lock() (err error)

+ func (lock *EtcdSharedLocker) UnLock() (err error)

+ type EtcdSharedMap struct

+ func (m *EtcdSharedMap) Clean() (err error)

+ func (m *EtcdSharedMap) Get(key string, value interface{}) (has bool, err error)

+ func (m *EtcdSharedMap) Keys() (keys []string, err error)

+ func (m *EtcdSharedMap) Put(key string, value interface{}, ttl time.Duration) (err error)

+ func (m *EtcdSharedMap) Rem(key string) (err error)

+ type Meta interface

+ Empty func() (ok bool)

+ Get func(key string) (value string, has bool)

+ Keys func() (keys []string)

+ Merge func(o ...Meta)

+ Put func(key string, value string)

+ Rem func(key string)

+ type Node struct

+ Id string

+ Name string

+ Status ServiceStatus

+ Tags []string

+ type Registration interface

+ Address func() (address string)

+ Group func() (group string)

+ Id func() (id string)

+ Meta func() (meta Meta)

+ Name func() (name string)

+ Protocol func() (protocol string)

+ Status func() (status Status)

+ TLS func() (registrationTLS RegistrationTLS)

+ Tags func() (tags []string)

+ type RegistrationEvent interface

+ Registration func() (registration Registration)

+ Type func() (eventType RegistrationEventType)

+ type RegistrationEventType interface

+ IsPut func() bool

+ IsRem func() bool

+ type RegistrationTLS interface

+ CA func() string

+ ClientCert func() string

+ ClientKey func() string

+ Enable func() bool

+ ServerCert func() string

+ ServerKey func() string

+ VerifySSL func() bool

+ type Service struct

+ Address_ string

+ Deleted bool

+ Group_ string

+ Id_ string

+ Local bool

+ Meta_ Meta

+ Name_ string

+ NodeId_ string

+ Protocol_ string

+ Status_ ServiceStatus

+ TLS_ RegistrationTLS

+ Tags_ []string

+ Version int64

+ func NewServiceFromJson(value []byte) (service Service, err error)

+ func (s Service) Address() (address string)

+ func (s Service) Group() (group string)

+ func (s Service) Id() (id string)

+ func (s Service) Meta() (meta Meta)

+ func (s Service) Name() (name string)

+ func (s Service) Protocol() (protocol string)

+ func (s Service) Status() (status Status)

+ func (s Service) TLS() (registrationTLS RegistrationTLS)

+ func (s Service) Tags() (tags []string)

+ type ServiceDiscovery interface

+ Close func()

+ Get func(group string, name string, tags ...string) (registration Registration, has bool, err error)

+ GetALL func(group string, name string, tags ...string) (registrations []Registration, has bool, err error)

+ Publish func(group string, name string, protocol string, address string, tags []string, ...) (registration Registration, err error)

+ UnPublish func(registration Registration) (err error)

+ type ServiceEvent struct

+ Registration_ Registration

+ Type_ RegistrationEventType

+ func (s ServiceEvent) Registration() (registration Registration)

+ func (s ServiceEvent) Type() (eventType RegistrationEventType)

+ type ServiceEventType string

+ func (s ServiceEventType) IsPut() bool

+ func (s ServiceEventType) IsRem() bool

+ type ServiceMeta map[string]string

+ func NewServiceMeta() ServiceMeta

+ func (meta ServiceMeta) Empty() bool

+ func (meta ServiceMeta) Get(key string) (string, bool)

+ func (meta ServiceMeta) Keys() []string

+ func (meta ServiceMeta) Merge(o ...Meta)

+ func (meta ServiceMeta) Put(key string, value string)

+ func (meta ServiceMeta) Rem(key string)

+ type ServiceStatus string

+ func (s ServiceStatus) Closing() bool

+ func (s ServiceStatus) Ok() bool

+ type ServiceTLS struct

+ CA_ string

+ ClientCert_ string

+ ClientKey_ string

+ Enable_ bool

+ ServerCert_ string

+ ServerKey_ string

+ VerifySSL_ bool

+ func (s ServiceTLS) CA() string

+ func (s ServiceTLS) ClientCert() string

+ func (s ServiceTLS) ClientKey() string

+ func (s ServiceTLS) Enable() bool

+ func (s ServiceTLS) ServerCert() string

+ func (s ServiceTLS) ServerKey() string

+ func (s ServiceTLS) VerifySSL() bool

+ type ServicesCache struct

+ func NewServicesCache() (c *ServicesCache, err error)

+ func (c *ServicesCache) Close()

+ func (c *ServicesCache) Get(group string, name string, tags ...string) (service Service, has bool)

+ func (c *ServicesCache) GetALL(group string, name string, tags ...string) (services []Service, has bool)

+ func (c *ServicesCache) GetALLLocaled() (services []Service)

+ func (c *ServicesCache) OnEvict(item *ristretto.Item)

+ func (c *ServicesCache) Put(services ...Service)

+ func (c *ServicesCache) Rem(services ...Service)

+ type SharedCounter interface

+ AddAndGet func(d int64) (v int64, err error)

+ Close func()

+ CompareAndSet func(expected int64, v int64) (ok bool, err error)

+ DecrementAndGet func() (v int64, err error)

+ Get func() (v int64, err error)

+ IncrementAndGet func() (v int64, err error)

+ func NewEtcdSharedCounter(name string, cli *etcd.Client) (counter SharedCounter, err error)

+ type SharedLocker interface

+ Lock func() (err error)

+ UnLock func() (err error)

+ type SharedMap interface

+ Clean func() (err error)

+ Get func(key string, value interface{}) (has bool, err error)

+ Keys func() (keys []string, err error)

+ Put func(key string, value interface{}, ttl time.Duration) (err error)

+ Rem func(key string) (err error)

+ type Status interface

+ Closing func() bool

+ Ok func() bool

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL