leaderelection

Documentation

Index

• type Client
  • func New(client v1.CoordinationV1Interface, lockName string, namespace string, ...) *Client
  • func (c *Client) RegisterOnNew(callback func(currentID string, lockID string)) *Client
  • func (c *Client) RegisterOnStart(callback func(c context.Context)) *Client
  • func (c *Client) RegisterOnStop(callback func()) *Client
  • func (c *Client) Run(ctx context.Context)

Types

type Client

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

func New

func New(
	client v1.CoordinationV1Interface,
	lockName string,
	namespace string,
	identity string,
	leaseDuration time.Duration,
	renewDeadline time.Duration,
	retryPeriod time.Duration,
	releaseOnCancel bool,
) *Client

func (*Client) RegisterOnNew

func (c *Client) RegisterOnNew(callback func(currentID string, lockID string)) *Client

func (*Client) RegisterOnStart

func (c *Client) RegisterOnStart(callback func(c context.Context)) *Client

func (*Client) RegisterOnStop

func (c *Client) RegisterOnStop(callback func()) *Client

func (*Client) Run

func (c *Client) Run(ctx context.Context)