collector

package

v0.2.0 Latest Latest Go to latest Published: Mar 23, 2022 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

func NewInstanceManagerMap() *instanceManagerMap

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

func New(config Config) (*Collector, error)

New initializes a new collector instance with state management and error handling

func (c *Collector) List() []string

func (c *Collector) ListStatus() []*manager.Status

func (c *Collector) RegisterInput(name string, input core.InputHandler) error

func (c *Collector) RegisterOutput(name string, output core.OutputHandler) error

func (c *Collector) RegisterProcessor(name string, processor core.ProcessHandler) error

func (c *Collector) Start(id string, config core.Config) error

func (c *Collector) Status(id string) (*manager.Status, error)

func (c *Collector) Stop(id string) error

func (c *Collector) StopAll()

type Config struct {
	SaveState    core.SaveStateFunc
	LoadState    core.LoadStateFunc
	ErrorHandler core.ErrorHandler
}