Documentation ¶
Index ¶
- Constants
- type BaseProvider
- type Daemon
- func (dm *Daemon) GetClient() types.Client
- func (dm *Daemon) GetCluster() *cluster.Cluster
- func (dm *Daemon) GetContext() common.Context
- func (dm *Daemon) GetDaemonConfig() common.DaemonConfig
- func (dm *Daemon) GetJobRepository() job.Repository
- func (dm *Daemon) GetTMConfig() cfg.Config
- func (dm *Daemon) ID() string
- func (dm *Daemon) IsLeaderNode() bool
- func (dm *Daemon) RegisterWorkerFactory(factory worker.Factory)
- func (dm *Daemon) SetJobOrganizer(organizer job.Organizer)
- func (dm *Daemon) Start()
- type Provider
- type StartedEvent
Constants ¶
View Source
const (
StartedEventPath = types.EventPath("daemon-started")
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseProvider ¶
type Daemon ¶
type Daemon struct {
// contains filtered or unexported fields
}
func (*Daemon) GetCluster ¶
func (*Daemon) GetContext ¶
func (*Daemon) GetDaemonConfig ¶
func (dm *Daemon) GetDaemonConfig() common.DaemonConfig
func (*Daemon) GetJobRepository ¶
func (dm *Daemon) GetJobRepository() job.Repository
func (*Daemon) GetTMConfig ¶
func (*Daemon) IsLeaderNode ¶
func (*Daemon) RegisterWorkerFactory ¶
RegisterWorkerFactory register worker.Factory
func (*Daemon) SetJobOrganizer ¶
type StartedEvent ¶
type StartedEvent struct {
common.DaemonEvent
}
func (StartedEvent) Path ¶
func (event StartedEvent) Path() types.EventPath
Click to show internal directories.
Click to hide internal directories.