inputs_manager

package

v0.44.0 Latest Latest Go to latest Published: Feb 17, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewInputsManager(ctx context.Context, store *collstore.Store, pipeline chan *pipeline.Msg) *InputsManager

func (mgr *InputsManager) DeleteInput(name string) error

func (mgr *InputsManager) GetInputState(name string) *collstore.InputState

GetInputState returns the runtime state of an input from the state store.

func (mgr *InputsManager) ListInputStates() []*collstore.InputState

ListInputStates returns all input states from the state store.

func (mgr *InputsManager) ProcessorInUse(name string) bool

func (mgr *InputsManager) Start(wg *sync.WaitGroup) error

func (mgr *InputsManager) Stop()

type ManagedInput struct {
	sync.RWMutex
	Name string
	Impl inputs.Input
	Cfg  map[string]any
}