hello

Documentation

Index

• Constants
• type Event
• type Factory
  • func (fac *Factory) Name() string
  • func (fac *Factory) NewWorker(helper *worker.Helper) (worker.Worker, error)
  • func (fac *Factory) Space() string
• type JobInfo
• type Module
  • func (e *Module) AfterDaemonStarted(dm *daemon.Daemon)
  • func (e *Module) BeforeDaemonStarting(cmd *cobra.Command, dm *daemon.Daemon)
  • func (e *Module) Factories() (facs []worker.Factory)
  • func (e *Module) GetConfig() types.ModuleConfig
  • func (e *Module) GetFactory(name string) worker.Factory
  • func (e *Module) Init(config *config.Config)
  • func (e *Module) Name() string
• type ModuleProvider
  • func (b *ModuleProvider) AddFlags(cmd *cobra.Command)
  • func (b *ModuleProvider) GetDefaultConfig() types.ModuleConfig
  • func (b *ModuleProvider) InitFile(config *config.Config)
  • func (b *ModuleProvider) NewModule(tmCfg *config.Config, config common.DaemonConfig) daemon.Module
• type ProxyEvent
• type ProxyFactory
  • func (fac *ProxyFactory) Name() string
  • func (fac *ProxyFactory) NewWorker(helper *worker.Helper) (worker.Worker, error)
  • func (fac *ProxyFactory) Space() string
• type ProxyJobInfo
• type ProxyWorker
  • func (worker *ProxyWorker) ID() string
  • func (worker *ProxyWorker) IsStarted() bool
  • func (worker *ProxyWorker) Start() error
  • func (worker *ProxyWorker) Stop() error
• type Worker
  • func (worker *Worker) ID() string
  • func (worker *Worker) IsStarted() bool
  • func (worker *Worker) Start() error
  • func (worker *Worker) Stop() error

Constants

const (
	FactoryName = "hello-worker"
)

const (
	ProxyFactoryName = "hello-proxy-worker"
)

const (
	SpaceHello = "hello"
)

Types

type Event

type Event struct {
	Greet   string
	TxIndex int64
	Time    time.Time
}

Event

type Factory

type Factory struct {
}

func (*Factory) Name

func (fac *Factory) Name() string

func (*Factory) NewWorker

func (fac *Factory) NewWorker(helper *worker.Helper) (worker.Worker, error)

func (*Factory) Space

func (fac *Factory) Space() string

type JobInfo

type JobInfo struct {
	Interval string `json:"interval"`
	Greet    string `json:"greet"`
	// contains filtered or unexported fields
}

JobInfo

type Module

type Module struct {
	// contains filtered or unexported fields
}

func (*Module) AfterDaemonStarted

func (e *Module) AfterDaemonStarted(dm *daemon.Daemon)

func (*Module) BeforeDaemonStarting

func (e *Module) BeforeDaemonStarting(cmd *cobra.Command, dm *daemon.Daemon)

func (*Module) Factories

func (e *Module) Factories() (facs []worker.Factory)

func (*Module) GetConfig

func (e *Module) GetConfig() types.ModuleConfig

func (*Module) GetFactory

func (e *Module) GetFactory(name string) worker.Factory

func (*Module) Init

func (e *Module) Init(config *config.Config)

func (*Module) Name

func (e *Module) Name() string

type ModuleProvider

type ModuleProvider struct {
}

func (*ModuleProvider) AddFlags

func (b *ModuleProvider) AddFlags(cmd *cobra.Command)

func (*ModuleProvider) GetDefaultConfig

func (b *ModuleProvider) GetDefaultConfig() types.ModuleConfig

func (*ModuleProvider) InitFile

func (b *ModuleProvider) InitFile(config *config.Config)

func (*ModuleProvider) NewModule

func (b *ModuleProvider) NewModule(tmCfg *config.Config, config common.DaemonConfig) daemon.Module

type ProxyEvent

type ProxyEvent struct {
	Source string
	Log    string
	Time   time.Time
}

Event

type ProxyFactory

type ProxyFactory struct {
}

func (*ProxyFactory) Name

func (fac *ProxyFactory) Name() string

func (*ProxyFactory) NewWorker

func (fac *ProxyFactory) NewWorker(helper *worker.Helper) (worker.Worker, error)

func (*ProxyFactory) Space

func (fac *ProxyFactory) Space() string

type ProxyJobInfo

type ProxyJobInfo struct {
	Source string `json:"source"`
}

JobInfo

type ProxyWorker

type ProxyWorker struct {
	// contains filtered or unexported fields
}

Worker

func (*ProxyWorker) ID

func (worker *ProxyWorker) ID() string

func (*ProxyWorker) IsStarted

func (worker *ProxyWorker) IsStarted() bool

func (*ProxyWorker) Start

func (worker *ProxyWorker) Start() error

func (*ProxyWorker) Stop

func (worker *ProxyWorker) Stop() error

type Worker

type Worker struct {
	// contains filtered or unexported fields
}

Worker

func (*Worker) ID

func (worker *Worker) ID() string

func (*Worker) IsStarted

func (worker *Worker) IsStarted() bool

func (*Worker) Start

func (worker *Worker) Start() error

func (*Worker) Stop

func (worker *Worker) Stop() error