controller

Documentation

Index

• Constants
• type JobSync
  • func NewJobSync() *JobSync
  • func (j *JobSync) Initialize(runtimeClient framework.RuntimeClientInterface) error
  • func (j *JobSync) Name() string
  • func (j *JobSync) Run(stopCh <-chan struct{})
• type NodeResourceSync
  • func NewNodeResourceSync() *NodeResourceSync
  • func (nr *NodeResourceSync) Initialize(runtimeClient framework.RuntimeClientInterface) error
  • func (nr *NodeResourceSync) Name() string
  • func (nr *NodeResourceSync) Run(stopCh <-chan struct{})
• type QueueSync
  • func NewQueueSync() *QueueSync
  • func (qs *QueueSync) Initialize(runtimeClient framework.RuntimeClientInterface) error
  • func (qs *QueueSync) Name() string
  • func (qs *QueueSync) Run(stopCh <-chan struct{})

Constants

const (
	JobSyncControllerName = "JobSync"
	DefaultSyncRetryTimes = 3
	DefaultJobTTLSeconds  = 600
)

const (
	NodeResourceControllerName = "NodeResourceSync"
)

const (
	QueueSyncControllerName = "QueueSync"
)

Types

type JobSync

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

func NewJobSync

func NewJobSync() *JobSync

func (*JobSync) Initialize

func (j *JobSync) Initialize(runtimeClient framework.RuntimeClientInterface) error

func (*JobSync) Name

func (j *JobSync) Name() string

func (*JobSync) Run

func (j *JobSync) Run(stopCh <-chan struct{})

type NodeResourceSync

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

func NewNodeResourceSync

func NewNodeResourceSync() *NodeResourceSync

func (*NodeResourceSync) Initialize

func (nr *NodeResourceSync) Initialize(runtimeClient framework.RuntimeClientInterface) error

func (*NodeResourceSync) Name

func (nr *NodeResourceSync) Name() string

func (*NodeResourceSync) Run

func (nr *NodeResourceSync) Run(stopCh <-chan struct{})

type QueueSync

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

func NewQueueSync

func NewQueueSync() *QueueSync

func (*QueueSync) Initialize

func (qs *QueueSync) Initialize(runtimeClient framework.RuntimeClientInterface) error

func (*QueueSync) Name

func (qs *QueueSync) Name() string

func (*QueueSync) Run

func (qs *QueueSync) Run(stopCh <-chan struct{})