controller

Documentation

Index

• type Config
• type Manager
  • func NewManager(client *kubernetes.Clientset, cfg Config) *Manager
  • func (mgr *Manager) Run(ctx context.Context) error
• type QueueEventHandler
  • func NewQueueEventHandler() QueueEventHandler
  • func (qeh *QueueEventHandler) GetEventHandler() cache.ResourceEventHandler
  • func (qeh *QueueEventHandler) ProcessNextKey(ctx context.Context, process func(context.Context, interface{}) bool) bool

Types

type Config

type Config struct {
	AgentNodeLabels   string
	AgentNodeTaint    string
	AgentPodNamespace string
	AgentPodLabels    string
	ResyncInterval    time.Duration
}

type Manager

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

func NewManager

func NewManager(client *kubernetes.Clientset, cfg Config) *Manager

func (*Manager) Run

func (mgr *Manager) Run(ctx context.Context) error

type QueueEventHandler

type QueueEventHandler struct {
	workqueue.Interface
}

func NewQueueEventHandler

func NewQueueEventHandler() QueueEventHandler

func (*QueueEventHandler) GetEventHandler

func (qeh *QueueEventHandler) GetEventHandler() cache.ResourceEventHandler

func (*QueueEventHandler) ProcessNextKey

func (qeh *QueueEventHandler) ProcessNextKey(ctx context.Context, process func(context.Context, interface{}) bool) bool