pool

Documentation

Index

• type JobNode
  • func (f *JobNode) DeepCopy() structs.Item
  • func (f *JobNode) Equals(another structs.Item) bool
  • func (f *JobNode) Priority() int
• type JobPool
  • func NewJobPool(ch chan struct{}, compareFunc structs.CompareFunc) *JobPool
  • func (j *JobPool) Lock()
  • func (j *JobPool) SyncJob(job *v1.RegistryJob)
  • func (j *JobPool) Unlock()

Types

type JobNode

type JobNode struct {
	*v1.RegistryJob
}

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

func (*JobNode) Priority

func (f *JobNode) Priority() int

Priority returns Item's priority

type JobPool

type JobPool struct {
	Pending *structs.SortedUniqueList
	Running *structs.SortedUniqueList
	// contains filtered or unexported fields
}

JobPool stores current status of v1.RegistryJobs, who are in Pending status or Running status All operations for this pool should be done in thread-safe manner, using Lock and Unlock methods

func NewJobPool

func NewJobPool(ch chan struct{}, compareFunc structs.CompareFunc) *JobPool

NewJobPool is a constructor for a JobPool

func (*JobPool) Lock

func (j *JobPool) Lock()

Lock locks JobPool

func (*JobPool) SyncJob

func (j *JobPool) SyncJob(job *v1.RegistryJob)

SyncJob syncs JobPool with an incoming IntegrationJob job, considering its status

func (*JobPool) Unlock

func (j *JobPool) Unlock()

Unlock unlocks JobPool