Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type WorkSource ¶ added in v15.4.0
type WorkerFactory ¶ added in v15.4.0
type WorkerFactory interface { New(agentId int64, source WorkSource) Worker SourcesFromConfiguration(*agentcfg.AgentConfiguration) []WorkSource }
type WorkerManager ¶ added in v15.4.0
type WorkerManager struct {
// contains filtered or unexported fields
}
func NewWorkerManager ¶ added in v15.4.0
func NewWorkerManager(log *zap.Logger, workerFactory WorkerFactory) *WorkerManager
func (*WorkerManager) ApplyConfiguration ¶ added in v15.4.0
func (m *WorkerManager) ApplyConfiguration(agentId int64, cfg *agentcfg.AgentConfiguration) error
func (*WorkerManager) StopAllWorkers ¶ added in v15.4.0
func (m *WorkerManager) StopAllWorkers()
Click to show internal directories.
Click to hide internal directories.