Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JobNode ¶
type JobNode struct {
*v1.RegistryJob
}
JobNode is a node to be stored in jobMap and JobPool
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) SyncJob ¶
func (j *JobPool) SyncJob(job *v1.RegistryJob)
SyncJob syncs JobPool with an incoming IntegrationJob job, considering its status
Source Files
Click to show internal directories.
Click to hide internal directories.