Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ContextDependencies ¶
type ContextDependencies struct {
Alive *broadcast.BroadcastChannel[string]
Logs *broadcast.BroadcastChannel[string]
Stats *broadcast.BroadcastChannel[feeder.Stats]
Jobs *JobCollection
}
func NewContextDependencies ¶
func NewContextDependencies() *ContextDependencies
type JobCollection ¶
type JobCollection struct {
// contains filtered or unexported fields
}
func NewJobCollection ¶
func NewJobCollection() *JobCollection
func (*JobCollection) Add ¶
func (jc *JobCollection) Add(id, path string)
func (*JobCollection) Remove ¶
func (jc *JobCollection) Remove(id string)
func (*JobCollection) SetCancel ¶
func (jc *JobCollection) SetCancel(id string, cancel context.CancelFunc) error
func (*JobCollection) UpdateState ¶
func (jc *JobCollection) UpdateState(id string, state JobState) error
Click to show internal directories.
Click to hide internal directories.