leadership

Documentation

Index

• type Manager
  • func NewManager(lr repo.LockedRepo, ec *etcdcli.Client, ...) (*Manager, error)
  • func (m *Manager) RequestAndBecomeMaster() bool

Types

type Manager

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

Manager is the node manager responsible for managing the online nodes

func NewManager

func NewManager(lr repo.LockedRepo, ec *etcdcli.Client, configFunc dtypes.GetSchedulerConfigFunc) (*Manager, error)

NewManager creates a new instance of the node manager

func (*Manager) RequestAndBecomeMaster

func (m *Manager) RequestAndBecomeMaster() bool

RequestAndBecomeMaster tries to acquire a lock from etcd. If the lock is successfully acquired, the function sets the server as the master and returns true. Otherwise, it returns false.