Documentation
¶
Index ¶
Constants ¶
View Source
const ( // NewSessionDefaultRetryCnt is the default retry times when create new session. NewSessionDefaultRetryCnt = 3 // NewSessionRetryUnlimited is the unlimited retry times when create new session. NewSessionRetryUnlimited = math.MaxInt64 )
Variables ¶
View Source
var ManagerSessionTTL = 60
ManagerSessionTTL is the etcd session's TTL in seconds. It's exported for testing.
Functions ¶
func GetOwnerInfo ¶
func GetOwnerInfo(ctx goctx.Context, elec *concurrency.Election, logPrefix, id string) (string, error)
GetOwnerInfo gets the owner information.
Types ¶
type Manager ¶
type Manager interface {
// ID returns the ID of the manager.
ID() string
// IsOwner returns whether the ownerManager is the owner.
IsOwner() bool
// SetOwner sets whether the ownerManager is the owner.
SetOwner(isOwner bool)
// GetOwnerID gets the owner ID.
GetOwnerID(ctx goctx.Context) (string, error)
// CampaignOwner campaigns the owner.
CampaignOwner(ctx goctx.Context) error
// Cancel cancels this etcd ownerManager campaign.
Cancel()
}
Manager is used to campaign the owner and manage the owner information.
func NewMockManager ¶
func NewMockManager(id string, cancel goctx.CancelFunc) Manager
NewMockManager creates a new mock Manager.
func NewOwnerManager ¶
func NewOwnerManager(etcdCli *clientv3.Client, prompt, id, key string, cancel goctx.CancelFunc) Manager
NewOwnerManager creates a new Manager.
Source Files
Click to show internal directories.
Click to hide internal directories.