core

package

v1.11.2 Latest Latest Go to latest Published: Dec 12, 2022 License: Apache-2.0 Imports: 7 Imported by: 122

Details

This section is empty.

This section is empty.

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 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