Documentation
¶
Index ¶
- Variables
- type DynamicMembershipRegistry
- func (r *DynamicMembershipRegistry) Claim() (err error)
- func (r *DynamicMembershipRegistry) FinalizeClaim(ip string, nodenum int, members []*discovery.Member, lock *redsync.Mutex) (err error)
- func (r *DynamicMembershipRegistry) GetInventory() (inventory []*discovery.Member, err error)
- func (r *DynamicMembershipRegistry) Init(cfg *config.Cluster, ctx context.Context) (err error)
- func (r *DynamicMembershipRegistry) RemoveNode() (err error)
- func (r *DynamicMembershipRegistry) SaveNode() (err error)
- func (r *DynamicMembershipRegistry) StartEventLoop()
- func (r *DynamicMembershipRegistry) Stop() (err error)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrSerfRequired = errors.New("discovery-way must be 0 for dynamic membership (serf)") ErrKeyExpMustBeGreater = errors.New("redis-node-key-exp must be greater than event-loop-interval-sec") ErrRedisNotAvail = errors.New("redis not available") ErrInvalidOutboundIP = errors.New("invalid or missing outbound IP") )
Functions ¶
This section is empty.
Types ¶
type DynamicMembershipRegistry ¶
type DynamicMembershipRegistry struct {
NodeKey string
// contains filtered or unexported fields
}
func NewDynamicMembershipRegistry ¶
func NewDynamicMembershipRegistry() *DynamicMembershipRegistry
func (*DynamicMembershipRegistry) Claim ¶
func (r *DynamicMembershipRegistry) Claim() (err error)
func (*DynamicMembershipRegistry) FinalizeClaim ¶
func (*DynamicMembershipRegistry) GetInventory ¶
func (r *DynamicMembershipRegistry) GetInventory() (inventory []*discovery.Member, err error)
func (*DynamicMembershipRegistry) RemoveNode ¶
func (r *DynamicMembershipRegistry) RemoveNode() (err error)
func (*DynamicMembershipRegistry) SaveNode ¶
func (r *DynamicMembershipRegistry) SaveNode() (err error)
func (*DynamicMembershipRegistry) StartEventLoop ¶
func (r *DynamicMembershipRegistry) StartEventLoop()
func (*DynamicMembershipRegistry) Stop ¶
func (r *DynamicMembershipRegistry) Stop() (err error)
Source Files
Click to show internal directories.
Click to hide internal directories.