manager

package

v0.0.0-...-ee9a62b Latest Latest Go to latest Published: Sep 1, 2023 License: AGPL-3.0 Imports: 25 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/antandros/go-yaps

Links

Open Source Insights

Documentation ¶

Index ¶

func GetTemplate() string
func ManagerTemplate() string
type Language
type Plugin
type PluginConfig
type PluginInterface
type PluginManager
- func GetManager() (*PluginManager, error)
- func RegisterManager(cnf *PluginManagerConfig) *PluginManager
type PluginManagerConfig

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func GetTemplate ¶

func GetTemplate() string

func ManagerTemplate ¶

func ManagerTemplate() string

Types ¶

type Language ¶

type Language uint

const (
	Go Language = iota
	Python
	Java
	JavaScript
)

type Plugin ¶

type Plugin struct {
	StructData parser.Struct
	StructMap  map[string]interface{}
	// contains filtered or unexported fields
}

func (*Plugin) Call ¶

func (p *Plugin) Call(structName string, function string, args []interface{}) (interface{}, error)

func (*Plugin) ClientStatus ¶

func (p *Plugin) ClientStatus() string

func (*Plugin) ConnectClient ¶

func (p *Plugin) ConnectClient()

func (*Plugin) Connected ¶

func (p *Plugin) Connected() bool

func (*Plugin) CreateClient ¶

func (p *Plugin) CreateClient() error

func (*Plugin) CreateProcess ¶

func (p *Plugin) CreateProcess() error

func (*Plugin) CreateToken ¶

func (p *Plugin) CreateToken() string

func (*Plugin) FunctionParamPop ¶

func (p *Plugin) FunctionParamPop(structName, function string, args []interface{}) []protocol.InItem

func (*Plugin) GenConfig ¶

func (p *Plugin) GenConfig() map[string]interface{}

func (*Plugin) GetLogger ¶

func (p *Plugin) GetLogger() *zap.Logger

func (*Plugin) KillProcess ¶

func (p *Plugin) KillProcess()

func (*Plugin) Language ¶

func (p *Plugin) Language() Language

func (*Plugin) Name ¶

func (p *Plugin) Name() string

func (*Plugin) ParseStruct ¶

func (p *Plugin) ParseStruct()

func (*Plugin) PluginCaller ¶

func (p *Plugin) PluginCaller(fu string, str string, ins []*protocol.InTypes) any

func (*Plugin) ProcessStatus ¶

func (p *Plugin) ProcessStatus()

func (*Plugin) Serve ¶

func (p *Plugin) Serve() error

func (*Plugin) SetManager ¶

func (p *Plugin) SetManager(manager *PluginManager)

func (*Plugin) SetSocket ¶

func (p *Plugin) SetSocket(sck string)

func (*Plugin) Socket ¶

func (p *Plugin) Socket() string

func (*Plugin) ValidateFunction ¶

func (p *Plugin) ValidateFunction(structName string, function string, args []interface{}) (bool, error)

func (*Plugin) ValidateStruct ¶

func (p *Plugin) ValidateStruct(item map[string]interface{}, function string, args []interface{}) []map[string]string

type PluginConfig ¶

type PluginConfig struct {
	Multiple     bool
	Language     Language
	Binary       bool
	File         string
	Name         string
	RemotePlugin bool
	Addr         string
	Port         int64
	Impl         PluginInterface
}

type PluginInterface ¶

type PluginInterface interface {
	Name() string
	SetLogger(*zap.Logger)
	Init() error
}

type PluginManager ¶

type PluginManager struct {
	Plugins []Plugin
	Plugin  Plugin

	PluginConfig *PluginConfig
	// contains filtered or unexported fields
}

func GetManager ¶

func GetManager() (*PluginManager, error)

func RegisterManager ¶

func RegisterManager(cnf *PluginManagerConfig) *PluginManager

func (*PluginManager) CallFunction ¶

func (pm *PluginManager) CallFunction(pluginName string, strucName string, function string, args []interface{}) (interface{}, error)

func (*PluginManager) Create ¶

func (pm *PluginManager) Create() error

func (*PluginManager) CreateBinary ¶

func (pm *PluginManager) CreateBinary() error

func (*PluginManager) CreateDirectory ¶

func (pm *PluginManager) CreateDirectory(dir string)

func (*PluginManager) CreateInterfaceFile ¶

func (pm *PluginManager) CreateInterfaceFile(pname string, packagePath string, item *parser.StructItem, allitem []*parser.StructItem, pkgName string, name string, inititem bool) error

func (*PluginManager) CreateInterfaces ¶

func (pm *PluginManager) CreateInterfaces() error

func (*PluginManager) Defer ¶

func (pm *PluginManager) Defer()

func (*PluginManager) Error ¶

func (pm *PluginManager) Error(errType yaperror.YapsError, err error, options ...yaperror.Options) error

func (*PluginManager) Generate ¶

func (pm *PluginManager) Generate()

func (*PluginManager) GetErrorLogger ¶

func (pm *PluginManager) GetErrorLogger() *zap.Logger

func (*PluginManager) GetPluginLogger ¶

func (pm *PluginManager) GetPluginLogger(plugin string) *zap.Logger

func (*PluginManager) RegisterPlugin ¶

func (pm *PluginManager) RegisterPlugin(pconfig *PluginConfig)

func (*PluginManager) RunPlugin ¶

func (pm *PluginManager) RunPlugin(pconfig *PluginConfig)

func (*PluginManager) StructCall ¶

func (pm *PluginManager) StructCall(fu string, str string, ins []*protocol.InTypes) any

func (*PluginManager) Wait ¶

func (pm *PluginManager) Wait()

type PluginManagerConfig ¶

type PluginManagerConfig struct {
	KillUnattendedClients bool
	ManagerId             string
	BinaryPath            string
	CreateBinary          bool
	LogFile               string
	CreateInterface       bool
	InterfacePath         string
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL