Documentation
¶
Index ¶
- type AWSPluginRuntime
- func (r *AWSPluginRuntime) Identity() (plugin_entities.PluginUniqueIdentifier, error)
- func (r *AWSPluginRuntime) InitEnvironment() error
- func (r *AWSPluginRuntime) Listen(sessionId string) *entities.Broadcast[plugin_entities.SessionMessage]
- func (r *AWSPluginRuntime) StartPlugin() error
- func (r *AWSPluginRuntime) Type() plugin_entities.PluginRuntimeType
- func (r *AWSPluginRuntime) Wait() (<-chan bool, error)
- func (r *AWSPluginRuntime) Write(sessionId string, action access_types.PluginAccessAction, data []byte)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AWSPluginRuntime ¶
type AWSPluginRuntime struct {
basic_runtime.BasicChecksum
plugin_entities.PluginRuntime
// access url for the lambda function
LambdaURL string
LambdaName string
// contains filtered or unexported fields
}
func (*AWSPluginRuntime) Identity ¶
func (r *AWSPluginRuntime) Identity() (plugin_entities.PluginUniqueIdentifier, error)
func (*AWSPluginRuntime) InitEnvironment ¶
func (r *AWSPluginRuntime) InitEnvironment() error
func (*AWSPluginRuntime) Listen ¶
func (r *AWSPluginRuntime) Listen(sessionId string) *entities.Broadcast[plugin_entities.SessionMessage]
func (*AWSPluginRuntime) StartPlugin ¶
func (r *AWSPluginRuntime) StartPlugin() error
func (*AWSPluginRuntime) Type ¶
func (r *AWSPluginRuntime) Type() plugin_entities.PluginRuntimeType
func (*AWSPluginRuntime) Wait ¶
func (r *AWSPluginRuntime) Wait() (<-chan bool, error)
func (*AWSPluginRuntime) Write ¶
func (r *AWSPluginRuntime) Write(sessionId string, action access_types.PluginAccessAction, data []byte)
For AWS Lambda, write is equivalent to http request, it's not a normal stream like stdio and tcp
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.