pool

Documentation

Index

• func New(ch chan struct{}, compareFunc structs.CompareFunc) *jobPool
• type JobNode
  • func (f *JobNode) DeepCopy() structs.Item
  • func (f *JobNode) Equals(another structs.Item) bool
• type JobPool

Functions

func New

func New(ch chan struct{}, compareFunc structs.CompareFunc) *jobPool

New is a constructor for a jobPool

Types

type JobNode

type JobNode struct {
	*v1.IntegrationJob
}

JobNode is a node to be stored in jobMap and jobPool

func (*JobNode) DeepCopy

func (f *JobNode) DeepCopy() structs.Item

DeepCopy implements Item's method

func (*JobNode) Equals

func (f *JobNode) Equals(another structs.Item) bool

Equals implements Item's method

type JobPool

type JobPool interface {
	Lock()
	Unlock()
	SyncJob(job *v1.IntegrationJob)
	Running() structs.SortedUniqueList
	Pending() structs.SortedUniqueList
}

JobPool is an interface of jobPool