Documentation ¶
Index ¶
- type BaseModule
- func (b BaseModule) AfterDaemonStarted(dm *Daemon)
- func (b BaseModule) BeforeDaemonStarting(cmd *cobra.Command, dm *Daemon)
- func (b BaseModule) Factories() (facs []worker.Factory)
- func (b BaseModule) GetConfig() types.ModuleConfig
- func (b BaseModule) GetFactory(name string) worker.Factory
- func (b BaseModule) Init(config *config.Config)
- func (b BaseModule) Name() string
- type BaseModuleProvider
- type BaseProvider
- func (provider *BaseProvider) AddFlags(cmd *cobra.Command)
- func (provider *BaseProvider) AddModuleProvider(moduleProvider ModuleProvider)
- func (provider *BaseProvider) InitFiles(config *cfg.Config, daemonConfig *common.DaemonConfig)
- func (provider *BaseProvider) NewDaemon(cmd *cobra.Command, tmCfg *cfg.Config, logger log.Logger, tmNode *node.Node, ...) *Daemon
- type Daemon
- func (dm *Daemon) AddModule(module Module)
- 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) GetModule(name string) Module
- func (dm *Daemon) GetTMConfig() cfg.Config
- func (dm *Daemon) ID() string
- func (dm *Daemon) IsLeaderNode() bool
- func (dm *Daemon) NewWorkerProxy(jobID string) (worker.Proxy, error)
- func (dm *Daemon) RegisterWorkerFactory(factory worker.Factory)
- func (dm *Daemon) SetJobOrganizer(organizer job.Organizer)
- func (dm *Daemon) Start()
- type Module
- type ModuleProvider
- type Provider
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BaseModule ¶ added in v0.0.2
type BaseModule struct { }
func (BaseModule) AfterDaemonStarted ¶ added in v0.0.2
func (b BaseModule) AfterDaemonStarted(dm *Daemon)
func (BaseModule) BeforeDaemonStarting ¶ added in v0.0.2
func (b BaseModule) BeforeDaemonStarting(cmd *cobra.Command, dm *Daemon)
func (BaseModule) Factories ¶ added in v0.0.2
func (b BaseModule) Factories() (facs []worker.Factory)
func (BaseModule) GetConfig ¶ added in v0.0.2
func (b BaseModule) GetConfig() types.ModuleConfig
func (BaseModule) GetFactory ¶ added in v0.0.2
func (b BaseModule) GetFactory(name string) worker.Factory
func (BaseModule) Init ¶ added in v0.0.2
func (b BaseModule) Init(config *config.Config)
func (BaseModule) Name ¶ added in v0.0.2
func (b BaseModule) Name() string
type BaseModuleProvider ¶ added in v0.0.2
type BaseModuleProvider struct { }
func (*BaseModuleProvider) AddFlags ¶ added in v0.0.2
func (b *BaseModuleProvider) AddFlags(cmd *cobra.Command)
func (*BaseModuleProvider) GetDefaultConfig ¶ added in v0.0.2
func (b *BaseModuleProvider) GetDefaultConfig() types.ModuleConfig
func (*BaseModuleProvider) InitFile ¶ added in v0.0.2
func (b *BaseModuleProvider) InitFile(config *config.Config)
func (*BaseModuleProvider) NewModule ¶ added in v0.0.2
func (b *BaseModuleProvider) NewModule(tmCfg *config.Config, config common.DaemonConfig) Module
type BaseProvider ¶
type BaseProvider struct {
// contains filtered or unexported fields
}
func (*BaseProvider) AddFlags ¶ added in v0.0.2
func (provider *BaseProvider) AddFlags(cmd *cobra.Command)
func (*BaseProvider) AddModuleProvider ¶ added in v0.0.2
func (provider *BaseProvider) AddModuleProvider(moduleProvider ModuleProvider)
func (*BaseProvider) InitFiles ¶ added in v0.0.2
func (provider *BaseProvider) InitFiles(config *cfg.Config, daemonConfig *common.DaemonConfig)
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) NewWorkerProxy ¶ added in v0.0.2
func (*Daemon) RegisterWorkerFactory ¶
RegisterWorkerFactory register worker.Factory
func (*Daemon) SetJobOrganizer ¶
type Module ¶ added in v0.0.2
type Module interface { Name() string GetFactory(name string) worker.Factory Factories() (facs []worker.Factory) Init(config *config.Config) GetConfig() types.ModuleConfig BeforeDaemonStarting(cmd *cobra.Command, dm *Daemon) AfterDaemonStarted(dm *Daemon) }
존재 이유가 약함
type ModuleProvider ¶ added in v0.0.2
Source Files ¶
Click to show internal directories.
Click to hide internal directories.