leaderelection

Dec 12, 2016

Changes in this version

type LeaderElectionConfig

+ Lock rl.Interface

Apr 22, 2016

Changes in this version

+ const DefaultLeaseDuration

+ const DefaultRenewDeadline

+ const DefaultRetryPeriod

+ const JitterFactor

+ const LeaderElectionRecordAnnotationKey

+ func BindFlags(l *componentconfig.LeaderElectionConfiguration, fs *pflag.FlagSet)

+ func DefaultLeaderElectionConfiguration() componentconfig.LeaderElectionConfiguration

+ func RunOrDie(lec LeaderElectionConfig)

+ type LeaderCallbacks struct

+ OnNewLeader func(identity string)

+ OnStartedLeading func(stop <-chan struct{})

+ OnStoppedLeading func()

+ type LeaderElectionConfig struct

+ Callbacks LeaderCallbacks

+ Client client.Interface

+ EndpointsMeta api.ObjectMeta

+ EventRecorder record.EventRecorder

+ Identity string

+ LeaseDuration time.Duration

+ RenewDeadline time.Duration

+ RetryPeriod time.Duration

+ type LeaderElectionRecord struct

+ AcquireTime unversioned.Time

+ HolderIdentity string

+ LeaderTransitions int

+ LeaseDurationSeconds int

+ RenewTime unversioned.Time

+ type LeaderElector struct

+ func NewLeaderElector(lec LeaderElectionConfig) (*LeaderElector, error)

+ func (le *LeaderElector) GetLeader() string

+ func (le *LeaderElector) IsLeader() bool

+ func (le *LeaderElector) Run()