Versions in this module Expand all Collapse all v0 v0.5.0 Mar 30, 2026 Changes in this version + const StepTypeService_ExecuteStep_FullMethodName + const StepTypeService_ListStepTypes_FullMethodName + const ValidatorService_ValidateStep_FullMethodName + const ValidatorService_ValidateWorkflow_FullMethodName + var Severity_name = map[int32]string + var Severity_value = map[string]int32 + var StepTypeService_ServiceDesc = grpc.ServiceDesc + var ValidatorService_ServiceDesc = grpc.ServiceDesc + func RegisterStepTypeServiceServer(s grpc.ServiceRegistrar, srv StepTypeServiceServer) + func RegisterValidatorServiceServer(s grpc.ServiceRegistrar, srv ValidatorServiceServer) + type ExecuteStepRequest struct + Config []byte + Inputs []byte + StepName string + StepType string + func (*ExecuteStepRequest) Descriptor() ([]byte, []int) + func (*ExecuteStepRequest) ProtoMessage() + func (x *ExecuteStepRequest) GetConfig() []byte + func (x *ExecuteStepRequest) GetInputs() []byte + func (x *ExecuteStepRequest) GetStepName() string + func (x *ExecuteStepRequest) GetStepType() string + func (x *ExecuteStepRequest) ProtoReflect() protoreflect.Message + func (x *ExecuteStepRequest) Reset() + func (x *ExecuteStepRequest) String() string + type ExecuteStepResponse struct + Data []byte + ExitCode int32 + Output string + func (*ExecuteStepResponse) Descriptor() ([]byte, []int) + func (*ExecuteStepResponse) ProtoMessage() + func (x *ExecuteStepResponse) GetData() []byte + func (x *ExecuteStepResponse) GetExitCode() int32 + func (x *ExecuteStepResponse) GetOutput() string + func (x *ExecuteStepResponse) ProtoReflect() protoreflect.Message + func (x *ExecuteStepResponse) Reset() + func (x *ExecuteStepResponse) String() string + type ListStepTypesRequest struct + func (*ListStepTypesRequest) Descriptor() ([]byte, []int) + func (*ListStepTypesRequest) ProtoMessage() + func (x *ListStepTypesRequest) ProtoReflect() protoreflect.Message + func (x *ListStepTypesRequest) Reset() + func (x *ListStepTypesRequest) String() string + type ListStepTypesResponse struct + StepTypes []*StepTypeInfo + func (*ListStepTypesResponse) Descriptor() ([]byte, []int) + func (*ListStepTypesResponse) ProtoMessage() + func (x *ListStepTypesResponse) GetStepTypes() []*StepTypeInfo + func (x *ListStepTypesResponse) ProtoReflect() protoreflect.Message + func (x *ListStepTypesResponse) Reset() + func (x *ListStepTypesResponse) String() string + type Severity int32 + const Severity_SEVERITY_ERROR + const Severity_SEVERITY_INFO + const Severity_SEVERITY_UNSPECIFIED + const Severity_SEVERITY_WARNING + func (Severity) Descriptor() protoreflect.EnumDescriptor + func (Severity) EnumDescriptor() ([]byte, []int) + func (Severity) Type() protoreflect.EnumType + func (x Severity) Enum() *Severity + func (x Severity) Number() protoreflect.EnumNumber + func (x Severity) String() string + type StepTypeInfo struct + Description string + Name string + func (*StepTypeInfo) Descriptor() ([]byte, []int) + func (*StepTypeInfo) ProtoMessage() + func (x *StepTypeInfo) GetDescription() string + func (x *StepTypeInfo) GetName() string + func (x *StepTypeInfo) ProtoReflect() protoreflect.Message + func (x *StepTypeInfo) Reset() + func (x *StepTypeInfo) String() string + type StepTypeServiceClient interface + ExecuteStep func(ctx context.Context, in *ExecuteStepRequest, opts ...grpc.CallOption) (*ExecuteStepResponse, error) + ListStepTypes func(ctx context.Context, in *ListStepTypesRequest, opts ...grpc.CallOption) (*ListStepTypesResponse, error) + func NewStepTypeServiceClient(cc grpc.ClientConnInterface) StepTypeServiceClient + type StepTypeServiceServer interface + ExecuteStep func(context.Context, *ExecuteStepRequest) (*ExecuteStepResponse, error) + ListStepTypes func(context.Context, *ListStepTypesRequest) (*ListStepTypesResponse, error) + type UnimplementedStepTypeServiceServer struct + func (UnimplementedStepTypeServiceServer) ExecuteStep(context.Context, *ExecuteStepRequest) (*ExecuteStepResponse, error) + func (UnimplementedStepTypeServiceServer) ListStepTypes(context.Context, *ListStepTypesRequest) (*ListStepTypesResponse, error) + type UnimplementedValidatorServiceServer struct + func (UnimplementedValidatorServiceServer) ValidateStep(context.Context, *ValidateStepRequest) (*ValidateStepResponse, error) + func (UnimplementedValidatorServiceServer) ValidateWorkflow(context.Context, *ValidateWorkflowRequest) (*ValidateWorkflowResponse, error) + type UnsafeStepTypeServiceServer interface + type UnsafeValidatorServiceServer interface + type ValidateStepRequest struct + StepName string + WorkflowJson []byte + func (*ValidateStepRequest) Descriptor() ([]byte, []int) + func (*ValidateStepRequest) ProtoMessage() + func (x *ValidateStepRequest) GetStepName() string + func (x *ValidateStepRequest) GetWorkflowJson() []byte + func (x *ValidateStepRequest) ProtoReflect() protoreflect.Message + func (x *ValidateStepRequest) Reset() + func (x *ValidateStepRequest) String() string + type ValidateStepResponse struct + Issues []*ValidationIssue + func (*ValidateStepResponse) Descriptor() ([]byte, []int) + func (*ValidateStepResponse) ProtoMessage() + func (x *ValidateStepResponse) GetIssues() []*ValidationIssue + func (x *ValidateStepResponse) ProtoReflect() protoreflect.Message + func (x *ValidateStepResponse) Reset() + func (x *ValidateStepResponse) String() string + type ValidateWorkflowRequest struct + WorkflowJson []byte + func (*ValidateWorkflowRequest) Descriptor() ([]byte, []int) + func (*ValidateWorkflowRequest) ProtoMessage() + func (x *ValidateWorkflowRequest) GetWorkflowJson() []byte + func (x *ValidateWorkflowRequest) ProtoReflect() protoreflect.Message + func (x *ValidateWorkflowRequest) Reset() + func (x *ValidateWorkflowRequest) String() string + type ValidateWorkflowResponse struct + Issues []*ValidationIssue + func (*ValidateWorkflowResponse) Descriptor() ([]byte, []int) + func (*ValidateWorkflowResponse) ProtoMessage() + func (x *ValidateWorkflowResponse) GetIssues() []*ValidationIssue + func (x *ValidateWorkflowResponse) ProtoReflect() protoreflect.Message + func (x *ValidateWorkflowResponse) Reset() + func (x *ValidateWorkflowResponse) String() string + type ValidationIssue struct + Field string + Message string + Severity Severity + Step string + func (*ValidationIssue) Descriptor() ([]byte, []int) + func (*ValidationIssue) ProtoMessage() + func (x *ValidationIssue) GetField() string + func (x *ValidationIssue) GetMessage() string + func (x *ValidationIssue) GetSeverity() Severity + func (x *ValidationIssue) GetStep() string + func (x *ValidationIssue) ProtoReflect() protoreflect.Message + func (x *ValidationIssue) Reset() + func (x *ValidationIssue) String() string + type ValidatorServiceClient interface + ValidateStep func(ctx context.Context, in *ValidateStepRequest, opts ...grpc.CallOption) (*ValidateStepResponse, error) + ValidateWorkflow func(ctx context.Context, in *ValidateWorkflowRequest, opts ...grpc.CallOption) (*ValidateWorkflowResponse, error) + func NewValidatorServiceClient(cc grpc.ClientConnInterface) ValidatorServiceClient + type ValidatorServiceServer interface + ValidateStep func(context.Context, *ValidateStepRequest) (*ValidateStepResponse, error) + ValidateWorkflow func(context.Context, *ValidateWorkflowRequest) (*ValidateWorkflowResponse, error) v0.4.1 Mar 28, 2026 Changes in this version + const OperationService_Execute_FullMethodName + const OperationService_GetOperation_FullMethodName + const OperationService_ListOperations_FullMethodName + const PluginService_GetInfo_FullMethodName + const PluginService_Init_FullMethodName + const PluginService_Shutdown_FullMethodName + var File_proto_plugin_v1_plugin_proto protoreflect.FileDescriptor + var OperationService_ServiceDesc = grpc.ServiceDesc + var PluginService_ServiceDesc = grpc.ServiceDesc + func RegisterOperationServiceServer(s grpc.ServiceRegistrar, srv OperationServiceServer) + func RegisterPluginServiceServer(s grpc.ServiceRegistrar, srv PluginServiceServer) + type ExecuteRequest struct + Inputs map[string][]byte + Operation string + func (*ExecuteRequest) Descriptor() ([]byte, []int) + func (*ExecuteRequest) ProtoMessage() + func (x *ExecuteRequest) GetInputs() map[string][]byte + func (x *ExecuteRequest) GetOperation() string + func (x *ExecuteRequest) ProtoReflect() protoreflect.Message + func (x *ExecuteRequest) Reset() + func (x *ExecuteRequest) String() string + type ExecuteResponse struct + Data map[string][]byte + Error string + Output string + Success bool + func (*ExecuteResponse) Descriptor() ([]byte, []int) + func (*ExecuteResponse) ProtoMessage() + func (x *ExecuteResponse) GetData() map[string][]byte + func (x *ExecuteResponse) GetError() string + func (x *ExecuteResponse) GetOutput() string + func (x *ExecuteResponse) GetSuccess() bool + func (x *ExecuteResponse) ProtoReflect() protoreflect.Message + func (x *ExecuteResponse) Reset() + func (x *ExecuteResponse) String() string + type GetInfoRequest struct + func (*GetInfoRequest) Descriptor() ([]byte, []int) + func (*GetInfoRequest) ProtoMessage() + func (x *GetInfoRequest) ProtoReflect() protoreflect.Message + func (x *GetInfoRequest) Reset() + func (x *GetInfoRequest) String() string + type GetInfoResponse struct + Capabilities []string + Description string + Name string + Version string + func (*GetInfoResponse) Descriptor() ([]byte, []int) + func (*GetInfoResponse) ProtoMessage() + func (x *GetInfoResponse) GetCapabilities() []string + func (x *GetInfoResponse) GetDescription() string + func (x *GetInfoResponse) GetName() string + func (x *GetInfoResponse) GetVersion() string + func (x *GetInfoResponse) ProtoReflect() protoreflect.Message + func (x *GetInfoResponse) Reset() + func (x *GetInfoResponse) String() string + type GetOperationRequest struct + Name string + func (*GetOperationRequest) Descriptor() ([]byte, []int) + func (*GetOperationRequest) ProtoMessage() + func (x *GetOperationRequest) GetName() string + func (x *GetOperationRequest) ProtoReflect() protoreflect.Message + func (x *GetOperationRequest) Reset() + func (x *GetOperationRequest) String() string + type GetOperationResponse struct + Operation *OperationSchema + func (*GetOperationResponse) Descriptor() ([]byte, []int) + func (*GetOperationResponse) ProtoMessage() + func (x *GetOperationResponse) GetOperation() *OperationSchema + func (x *GetOperationResponse) ProtoReflect() protoreflect.Message + func (x *GetOperationResponse) Reset() + func (x *GetOperationResponse) String() string + type InitRequest struct + Config map[string][]byte + func (*InitRequest) Descriptor() ([]byte, []int) + func (*InitRequest) ProtoMessage() + func (x *InitRequest) GetConfig() map[string][]byte + func (x *InitRequest) ProtoReflect() protoreflect.Message + func (x *InitRequest) Reset() + func (x *InitRequest) String() string + type InitResponse struct + func (*InitResponse) Descriptor() ([]byte, []int) + func (*InitResponse) ProtoMessage() + func (x *InitResponse) ProtoReflect() protoreflect.Message + func (x *InitResponse) Reset() + func (x *InitResponse) String() string + type InputSchema struct + Default string + Description string + Name string + Required bool + Type string + Validation string + func (*InputSchema) Descriptor() ([]byte, []int) + func (*InputSchema) ProtoMessage() + func (x *InputSchema) GetDefault() string + func (x *InputSchema) GetDescription() string + func (x *InputSchema) GetName() string + func (x *InputSchema) GetRequired() bool + func (x *InputSchema) GetType() string + func (x *InputSchema) GetValidation() string + func (x *InputSchema) ProtoReflect() protoreflect.Message + func (x *InputSchema) Reset() + func (x *InputSchema) String() string + type ListOperationsRequest struct + func (*ListOperationsRequest) Descriptor() ([]byte, []int) + func (*ListOperationsRequest) ProtoMessage() + func (x *ListOperationsRequest) ProtoReflect() protoreflect.Message + func (x *ListOperationsRequest) Reset() + func (x *ListOperationsRequest) String() string + type ListOperationsResponse struct + Operations []*OperationSchema + func (*ListOperationsResponse) Descriptor() ([]byte, []int) + func (*ListOperationsResponse) ProtoMessage() + func (x *ListOperationsResponse) GetOperations() []*OperationSchema + func (x *ListOperationsResponse) ProtoReflect() protoreflect.Message + func (x *ListOperationsResponse) Reset() + func (x *ListOperationsResponse) String() string + type OperationSchema struct + Description string + Inputs []*InputSchema + Name string + Outputs []*OutputSchema + func (*OperationSchema) Descriptor() ([]byte, []int) + func (*OperationSchema) ProtoMessage() + func (x *OperationSchema) GetDescription() string + func (x *OperationSchema) GetInputs() []*InputSchema + func (x *OperationSchema) GetName() string + func (x *OperationSchema) GetOutputs() []*OutputSchema + func (x *OperationSchema) ProtoReflect() protoreflect.Message + func (x *OperationSchema) Reset() + func (x *OperationSchema) String() string + type OperationServiceClient interface + Execute func(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error) + GetOperation func(ctx context.Context, in *GetOperationRequest, opts ...grpc.CallOption) (*GetOperationResponse, error) + ListOperations func(ctx context.Context, in *ListOperationsRequest, opts ...grpc.CallOption) (*ListOperationsResponse, error) + func NewOperationServiceClient(cc grpc.ClientConnInterface) OperationServiceClient + type OperationServiceServer interface + Execute func(context.Context, *ExecuteRequest) (*ExecuteResponse, error) + GetOperation func(context.Context, *GetOperationRequest) (*GetOperationResponse, error) + ListOperations func(context.Context, *ListOperationsRequest) (*ListOperationsResponse, error) + type OutputSchema struct + Description string + Name string + Type string + func (*OutputSchema) Descriptor() ([]byte, []int) + func (*OutputSchema) ProtoMessage() + func (x *OutputSchema) GetDescription() string + func (x *OutputSchema) GetName() string + func (x *OutputSchema) GetType() string + func (x *OutputSchema) ProtoReflect() protoreflect.Message + func (x *OutputSchema) Reset() + func (x *OutputSchema) String() string + type PluginServiceClient interface + GetInfo func(ctx context.Context, in *GetInfoRequest, opts ...grpc.CallOption) (*GetInfoResponse, error) + Init func(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error) + Shutdown func(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error) + func NewPluginServiceClient(cc grpc.ClientConnInterface) PluginServiceClient + type PluginServiceServer interface + GetInfo func(context.Context, *GetInfoRequest) (*GetInfoResponse, error) + Init func(context.Context, *InitRequest) (*InitResponse, error) + Shutdown func(context.Context, *ShutdownRequest) (*ShutdownResponse, error) + type ShutdownRequest struct + func (*ShutdownRequest) Descriptor() ([]byte, []int) + func (*ShutdownRequest) ProtoMessage() + func (x *ShutdownRequest) ProtoReflect() protoreflect.Message + func (x *ShutdownRequest) Reset() + func (x *ShutdownRequest) String() string + type ShutdownResponse struct + func (*ShutdownResponse) Descriptor() ([]byte, []int) + func (*ShutdownResponse) ProtoMessage() + func (x *ShutdownResponse) ProtoReflect() protoreflect.Message + func (x *ShutdownResponse) Reset() + func (x *ShutdownResponse) String() string + type UnimplementedOperationServiceServer struct + func (UnimplementedOperationServiceServer) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error) + func (UnimplementedOperationServiceServer) GetOperation(context.Context, *GetOperationRequest) (*GetOperationResponse, error) + func (UnimplementedOperationServiceServer) ListOperations(context.Context, *ListOperationsRequest) (*ListOperationsResponse, error) + type UnimplementedPluginServiceServer struct + func (UnimplementedPluginServiceServer) GetInfo(context.Context, *GetInfoRequest) (*GetInfoResponse, error) + func (UnimplementedPluginServiceServer) Init(context.Context, *InitRequest) (*InitResponse, error) + func (UnimplementedPluginServiceServer) Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error) + type UnsafeOperationServiceServer interface + type UnsafePluginServiceServer interface
Go to main page