Documentation
¶
Overview ¶
Package local_runtime handles the local plugin runtime management
Index ¶
- func OnError(id string, session_id string, listener func([]byte))
- func OnGlobalEvent(listener func(string, []byte))
- type LocalPluginRuntime
- func (r *LocalPluginRuntime) Identity() (plugin_entities.PluginUniqueIdentifier, error)
- func (r *LocalPluginRuntime) InitEnvironment() error
- func (p *LocalPluginRuntime) InitPythonEnvironment() error
- func (r *LocalPluginRuntime) Listen(session_id string) *entities.Broadcast[plugin_entities.SessionMessage]
- func (r *LocalPluginRuntime) StartPlugin() error
- func (r *LocalPluginRuntime) Stop()
- func (r *LocalPluginRuntime) Type() plugin_entities.PluginRuntimeType
- func (r *LocalPluginRuntime) Wait() (<-chan bool, error)
- func (r *LocalPluginRuntime) WaitStarted() <-chan bool
- func (r *LocalPluginRuntime) WaitStopped() <-chan bool
- func (r *LocalPluginRuntime) Write(session_id string, action access_types.PluginAccessAction, data []byte)
- type LocalPluginRuntimeConfig
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func OnGlobalEvent ¶
Types ¶
type LocalPluginRuntime ¶
type LocalPluginRuntime struct {
basic_runtime.BasicChecksum
plugin_entities.PluginRuntime
// proxy settings
HttpProxy string
HttpsProxy string
// contains filtered or unexported fields
}
func NewLocalPluginRuntime ¶
func NewLocalPluginRuntime(config LocalPluginRuntimeConfig) *LocalPluginRuntime
func (*LocalPluginRuntime) Identity ¶
func (r *LocalPluginRuntime) Identity() (plugin_entities.PluginUniqueIdentifier, error)
func (*LocalPluginRuntime) InitEnvironment ¶
func (r *LocalPluginRuntime) InitEnvironment() error
func (*LocalPluginRuntime) InitPythonEnvironment ¶
func (p *LocalPluginRuntime) InitPythonEnvironment() error
func (*LocalPluginRuntime) Listen ¶
func (r *LocalPluginRuntime) Listen(session_id string) *entities.Broadcast[plugin_entities.SessionMessage]
func (*LocalPluginRuntime) StartPlugin ¶
func (r *LocalPluginRuntime) StartPlugin() error
StartPlugin starts the plugin and manages its lifecycle
func (*LocalPluginRuntime) Type ¶
func (r *LocalPluginRuntime) Type() plugin_entities.PluginRuntimeType
Type returns the runtime type of the plugin
func (*LocalPluginRuntime) Wait ¶
func (r *LocalPluginRuntime) Wait() (<-chan bool, error)
Wait returns a channel that will be closed when the plugin stops
func (*LocalPluginRuntime) WaitStarted ¶
func (r *LocalPluginRuntime) WaitStarted() <-chan bool
WaitStarted returns a channel that will receive true when the plugin starts
func (*LocalPluginRuntime) WaitStopped ¶
func (r *LocalPluginRuntime) WaitStopped() <-chan bool
WaitStopped returns a channel that will receive true when the plugin stops
func (*LocalPluginRuntime) Write ¶
func (r *LocalPluginRuntime) Write(session_id string, action access_types.PluginAccessAction, data []byte)
Source Files
Click to show internal directories.
Click to hide internal directories.