pluginrpc

package
v1.11.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 21, 2026 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EmeraldPlugin_Describe_FullMethodName       = "/pluginrpc.EmeraldPlugin/Describe"
	EmeraldPlugin_ValidateConfig_FullMethodName = "/pluginrpc.EmeraldPlugin/ValidateConfig"
	EmeraldPlugin_ExecuteAction_FullMethodName  = "/pluginrpc.EmeraldPlugin/ExecuteAction"
	EmeraldPlugin_ToolDefinition_FullMethodName = "/pluginrpc.EmeraldPlugin/ToolDefinition"
	EmeraldPlugin_ExecuteTool_FullMethodName    = "/pluginrpc.EmeraldPlugin/ExecuteTool"
	EmeraldPlugin_TriggerRuntime_FullMethodName = "/pluginrpc.EmeraldPlugin/TriggerRuntime"
)

Variables

View Source 
var EmeraldPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pluginrpc.EmeraldPlugin",
	HandlerType: (*EmeraldPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Describe",
			Handler:    _EmeraldPlugin_Describe_Handler,
		},
		{
			MethodName: "ValidateConfig",
			Handler:    _EmeraldPlugin_ValidateConfig_Handler,
		},
		{
			MethodName: "ExecuteAction",
			Handler:    _EmeraldPlugin_ExecuteAction_Handler,
		},
		{
			MethodName: "ToolDefinition",
			Handler:    _EmeraldPlugin_ToolDefinition_Handler,
		},
		{
			MethodName: "ExecuteTool",
			Handler:    _EmeraldPlugin_ExecuteTool_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "TriggerRuntime",
			Handler:       _EmeraldPlugin_TriggerRuntime_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "pkg/pluginrpc/plugin.proto",
}

EmeraldPlugin_ServiceDesc is the grpc.ServiceDesc for EmeraldPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_pkg_pluginrpc_plugin_proto protoreflect.FileDescriptor

Functions

func RegisterEmeraldPluginServer 

func RegisterEmeraldPluginServer(s grpc.ServiceRegistrar, srv EmeraldPluginServer)

Types

type DescribeRequest 

type DescribeRequest struct {
	// contains filtered or unexported fields
}

func (*DescribeRequest) Descriptor deprecated 

func (*DescribeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DescribeRequest.ProtoReflect.Descriptor instead.

func (*DescribeRequest) ProtoMessage 

func (*DescribeRequest) ProtoMessage()

func (*DescribeRequest) ProtoReflect 

func (x *DescribeRequest) ProtoReflect() protoreflect.Message

func (*DescribeRequest) Reset 

func (x *DescribeRequest) Reset()

func (*DescribeRequest) String 

func (x *DescribeRequest) String() string

type DescribeResponse 

type DescribeResponse struct {
	PluginInfoJson []byte `protobuf:"bytes,1,opt,name=plugin_info_json,json=pluginInfoJson,proto3" json:"plugin_info_json,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeResponse) Descriptor deprecated 

func (*DescribeResponse) Descriptor() ([]byte, []int)

Deprecated: Use DescribeResponse.ProtoReflect.Descriptor instead.

func (*DescribeResponse) GetPluginInfoJson 

func (x *DescribeResponse) GetPluginInfoJson() []byte

func (*DescribeResponse) ProtoMessage 

func (*DescribeResponse) ProtoMessage()

func (*DescribeResponse) ProtoReflect 

func (x *DescribeResponse) ProtoReflect() protoreflect.Message

func (*DescribeResponse) Reset 

func (x *DescribeResponse) Reset()

func (*DescribeResponse) String 

func (x *DescribeResponse) String() string

type EmeraldPluginClient 

type EmeraldPluginClient interface {
	Describe(ctx context.Context, in *DescribeRequest, opts ...grpc.CallOption) (*DescribeResponse, error)
	ValidateConfig(ctx context.Context, in *ValidateConfigRequest, opts ...grpc.CallOption) (*ValidateConfigResponse, error)
	ExecuteAction(ctx context.Context, in *ExecuteActionRequest, opts ...grpc.CallOption) (*ExecuteActionResponse, error)
	ToolDefinition(ctx context.Context, in *ToolDefinitionRequest, opts ...grpc.CallOption) (*ToolDefinitionResponse, error)
	ExecuteTool(ctx context.Context, in *ExecuteToolRequest, opts ...grpc.CallOption) (*ExecuteToolResponse, error)
	TriggerRuntime(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[TriggerRuntimeClientMessage, TriggerRuntimeServerMessage], error)
}

EmeraldPluginClient is the client API for EmeraldPlugin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewEmeraldPluginClient 

func NewEmeraldPluginClient(cc grpc.ClientConnInterface) EmeraldPluginClient

type EmeraldPluginServer 

type EmeraldPluginServer interface {
	Describe(context.Context, *DescribeRequest) (*DescribeResponse, error)
	ValidateConfig(context.Context, *ValidateConfigRequest) (*ValidateConfigResponse, error)
	ExecuteAction(context.Context, *ExecuteActionRequest) (*ExecuteActionResponse, error)
	ToolDefinition(context.Context, *ToolDefinitionRequest) (*ToolDefinitionResponse, error)
	ExecuteTool(context.Context, *ExecuteToolRequest) (*ExecuteToolResponse, error)
	TriggerRuntime(grpc.BidiStreamingServer[TriggerRuntimeClientMessage, TriggerRuntimeServerMessage]) error
	// contains filtered or unexported methods
}

EmeraldPluginServer is the server API for EmeraldPlugin service. All implementations must embed UnimplementedEmeraldPluginServer for forward compatibility.

type EmeraldPlugin_TriggerRuntimeClient 

type EmeraldPlugin_TriggerRuntimeClient = grpc.BidiStreamingClient[TriggerRuntimeClientMessage, TriggerRuntimeServerMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type EmeraldPlugin_TriggerRuntimeServer 

type EmeraldPlugin_TriggerRuntimeServer = grpc.BidiStreamingServer[TriggerRuntimeClientMessage, TriggerRuntimeServerMessage]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type ExecuteActionRequest 

type ExecuteActionRequest struct {
	NodeId     string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	ConfigJson []byte `protobuf:"bytes,2,opt,name=config_json,json=configJson,proto3" json:"config_json,omitempty"`
	InputJson  []byte `protobuf:"bytes,3,opt,name=input_json,json=inputJson,proto3" json:"input_json,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteActionRequest) Descriptor deprecated 

func (*ExecuteActionRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteActionRequest.ProtoReflect.Descriptor instead.

func (*ExecuteActionRequest) GetConfigJson 

func (x *ExecuteActionRequest) GetConfigJson() []byte

func (*ExecuteActionRequest) GetInputJson 

func (x *ExecuteActionRequest) GetInputJson() []byte

func (*ExecuteActionRequest) GetNodeId 

func (x *ExecuteActionRequest) GetNodeId() string

func (*ExecuteActionRequest) ProtoMessage 

func (*ExecuteActionRequest) ProtoMessage()

func (*ExecuteActionRequest) ProtoReflect 

func (x *ExecuteActionRequest) ProtoReflect() protoreflect.Message

func (*ExecuteActionRequest) Reset 

func (x *ExecuteActionRequest) Reset()

func (*ExecuteActionRequest) String 

func (x *ExecuteActionRequest) String() string

type ExecuteActionResponse 

type ExecuteActionResponse struct {
	OutputJson []byte `protobuf:"bytes,1,opt,name=output_json,json=outputJson,proto3" json:"output_json,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteActionResponse) Descriptor deprecated 

func (*ExecuteActionResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteActionResponse.ProtoReflect.Descriptor instead.

func (*ExecuteActionResponse) GetOutputJson 

func (x *ExecuteActionResponse) GetOutputJson() []byte

func (*ExecuteActionResponse) ProtoMessage 

func (*ExecuteActionResponse) ProtoMessage()

func (*ExecuteActionResponse) ProtoReflect 

func (x *ExecuteActionResponse) ProtoReflect() protoreflect.Message

func (*ExecuteActionResponse) Reset 

func (x *ExecuteActionResponse) Reset()

func (*ExecuteActionResponse) String 

func (x *ExecuteActionResponse) String() string

type ExecuteToolRequest 

type ExecuteToolRequest struct {
	NodeId     string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	ConfigJson []byte `protobuf:"bytes,2,opt,name=config_json,json=configJson,proto3" json:"config_json,omitempty"`
	ArgsJson   []byte `protobuf:"bytes,3,opt,name=args_json,json=argsJson,proto3" json:"args_json,omitempty"`
	InputJson  []byte `protobuf:"bytes,4,opt,name=input_json,json=inputJson,proto3" json:"input_json,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteToolRequest) Descriptor deprecated 

func (*ExecuteToolRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteToolRequest.ProtoReflect.Descriptor instead.

func (*ExecuteToolRequest) GetArgsJson 

func (x *ExecuteToolRequest) GetArgsJson() []byte

func (*ExecuteToolRequest) GetConfigJson 

func (x *ExecuteToolRequest) GetConfigJson() []byte

func (*ExecuteToolRequest) GetInputJson 

func (x *ExecuteToolRequest) GetInputJson() []byte

func (*ExecuteToolRequest) GetNodeId 

func (x *ExecuteToolRequest) GetNodeId() string

func (*ExecuteToolRequest) ProtoMessage 

func (*ExecuteToolRequest) ProtoMessage()

func (*ExecuteToolRequest) ProtoReflect 

func (x *ExecuteToolRequest) ProtoReflect() protoreflect.Message

func (*ExecuteToolRequest) Reset 

func (x *ExecuteToolRequest) Reset()

func (*ExecuteToolRequest) String 

func (x *ExecuteToolRequest) String() string

type ExecuteToolResponse 

type ExecuteToolResponse struct {
	ResultJson []byte `protobuf:"bytes,1,opt,name=result_json,json=resultJson,proto3" json:"result_json,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteToolResponse) Descriptor deprecated 

func (*ExecuteToolResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteToolResponse.ProtoReflect.Descriptor instead.

func (*ExecuteToolResponse) GetResultJson 

func (x *ExecuteToolResponse) GetResultJson() []byte

func (*ExecuteToolResponse) ProtoMessage 

func (*ExecuteToolResponse) ProtoMessage()

func (*ExecuteToolResponse) ProtoReflect 

func (x *ExecuteToolResponse) ProtoReflect() protoreflect.Message

func (*ExecuteToolResponse) Reset 

func (x *ExecuteToolResponse) Reset()

func (*ExecuteToolResponse) String 

func (x *ExecuteToolResponse) String() string

type ToolDefinitionRequest 

type ToolDefinitionRequest struct {
	NodeId     string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	MetaJson   []byte `protobuf:"bytes,2,opt,name=meta_json,json=metaJson,proto3" json:"meta_json,omitempty"`
	ConfigJson []byte `protobuf:"bytes,3,opt,name=config_json,json=configJson,proto3" json:"config_json,omitempty"`
	// contains filtered or unexported fields
}

func (*ToolDefinitionRequest) Descriptor deprecated 

func (*ToolDefinitionRequest) Descriptor() ([]byte, []int)

Deprecated: Use ToolDefinitionRequest.ProtoReflect.Descriptor instead.

func (*ToolDefinitionRequest) GetConfigJson 

func (x *ToolDefinitionRequest) GetConfigJson() []byte

func (*ToolDefinitionRequest) GetMetaJson 

func (x *ToolDefinitionRequest) GetMetaJson() []byte

func (*ToolDefinitionRequest) GetNodeId 

func (x *ToolDefinitionRequest) GetNodeId() string

func (*ToolDefinitionRequest) ProtoMessage 

func (*ToolDefinitionRequest) ProtoMessage()

func (*ToolDefinitionRequest) ProtoReflect 

func (x *ToolDefinitionRequest) ProtoReflect() protoreflect.Message

func (*ToolDefinitionRequest) Reset 

func (x *ToolDefinitionRequest) Reset()

func (*ToolDefinitionRequest) String 

func (x *ToolDefinitionRequest) String() string

type ToolDefinitionResponse 

type ToolDefinitionResponse struct {
	DefinitionJson []byte `protobuf:"bytes,1,opt,name=definition_json,json=definitionJson,proto3" json:"definition_json,omitempty"`
	// contains filtered or unexported fields
}

func (*ToolDefinitionResponse) Descriptor deprecated 

func (*ToolDefinitionResponse) Descriptor() ([]byte, []int)

Deprecated: Use ToolDefinitionResponse.ProtoReflect.Descriptor instead.

func (*ToolDefinitionResponse) GetDefinitionJson 

func (x *ToolDefinitionResponse) GetDefinitionJson() []byte

func (*ToolDefinitionResponse) ProtoMessage 

func (*ToolDefinitionResponse) ProtoMessage()

func (*ToolDefinitionResponse) ProtoReflect 

func (x *ToolDefinitionResponse) ProtoReflect() protoreflect.Message

func (*ToolDefinitionResponse) Reset 

func (x *ToolDefinitionResponse) Reset()

func (*ToolDefinitionResponse) String 

func (x *ToolDefinitionResponse) String() string

type TriggerRuntimeClientMessage 

type TriggerRuntimeClientMessage struct {
	SnapshotJson []byte `protobuf:"bytes,1,opt,name=snapshot_json,json=snapshotJson,proto3" json:"snapshot_json,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerRuntimeClientMessage) Descriptor deprecated 

func (*TriggerRuntimeClientMessage) Descriptor() ([]byte, []int)

Deprecated: Use TriggerRuntimeClientMessage.ProtoReflect.Descriptor instead.

func (*TriggerRuntimeClientMessage) GetSnapshotJson 

func (x *TriggerRuntimeClientMessage) GetSnapshotJson() []byte

func (*TriggerRuntimeClientMessage) ProtoMessage 

func (*TriggerRuntimeClientMessage) ProtoMessage()

func (*TriggerRuntimeClientMessage) ProtoReflect 

func (x *TriggerRuntimeClientMessage) ProtoReflect() protoreflect.Message

func (*TriggerRuntimeClientMessage) Reset 

func (x *TriggerRuntimeClientMessage) Reset()

func (*TriggerRuntimeClientMessage) String 

func (x *TriggerRuntimeClientMessage) String() string

type TriggerRuntimeServerMessage 

type TriggerRuntimeServerMessage struct {
	EventJson []byte `protobuf:"bytes,1,opt,name=event_json,json=eventJson,proto3" json:"event_json,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerRuntimeServerMessage) Descriptor deprecated 

func (*TriggerRuntimeServerMessage) Descriptor() ([]byte, []int)

Deprecated: Use TriggerRuntimeServerMessage.ProtoReflect.Descriptor instead.

func (*TriggerRuntimeServerMessage) GetEventJson 

func (x *TriggerRuntimeServerMessage) GetEventJson() []byte

func (*TriggerRuntimeServerMessage) ProtoMessage 

func (*TriggerRuntimeServerMessage) ProtoMessage()

func (*TriggerRuntimeServerMessage) ProtoReflect 

func (x *TriggerRuntimeServerMessage) ProtoReflect() protoreflect.Message

func (*TriggerRuntimeServerMessage) Reset 

func (x *TriggerRuntimeServerMessage) Reset()

func (*TriggerRuntimeServerMessage) String 

func (x *TriggerRuntimeServerMessage) String() string

type UnimplementedEmeraldPluginServer 

type UnimplementedEmeraldPluginServer struct{}

UnimplementedEmeraldPluginServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedEmeraldPluginServer) Describe 

func (UnimplementedEmeraldPluginServer) Describe(context.Context, *DescribeRequest) (*DescribeResponse, error)

func (UnimplementedEmeraldPluginServer) ExecuteAction 

func (UnimplementedEmeraldPluginServer) ExecuteAction(context.Context, *ExecuteActionRequest) (*ExecuteActionResponse, error)

func (UnimplementedEmeraldPluginServer) ExecuteTool 

func (UnimplementedEmeraldPluginServer) ExecuteTool(context.Context, *ExecuteToolRequest) (*ExecuteToolResponse, error)

func (UnimplementedEmeraldPluginServer) ToolDefinition 

func (UnimplementedEmeraldPluginServer) ToolDefinition(context.Context, *ToolDefinitionRequest) (*ToolDefinitionResponse, error)

func (UnimplementedEmeraldPluginServer) TriggerRuntime 

func (UnimplementedEmeraldPluginServer) TriggerRuntime(grpc.BidiStreamingServer[TriggerRuntimeClientMessage, TriggerRuntimeServerMessage]) error

func (UnimplementedEmeraldPluginServer) ValidateConfig 

func (UnimplementedEmeraldPluginServer) ValidateConfig(context.Context, *ValidateConfigRequest) (*ValidateConfigResponse, error)

type UnsafeEmeraldPluginServer 

type UnsafeEmeraldPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeEmeraldPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EmeraldPluginServer will result in compilation errors.

type ValidateConfigRequest 

type ValidateConfigRequest struct {
	NodeId     string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	ConfigJson []byte `protobuf:"bytes,2,opt,name=config_json,json=configJson,proto3" json:"config_json,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateConfigRequest) Descriptor deprecated 

func (*ValidateConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use ValidateConfigRequest.ProtoReflect.Descriptor instead.

func (*ValidateConfigRequest) GetConfigJson 

func (x *ValidateConfigRequest) GetConfigJson() []byte

func (*ValidateConfigRequest) GetNodeId 

func (x *ValidateConfigRequest) GetNodeId() string

func (*ValidateConfigRequest) ProtoMessage 

func (*ValidateConfigRequest) ProtoMessage()

func (*ValidateConfigRequest) ProtoReflect 

func (x *ValidateConfigRequest) ProtoReflect() protoreflect.Message

func (*ValidateConfigRequest) Reset 

func (x *ValidateConfigRequest) Reset()

func (*ValidateConfigRequest) String 

func (x *ValidateConfigRequest) String() string

type ValidateConfigResponse 

type ValidateConfigResponse struct {
	// contains filtered or unexported fields
}

func (*ValidateConfigResponse) Descriptor deprecated 

func (*ValidateConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use ValidateConfigResponse.ProtoReflect.Descriptor instead.

func (*ValidateConfigResponse) ProtoMessage 

func (*ValidateConfigResponse) ProtoMessage()

func (*ValidateConfigResponse) ProtoReflect 

func (x *ValidateConfigResponse) ProtoReflect() protoreflect.Message

func (*ValidateConfigResponse) Reset 

func (x *ValidateConfigResponse) Reset()

func (*ValidateConfigResponse) String 

func (x *ValidateConfigResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.