source

Documentation

Index

• type InitConfig
• type Manager
  • func NewManager(cfg *InitConfig) *Manager
  • func (m *Manager) AllReady() bool
  • func (m *Manager) Run(stopCh <-chan struct{}) error
• type Merger
• type PodConfigNotificationMode

Types

type InitConfig

type InitConfig struct {
	Namespace  string
	NodeName   types.NodeName
	SourceCfg  *config.SourceCfg
	KubeClient kubernetes.Interface
	Updates    chan<- kubetypes.PodUpdate
	Recorder   record.EventRecorder
}

type Manager

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

func NewManager

func NewManager(cfg *InitConfig) *Manager

func (*Manager) AllReady

func (m *Manager) AllReady() bool

func (*Manager) Run

func (m *Manager) Run(stopCh <-chan struct{}) error

Run starts all sources

type Merger

type Merger interface {
	// Merge invoked when a change from a source is received.  May also function as an incremental
	// merger if you wish to consume changes incrementally.  Must be reentrant when more than
	// one source is defined.
	Merge(source string, update interface{}) error
}

type PodConfigNotificationMode

type PodConfigNotificationMode int

PodConfigNotificationMode describes how changes are sent to the update channel.

const (
	// PodConfigNotificationUnknown is the default value for
	// PodConfigNotificationMode when uninitialized.
	PodConfigNotificationUnknown PodConfigNotificationMode = iota
	// PodConfigNotificationSnapshot delivers the full configuration as a SET whenever
	// any change occurs.
	PodConfigNotificationSnapshot
	// PodConfigNotificationSnapshotAndUpdates delivers an UPDATE and DELETE message whenever pods are
	// changed, and a SET message if there are any additions or removals.
	PodConfigNotificationSnapshotAndUpdates
	// PodConfigNotificationIncremental delivers ADD, UPDATE, DELETE, REMOVE, RECONCILE to the update channel.
	PodConfigNotificationIncremental
)