Method Campaign

leader/election.go:42–50

Campaign starts a leader election. It will block until this node becomes a leader or context cancelled.

(ctx context.Context)

// Campaign starts a leader election. It will block until this node becomes a leader or context cancelled.
func (e *Election) Campaign(ctx context.Context) error {
	if err := e.driver.Campaign(ctx); err != nil {
		return fmt.Errorf("not elected: %w", err)
	}
	e.status.isLeader.Store(true)
	// trigger events
	e.dispatcher.Dispatch(ctx, OnStatusChanged, OnStatusChangedPayload{Status: e.status})
	return nil
}

// Resign gives up the leadership.
func (e *Election) Resign(ctx context.Context) error {