manager

package

v0.0.0-...-b47799d Latest Latest Go to latest Published: Mar 4, 2025 License: Apache-2.0 Imports: 5 Imported by: 0

Details

Package manager encapsulates everything related to long running plugin manager that starts, stops & configures long running plugins

View Source

const CloudWatchId = "aws:cloudWatch"

CloudWatchId represents the ID of cloud watch plugin

This section is empty.

This section is empty.

type Mock struct {
	mock.Mock
}

Mock stands for a mocked manager.

func NewMockDefault() *Mock

NewMockDefault returns an instance of Mock with default expectations set.

func (m *Mock) EnsurePluginRegistered(name string, plugin managerContracts.Plugin) (err error)

EnsurePluginRegistered adds a long-running plugin if it is not already in the registry

func (m *Mock) GetRegisteredPlugins() map[string]managerContracts.Plugin

GetRegisteredPlugins returns a map of all registered long running plugins - return the specified plugin map for testing here

func (m *Mock) ModuleExecute() (err error)

Execute starts long running plugin manager and returns encountered error - returns nil here for testing

func (m *Mock) ModuleName() string

Name returns the module name

func (m *Mock) ModuleStop() (err error)

RequestStop handles the termination of the message processor plugin job and returns encountered error - returns nil here for testing

func (m *Mock) StartPlugin(name, configuration, orchestrationDir string, cancelFlag task.CancelFlag, out iohandler.IOHandler) (err error)

StartPlugin starts the given plugin with the given configuration and returns encountered error - returns nil here for testing

func (m *Mock) StopPlugin(name string, cancelFlag task.CancelFlag) (err error)

StopPlugin stops a given plugin from executing and returns encountered error - returns nil here for testing