proto

package

Go to main page

Versions in this module

v0

v0.1.5

Feb 22, 2026

Changes in this version

+ const EngineCallbackService_PublishMessage_FullMethodName

+ const EngineCallbackService_Subscribe_FullMethodName

+ const EngineCallbackService_Unsubscribe_FullMethodName

+ const PluginService_DeliverMessage_FullMethodName

+ var File_plugin_external_proto_plugin_proto protoreflect.FileDescriptor

+ type DeliverMessageRequest struct

+ HandleId string

+ MessageId string

+ Metadata map[string]string

+ Payload []byte

+ Topic string

+ func (*DeliverMessageRequest) Descriptor() ([]byte, []int)

+ func (*DeliverMessageRequest) ProtoMessage()

+ func (x *DeliverMessageRequest) GetHandleId() string

+ func (x *DeliverMessageRequest) GetMessageId() string

+ func (x *DeliverMessageRequest) GetMetadata() map[string]string

+ func (x *DeliverMessageRequest) GetPayload() []byte

+ func (x *DeliverMessageRequest) GetTopic() string

+ func (x *DeliverMessageRequest) ProtoReflect() protoreflect.Message

+ func (x *DeliverMessageRequest) Reset()

+ func (x *DeliverMessageRequest) String() string

+ type DeliverMessageResponse struct

+ Acknowledged bool

+ Error string

+ func (*DeliverMessageResponse) Descriptor() ([]byte, []int)

+ func (*DeliverMessageResponse) ProtoMessage()

+ func (x *DeliverMessageResponse) GetAcknowledged() bool

+ func (x *DeliverMessageResponse) GetError() string

+ func (x *DeliverMessageResponse) ProtoReflect() protoreflect.Message

+ func (x *DeliverMessageResponse) Reset()

+ func (x *DeliverMessageResponse) String() string

type EngineCallbackServiceClient

+ PublishMessage func(ctx context.Context, in *PublishMessageRequest, opts ...grpc.CallOption) (*PublishMessageResponse, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*ErrorResponse, error)

+ Unsubscribe func(ctx context.Context, in *UnsubscribeRequest, opts ...grpc.CallOption) (*ErrorResponse, error)

type EngineCallbackServiceServer

+ PublishMessage func(context.Context, *PublishMessageRequest) (*PublishMessageResponse, error)

+ Subscribe func(context.Context, *SubscribeRequest) (*ErrorResponse, error)

+ Unsubscribe func(context.Context, *UnsubscribeRequest) (*ErrorResponse, error)

type PluginServiceClient

+ DeliverMessage func(ctx context.Context, in *DeliverMessageRequest, opts ...grpc.CallOption) (*DeliverMessageResponse, error)

type PluginServiceServer

+ DeliverMessage func(context.Context, *DeliverMessageRequest) (*DeliverMessageResponse, error)

+ type PublishMessageRequest struct

+ HandleId string

+ Metadata map[string]string

+ Payload []byte

+ Topic string

+ func (*PublishMessageRequest) Descriptor() ([]byte, []int)

+ func (*PublishMessageRequest) ProtoMessage()

+ func (x *PublishMessageRequest) GetHandleId() string

+ func (x *PublishMessageRequest) GetMetadata() map[string]string

+ func (x *PublishMessageRequest) GetPayload() []byte

+ func (x *PublishMessageRequest) GetTopic() string

+ func (x *PublishMessageRequest) ProtoReflect() protoreflect.Message

+ func (x *PublishMessageRequest) Reset()

+ func (x *PublishMessageRequest) String() string

+ type PublishMessageResponse struct

+ Error string

+ MessageId string

+ func (*PublishMessageResponse) Descriptor() ([]byte, []int)

+ func (*PublishMessageResponse) ProtoMessage()

+ func (x *PublishMessageResponse) GetError() string

+ func (x *PublishMessageResponse) GetMessageId() string

+ func (x *PublishMessageResponse) ProtoReflect() protoreflect.Message

+ func (x *PublishMessageResponse) Reset()

+ func (x *PublishMessageResponse) String() string

+ type SubscribeRequest struct

+ BrokerName string

+ HandleId string

+ Topic string

+ func (*SubscribeRequest) Descriptor() ([]byte, []int)

+ func (*SubscribeRequest) ProtoMessage()

+ func (x *SubscribeRequest) GetBrokerName() string

+ func (x *SubscribeRequest) GetHandleId() string

+ func (x *SubscribeRequest) GetTopic() string

+ func (x *SubscribeRequest) ProtoReflect() protoreflect.Message

+ func (x *SubscribeRequest) Reset()

+ func (x *SubscribeRequest) String() string

type UnimplementedEngineCallbackServiceServer

+ func (UnimplementedEngineCallbackServiceServer) PublishMessage(context.Context, *PublishMessageRequest) (*PublishMessageResponse, error)

+ func (UnimplementedEngineCallbackServiceServer) Subscribe(context.Context, *SubscribeRequest) (*ErrorResponse, error)

+ func (UnimplementedEngineCallbackServiceServer) Unsubscribe(context.Context, *UnsubscribeRequest) (*ErrorResponse, error)

type UnimplementedPluginServiceServer

+ func (UnimplementedPluginServiceServer) DeliverMessage(context.Context, *DeliverMessageRequest) (*DeliverMessageResponse, error)

+ type UnsubscribeRequest struct

+ HandleId string

+ Topic string

+ func (*UnsubscribeRequest) Descriptor() ([]byte, []int)

+ func (*UnsubscribeRequest) ProtoMessage()

+ func (x *UnsubscribeRequest) GetHandleId() string

+ func (x *UnsubscribeRequest) GetTopic() string

+ func (x *UnsubscribeRequest) ProtoReflect() protoreflect.Message

+ func (x *UnsubscribeRequest) Reset()

+ func (x *UnsubscribeRequest) String() string

v0.1.1

Feb 22, 2026

v0.1.0

Feb 22, 2026

Changes in this version

+ const EngineCallbackService_GetService_FullMethodName

+ const EngineCallbackService_Log_FullMethodName

+ const EngineCallbackService_TriggerWorkflow_FullMethodName

+ const PluginService_CreateModule_FullMethodName

+ const PluginService_CreateStep_FullMethodName

+ const PluginService_DestroyModule_FullMethodName

+ const PluginService_DestroyStep_FullMethodName

+ const PluginService_ExecuteStep_FullMethodName

+ const PluginService_GetManifest_FullMethodName

+ const PluginService_GetModuleSchemas_FullMethodName

+ const PluginService_GetModuleTypes_FullMethodName

+ const PluginService_GetStepTypes_FullMethodName

+ const PluginService_GetTriggerTypes_FullMethodName

+ const PluginService_InitModule_FullMethodName

+ const PluginService_InvokeService_FullMethodName

+ const PluginService_StartModule_FullMethodName

+ const PluginService_StopModule_FullMethodName

+ var EngineCallbackService_ServiceDesc = grpc.ServiceDesc

+ var File_plugin_proto protoreflect.FileDescriptor

+ var PluginService_ServiceDesc = grpc.ServiceDesc

+ func RegisterEngineCallbackServiceServer(s grpc.ServiceRegistrar, srv EngineCallbackServiceServer)

+ func RegisterPluginServiceServer(s grpc.ServiceRegistrar, srv PluginServiceServer)

+ type ConfigFieldDef struct

+ DefaultValue string

+ Description string

+ Name string

+ Options []string

+ Required bool

+ Type string

+ func (*ConfigFieldDef) Descriptor() ([]byte, []int)

+ func (*ConfigFieldDef) ProtoMessage()

+ func (x *ConfigFieldDef) GetDefaultValue() string

+ func (x *ConfigFieldDef) GetDescription() string

+ func (x *ConfigFieldDef) GetName() string

+ func (x *ConfigFieldDef) GetOptions() []string

+ func (x *ConfigFieldDef) GetRequired() bool

+ func (x *ConfigFieldDef) GetType() string

+ func (x *ConfigFieldDef) ProtoReflect() protoreflect.Message

+ func (x *ConfigFieldDef) Reset()

+ func (x *ConfigFieldDef) String() string

+ type CreateModuleRequest struct

+ Config *structpb.Struct

+ Name string

+ Type string

+ func (*CreateModuleRequest) Descriptor() ([]byte, []int)

+ func (*CreateModuleRequest) ProtoMessage()

+ func (x *CreateModuleRequest) GetConfig() *structpb.Struct

+ func (x *CreateModuleRequest) GetName() string

+ func (x *CreateModuleRequest) GetType() string

+ func (x *CreateModuleRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateModuleRequest) Reset()

+ func (x *CreateModuleRequest) String() string

+ type CreateStepRequest struct

+ Config *structpb.Struct

+ Name string

+ Type string

+ func (*CreateStepRequest) Descriptor() ([]byte, []int)

+ func (*CreateStepRequest) ProtoMessage()

+ func (x *CreateStepRequest) GetConfig() *structpb.Struct

+ func (x *CreateStepRequest) GetName() string

+ func (x *CreateStepRequest) GetType() string

+ func (x *CreateStepRequest) ProtoReflect() protoreflect.Message

+ func (x *CreateStepRequest) Reset()

+ func (x *CreateStepRequest) String() string

+ type EngineCallbackServiceClient interface

+ GetService func(ctx context.Context, in *GetServiceRequest, opts ...grpc.CallOption) (*GetServiceResponse, error)

+ Log func(ctx context.Context, in *LogRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ TriggerWorkflow func(ctx context.Context, in *TriggerWorkflowRequest, opts ...grpc.CallOption) (*ErrorResponse, error)

+ func NewEngineCallbackServiceClient(cc grpc.ClientConnInterface) EngineCallbackServiceClient

+ type EngineCallbackServiceServer interface

+ GetService func(context.Context, *GetServiceRequest) (*GetServiceResponse, error)

+ Log func(context.Context, *LogRequest) (*emptypb.Empty, error)

+ TriggerWorkflow func(context.Context, *TriggerWorkflowRequest) (*ErrorResponse, error)

+ type ErrorResponse struct

+ Error string

+ func (*ErrorResponse) Descriptor() ([]byte, []int)

+ func (*ErrorResponse) ProtoMessage()

+ func (x *ErrorResponse) GetError() string

+ func (x *ErrorResponse) ProtoReflect() protoreflect.Message

+ func (x *ErrorResponse) Reset()

+ func (x *ErrorResponse) String() string

+ type ExecuteStepRequest struct

+ Current *structpb.Struct

+ HandleId string

+ Metadata *structpb.Struct

+ StepOutputs map[string]*structpb.Struct

+ TriggerData *structpb.Struct

+ func (*ExecuteStepRequest) Descriptor() ([]byte, []int)

+ func (*ExecuteStepRequest) ProtoMessage()

+ func (x *ExecuteStepRequest) GetCurrent() *structpb.Struct

+ func (x *ExecuteStepRequest) GetHandleId() string

+ func (x *ExecuteStepRequest) GetMetadata() *structpb.Struct

+ func (x *ExecuteStepRequest) GetStepOutputs() map[string]*structpb.Struct

+ func (x *ExecuteStepRequest) GetTriggerData() *structpb.Struct

+ func (x *ExecuteStepRequest) ProtoReflect() protoreflect.Message

+ func (x *ExecuteStepRequest) Reset()

+ func (x *ExecuteStepRequest) String() string

+ type ExecuteStepResponse struct

+ Error string

+ Output *structpb.Struct

+ StopPipeline bool

+ func (*ExecuteStepResponse) Descriptor() ([]byte, []int)

+ func (*ExecuteStepResponse) ProtoMessage()

+ func (x *ExecuteStepResponse) GetError() string

+ func (x *ExecuteStepResponse) GetOutput() *structpb.Struct

+ func (x *ExecuteStepResponse) GetStopPipeline() bool

+ func (x *ExecuteStepResponse) ProtoReflect() protoreflect.Message

+ func (x *ExecuteStepResponse) Reset()

+ func (x *ExecuteStepResponse) String() string

+ type GetServiceRequest struct

+ Name string

+ func (*GetServiceRequest) Descriptor() ([]byte, []int)

+ func (*GetServiceRequest) ProtoMessage()

+ func (x *GetServiceRequest) GetName() string

+ func (x *GetServiceRequest) ProtoReflect() protoreflect.Message

+ func (x *GetServiceRequest) Reset()

+ func (x *GetServiceRequest) String() string

+ type GetServiceResponse struct

+ Found bool

+ func (*GetServiceResponse) Descriptor() ([]byte, []int)

+ func (*GetServiceResponse) ProtoMessage()

+ func (x *GetServiceResponse) GetFound() bool

+ func (x *GetServiceResponse) ProtoReflect() protoreflect.Message

+ func (x *GetServiceResponse) Reset()

+ func (x *GetServiceResponse) String() string

+ type HandleRequest struct

+ HandleId string

+ func (*HandleRequest) Descriptor() ([]byte, []int)

+ func (*HandleRequest) ProtoMessage()

+ func (x *HandleRequest) GetHandleId() string

+ func (x *HandleRequest) ProtoReflect() protoreflect.Message

+ func (x *HandleRequest) Reset()

+ func (x *HandleRequest) String() string

+ type HandleResponse struct

+ Error string

+ HandleId string

+ func (*HandleResponse) Descriptor() ([]byte, []int)

+ func (*HandleResponse) ProtoMessage()

+ func (x *HandleResponse) GetError() string

+ func (x *HandleResponse) GetHandleId() string

+ func (x *HandleResponse) ProtoReflect() protoreflect.Message

+ func (x *HandleResponse) Reset()

+ func (x *HandleResponse) String() string

+ type InvokeServiceRequest struct

+ Args *structpb.Struct

+ HandleId string

+ Method string

+ func (*InvokeServiceRequest) Descriptor() ([]byte, []int)

+ func (*InvokeServiceRequest) ProtoMessage()

+ func (x *InvokeServiceRequest) GetArgs() *structpb.Struct

+ func (x *InvokeServiceRequest) GetHandleId() string

+ func (x *InvokeServiceRequest) GetMethod() string

+ func (x *InvokeServiceRequest) ProtoReflect() protoreflect.Message

+ func (x *InvokeServiceRequest) Reset()

+ func (x *InvokeServiceRequest) String() string

+ type InvokeServiceResponse struct

+ Error string

+ Result *structpb.Struct

+ func (*InvokeServiceResponse) Descriptor() ([]byte, []int)

+ func (*InvokeServiceResponse) ProtoMessage()

+ func (x *InvokeServiceResponse) GetError() string

+ func (x *InvokeServiceResponse) GetResult() *structpb.Struct

+ func (x *InvokeServiceResponse) ProtoReflect() protoreflect.Message

+ func (x *InvokeServiceResponse) Reset()

+ func (x *InvokeServiceResponse) String() string

+ type LogRequest struct

+ Fields *structpb.Struct

+ Level string

+ Message string

+ func (*LogRequest) Descriptor() ([]byte, []int)

+ func (*LogRequest) ProtoMessage()

+ func (x *LogRequest) GetFields() *structpb.Struct

+ func (x *LogRequest) GetLevel() string

+ func (x *LogRequest) GetMessage() string

+ func (x *LogRequest) ProtoReflect() protoreflect.Message

+ func (x *LogRequest) Reset()

+ func (x *LogRequest) String() string

+ type Manifest struct

+ Author string

+ Description string

+ Name string

+ Version string

+ func (*Manifest) Descriptor() ([]byte, []int)

+ func (*Manifest) ProtoMessage()

+ func (x *Manifest) GetAuthor() string

+ func (x *Manifest) GetDescription() string

+ func (x *Manifest) GetName() string

+ func (x *Manifest) GetVersion() string

+ func (x *Manifest) ProtoReflect() protoreflect.Message

+ func (x *Manifest) Reset()

+ func (x *Manifest) String() string

+ type ModuleSchema struct

+ Category string

+ ConfigFields []*ConfigFieldDef

+ Description string

+ Inputs []*ServiceIODef

+ Label string

+ Outputs []*ServiceIODef

+ Type string

+ func (*ModuleSchema) Descriptor() ([]byte, []int)

+ func (*ModuleSchema) ProtoMessage()

+ func (x *ModuleSchema) GetCategory() string

+ func (x *ModuleSchema) GetConfigFields() []*ConfigFieldDef

+ func (x *ModuleSchema) GetDescription() string

+ func (x *ModuleSchema) GetInputs() []*ServiceIODef

+ func (x *ModuleSchema) GetLabel() string

+ func (x *ModuleSchema) GetOutputs() []*ServiceIODef

+ func (x *ModuleSchema) GetType() string

+ func (x *ModuleSchema) ProtoReflect() protoreflect.Message

+ func (x *ModuleSchema) Reset()

+ func (x *ModuleSchema) String() string

+ type ModuleSchemaList struct

+ Schemas []*ModuleSchema

+ func (*ModuleSchemaList) Descriptor() ([]byte, []int)

+ func (*ModuleSchemaList) ProtoMessage()

+ func (x *ModuleSchemaList) GetSchemas() []*ModuleSchema

+ func (x *ModuleSchemaList) ProtoReflect() protoreflect.Message

+ func (x *ModuleSchemaList) Reset()

+ func (x *ModuleSchemaList) String() string

+ type PluginServiceClient interface

+ CreateModule func(ctx context.Context, in *CreateModuleRequest, opts ...grpc.CallOption) (*HandleResponse, error)

+ CreateStep func(ctx context.Context, in *CreateStepRequest, opts ...grpc.CallOption) (*HandleResponse, error)

+ DestroyModule func(ctx context.Context, in *HandleRequest, opts ...grpc.CallOption) (*ErrorResponse, error)

+ DestroyStep func(ctx context.Context, in *HandleRequest, opts ...grpc.CallOption) (*ErrorResponse, error)

+ ExecuteStep func(ctx context.Context, in *ExecuteStepRequest, opts ...grpc.CallOption) (*ExecuteStepResponse, error)

+ GetManifest func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*Manifest, error)

+ GetModuleSchemas func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ModuleSchemaList, error)

+ GetModuleTypes func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TypeList, error)

+ GetStepTypes func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TypeList, error)

+ GetTriggerTypes func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*TypeList, error)

+ InitModule func(ctx context.Context, in *HandleRequest, opts ...grpc.CallOption) (*ErrorResponse, error)

+ InvokeService func(ctx context.Context, in *InvokeServiceRequest, opts ...grpc.CallOption) (*InvokeServiceResponse, error)

+ StartModule func(ctx context.Context, in *HandleRequest, opts ...grpc.CallOption) (*ErrorResponse, error)

+ StopModule func(ctx context.Context, in *HandleRequest, opts ...grpc.CallOption) (*ErrorResponse, error)

+ func NewPluginServiceClient(cc grpc.ClientConnInterface) PluginServiceClient

+ type PluginServiceServer interface

+ CreateModule func(context.Context, *CreateModuleRequest) (*HandleResponse, error)

+ CreateStep func(context.Context, *CreateStepRequest) (*HandleResponse, error)

+ DestroyModule func(context.Context, *HandleRequest) (*ErrorResponse, error)

+ DestroyStep func(context.Context, *HandleRequest) (*ErrorResponse, error)

+ ExecuteStep func(context.Context, *ExecuteStepRequest) (*ExecuteStepResponse, error)

+ GetManifest func(context.Context, *emptypb.Empty) (*Manifest, error)

+ GetModuleSchemas func(context.Context, *emptypb.Empty) (*ModuleSchemaList, error)

+ GetModuleTypes func(context.Context, *emptypb.Empty) (*TypeList, error)

+ GetStepTypes func(context.Context, *emptypb.Empty) (*TypeList, error)

+ GetTriggerTypes func(context.Context, *emptypb.Empty) (*TypeList, error)

+ InitModule func(context.Context, *HandleRequest) (*ErrorResponse, error)

+ InvokeService func(context.Context, *InvokeServiceRequest) (*InvokeServiceResponse, error)

+ StartModule func(context.Context, *HandleRequest) (*ErrorResponse, error)

+ StopModule func(context.Context, *HandleRequest) (*ErrorResponse, error)

+ type ServiceIODef struct

+ Description string

+ Name string

+ Type string

+ func (*ServiceIODef) Descriptor() ([]byte, []int)

+ func (*ServiceIODef) ProtoMessage()

+ func (x *ServiceIODef) GetDescription() string

+ func (x *ServiceIODef) GetName() string

+ func (x *ServiceIODef) GetType() string

+ func (x *ServiceIODef) ProtoReflect() protoreflect.Message

+ func (x *ServiceIODef) Reset()

+ func (x *ServiceIODef) String() string

+ type TriggerWorkflowRequest struct

+ Action string

+ Data *structpb.Struct

+ TriggerType string

+ func (*TriggerWorkflowRequest) Descriptor() ([]byte, []int)

+ func (*TriggerWorkflowRequest) ProtoMessage()

+ func (x *TriggerWorkflowRequest) GetAction() string

+ func (x *TriggerWorkflowRequest) GetData() *structpb.Struct

+ func (x *TriggerWorkflowRequest) GetTriggerType() string

+ func (x *TriggerWorkflowRequest) ProtoReflect() protoreflect.Message

+ func (x *TriggerWorkflowRequest) Reset()

+ func (x *TriggerWorkflowRequest) String() string

+ type TypeList struct

+ Types []string

+ func (*TypeList) Descriptor() ([]byte, []int)

+ func (*TypeList) ProtoMessage()

+ func (x *TypeList) GetTypes() []string

+ func (x *TypeList) ProtoReflect() protoreflect.Message

+ func (x *TypeList) Reset()

+ func (x *TypeList) String() string

+ type UnimplementedEngineCallbackServiceServer struct

+ func (UnimplementedEngineCallbackServiceServer) GetService(context.Context, *GetServiceRequest) (*GetServiceResponse, error)

+ func (UnimplementedEngineCallbackServiceServer) Log(context.Context, *LogRequest) (*emptypb.Empty, error)

+ func (UnimplementedEngineCallbackServiceServer) TriggerWorkflow(context.Context, *TriggerWorkflowRequest) (*ErrorResponse, error)

+ type UnimplementedPluginServiceServer struct

+ func (UnimplementedPluginServiceServer) CreateModule(context.Context, *CreateModuleRequest) (*HandleResponse, error)

+ func (UnimplementedPluginServiceServer) CreateStep(context.Context, *CreateStepRequest) (*HandleResponse, error)

+ func (UnimplementedPluginServiceServer) DestroyModule(context.Context, *HandleRequest) (*ErrorResponse, error)

+ func (UnimplementedPluginServiceServer) DestroyStep(context.Context, *HandleRequest) (*ErrorResponse, error)

+ func (UnimplementedPluginServiceServer) ExecuteStep(context.Context, *ExecuteStepRequest) (*ExecuteStepResponse, error)

+ func (UnimplementedPluginServiceServer) GetManifest(context.Context, *emptypb.Empty) (*Manifest, error)

+ func (UnimplementedPluginServiceServer) GetModuleSchemas(context.Context, *emptypb.Empty) (*ModuleSchemaList, error)

+ func (UnimplementedPluginServiceServer) GetModuleTypes(context.Context, *emptypb.Empty) (*TypeList, error)

+ func (UnimplementedPluginServiceServer) GetStepTypes(context.Context, *emptypb.Empty) (*TypeList, error)

+ func (UnimplementedPluginServiceServer) GetTriggerTypes(context.Context, *emptypb.Empty) (*TypeList, error)

+ func (UnimplementedPluginServiceServer) InitModule(context.Context, *HandleRequest) (*ErrorResponse, error)

+ func (UnimplementedPluginServiceServer) InvokeService(context.Context, *InvokeServiceRequest) (*InvokeServiceResponse, error)

+ func (UnimplementedPluginServiceServer) StartModule(context.Context, *HandleRequest) (*ErrorResponse, error)

+ func (UnimplementedPluginServiceServer) StopModule(context.Context, *HandleRequest) (*ErrorResponse, error)

+ type UnsafeEngineCallbackServiceServer interface

+ type UnsafePluginServiceServer interface

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