coord

Documentation

Index

• type Coordinator
  • func NewCoordinator(resourceLock resourcelock.Interface, errChan chan<- error, ...) (Coordinator, error)
  • func (c Coordinator) Coordinate(ctx context.Context)
  • func (c Coordinator) IsLeader() bool
• type EventRecorderProvider
  • func (e EventRecorderProvider) GetEventRecorderFor(name string) record.EventRecorder
• type UnixSocketReporter
  • func NewUnixSocketReporter(pollInterval time.Duration, unixSockPath string, errChan chan error, ...) (UnixSocketReporter, error)
  • func (r UnixSocketReporter) Report(ctx context.Context)

Types

type Coordinator

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

func NewCoordinator

func NewCoordinator(resourceLock resourcelock.Interface, errChan chan<- error, isLeaderChan chan<- bool) (Coordinator, error)

func (Coordinator) Coordinate

func (c Coordinator) Coordinate(ctx context.Context)

func (Coordinator) IsLeader

func (c Coordinator) IsLeader() bool

type EventRecorderProvider

type EventRecorderProvider struct{}

func (EventRecorderProvider) GetEventRecorderFor

func (e EventRecorderProvider) GetEventRecorderFor(name string) record.EventRecorder

TODO: use a real recorder

type UnixSocketReporter

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

func NewUnixSocketReporter

func NewUnixSocketReporter(
	pollInterval time.Duration,
	unixSockPath string,
	errChan chan error,
	isLeaderChan chan bool,
	isLeaderFunc func() bool,
) (UnixSocketReporter, error)

func (UnixSocketReporter) Report

func (r UnixSocketReporter) Report(ctx context.Context)