core

package

v1.21.0 Latest Latest Go to latest Published: Feb 21, 2025 License: Apache-2.0 Imports: 8 Imported by: 122

Details

This section is empty.

This section is empty.

func EnableModuleRestart()

EnableModuleRestart enable feature for auto restarting modules

func GetModuleExchange() *socket.ModuleExchange

GetModuleExchange return module exchange

func GetModules() map[string]*ModuleInfo

GetModules gets modules map

func GracefulShutdown()

GracefulShutdown is if it gets the special signals it does modules cleanup

func IsModuleRestartEnabled() bool

IsModuleRestartEnabled checks whether auto-restart feature is enabled.

func Register(m Module, opts ...string)

Register register module if not passed in parameter opts, default contextType is "channel"

func Run()

Run starts the modules and in the end does module cleanup

func StartModules()

StartModules starts modules that are registered

type Module interface {
	Name() string
	Group() string
	Start()
	Enable() bool
}

Module interface

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

ModuleInfo represent a module info

func (m *ModuleInfo) GetModule() Module

GetModule gets module