manager

Documentation

Index

• func GetTemplate() string
• func ManagerTemplate() string
• type Language
• type Plugin
  • func (p *Plugin) Call(structName string, function string, args []interface{}) (interface{}, error)
  • func (p *Plugin) ClientStatus() string
  • func (p *Plugin) ConnectClient()
  • func (p *Plugin) Connected() bool
  • func (p *Plugin) CreateClient() error
  • func (p *Plugin) CreateProcess() error
  • func (p *Plugin) CreateToken() string
  • func (p *Plugin) FunctionParamPop(structName, function string, args []interface{}) []protocol.InItem
  • func (p *Plugin) GenConfig() map[string]interface{}
  • func (p *Plugin) GetLogger() *zap.Logger
  • func (p *Plugin) KillProcess()
  • func (p *Plugin) Language() Language
  • func (p *Plugin) Name() string
  • func (p *Plugin) ParseStruct()
  • func (p *Plugin) PluginCaller(fu string, str string, ins []*protocol.InTypes) any
  • func (p *Plugin) ProcessStatus()
  • func (p *Plugin) Serve() error
  • func (p *Plugin) SetManager(manager *PluginManager)
  • func (p *Plugin) SetSocket(sck string)
  • func (p *Plugin) Socket() string
  • func (p *Plugin) ValidateFunction(structName string, function string, args []interface{}) (bool, error)
  • func (p *Plugin) ValidateStruct(item map[string]interface{}, function string, args []interface{}) []map[string]string
• type PluginConfig
• type PluginInterface
• type PluginManager
  • func GetManager() (*PluginManager, error)
  • func RegisterManager(cnf *PluginManagerConfig) *PluginManager
  • func (pm *PluginManager) CallFunction(pluginName string, strucName string, function string, args []interface{}) (interface{}, error)
  • func (pm *PluginManager) Create() error
  • func (pm *PluginManager) CreateBinary() error
  • func (pm *PluginManager) CreateDirectory(dir string)
  • func (pm *PluginManager) CreateInterfaceFile(pname string, packagePath string, item *parser.StructItem, ...) error
  • func (pm *PluginManager) CreateInterfaces() error
  • func (pm *PluginManager) Defer()
  • func (pm *PluginManager) Error(errType yaperror.YapsError, err error, options ...yaperror.Options) error
  • func (pm *PluginManager) Generate()
  • func (pm *PluginManager) GetErrorLogger() *zap.Logger
  • func (pm *PluginManager) GetPluginLogger(plugin string) *zap.Logger
  • func (pm *PluginManager) RegisterPlugin(pconfig *PluginConfig)
  • func (pm *PluginManager) RunPlugin(pconfig *PluginConfig)
  • func (pm *PluginManager) StructCall(fu string, str string, ins []*protocol.InTypes) any
  • func (pm *PluginManager) Wait()
• type PluginManagerConfig

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
}