daemon

package

v0.0.0-...-4097794 Latest Latest Go to latest Published: Jul 31, 2017 License: GPL-3.0 Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Rendered for

This section is empty.

This section is empty.

func HandleCollectorActions(actions []graylog.ResponseCollectorAction)

func RegisterBackendRunner(name string, c RunnerCreator) error

type DaemonConfig struct {
	Name        string
	DisplayName string
	Description string

	Dir string
	Env []string

	Runner map[string]Runner
}

var (
	Daemon *DaemonConfig
)

func NewConfig() *DaemonConfig

func (dc *DaemonConfig) AddBackend(backend backends.Backend, context *context.Ctx)

func (dc *DaemonConfig) NewDistributor() *Distributor

type Distributor struct {
	Running bool
	// contains filtered or unexported fields
}

func (dist *Distributor) BindToService(s service.Service)

func (dist *Distributor) Start(s service.Service) error

start all backend runner, don't block

func (dist *Distributor) Stop(s service.Service) error

stop all backend runner parallel and wait till they are finished

type ExecRunner struct {
	RunnerCommon
	// contains filtered or unexported fields
}

func (r *ExecRunner) Name() string

func (r *ExecRunner) Restart() error

func (r *ExecRunner) Running() bool

func (r *ExecRunner) SetDaemon(d *DaemonConfig)

func (r *ExecRunner) Shutdown() error

func (r *ExecRunner) Supervised() bool

func (r *ExecRunner) ValidateBeforeStart() error

type Runner interface {
	Name() string
	Running() bool
	ValidateBeforeStart() error
	Restart() error
	Shutdown() error
	SetDaemon(*DaemonConfig)
}

func NewExecRunner(backend backends.Backend, context *context.Ctx) Runner

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

type RunnerCreator func(backends.Backend, *context.Ctx) Runner