pluginv1

package
v0.5.0 Latest Latest
Warning

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

Go to latest
Published: Mar 30, 2026 License: EUPL-1.2 Imports: 10 Imported by: 0

Documentation

Overview

Package pluginv1 contains the generated protobuf and gRPC code for the AWF plugin protocol. This file will be overwritten by `make proto-gen` (T005) once plugin.proto is defined (T004).

Index

Constants

View Source
const (
	PluginService_GetInfo_FullMethodName  = "/plugin.v1.PluginService/GetInfo"
	PluginService_Init_FullMethodName     = "/plugin.v1.PluginService/Init"
	PluginService_Shutdown_FullMethodName = "/plugin.v1.PluginService/Shutdown"
)
View Source
const (
	OperationService_ListOperations_FullMethodName = "/plugin.v1.OperationService/ListOperations"
	OperationService_GetOperation_FullMethodName   = "/plugin.v1.OperationService/GetOperation"
	OperationService_Execute_FullMethodName        = "/plugin.v1.OperationService/Execute"
)
View Source
const (
	ValidatorService_ValidateWorkflow_FullMethodName = "/plugin.v1.ValidatorService/ValidateWorkflow"
	ValidatorService_ValidateStep_FullMethodName     = "/plugin.v1.ValidatorService/ValidateStep"
)
View Source
const (
	StepTypeService_ListStepTypes_FullMethodName = "/plugin.v1.StepTypeService/ListStepTypes"
	StepTypeService_ExecuteStep_FullMethodName   = "/plugin.v1.StepTypeService/ExecuteStep"
)

Variables

View Source
var (
	Severity_name = map[int32]string{
		0: "SEVERITY_UNSPECIFIED",
		1: "SEVERITY_WARNING",
		2: "SEVERITY_ERROR",
		3: "SEVERITY_INFO",
	}
	Severity_value = map[string]int32{
		"SEVERITY_UNSPECIFIED": 0,
		"SEVERITY_WARNING":     1,
		"SEVERITY_ERROR":       2,
		"SEVERITY_INFO":        3,
	}
)

Enum value maps for Severity.

View Source
var File_proto_plugin_v1_plugin_proto protoreflect.FileDescriptor
View Source
var OperationService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugin.v1.OperationService",
	HandlerType: (*OperationServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListOperations",
			Handler:    _OperationService_ListOperations_Handler,
		},
		{
			MethodName: "GetOperation",
			Handler:    _OperationService_GetOperation_Handler,
		},
		{
			MethodName: "Execute",
			Handler:    _OperationService_Execute_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/plugin/v1/plugin.proto",
}

OperationService_ServiceDesc is the grpc.ServiceDesc for OperationService 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 PluginService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugin.v1.PluginService",
	HandlerType: (*PluginServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetInfo",
			Handler:    _PluginService_GetInfo_Handler,
		},
		{
			MethodName: "Init",
			Handler:    _PluginService_Init_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _PluginService_Shutdown_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/plugin/v1/plugin.proto",
}

PluginService_ServiceDesc is the grpc.ServiceDesc for PluginService 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 StepTypeService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugin.v1.StepTypeService",
	HandlerType: (*StepTypeServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListStepTypes",
			Handler:    _StepTypeService_ListStepTypes_Handler,
		},
		{
			MethodName: "ExecuteStep",
			Handler:    _StepTypeService_ExecuteStep_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/plugin/v1/plugin.proto",
}

StepTypeService_ServiceDesc is the grpc.ServiceDesc for StepTypeService 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 ValidatorService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "plugin.v1.ValidatorService",
	HandlerType: (*ValidatorServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ValidateWorkflow",
			Handler:    _ValidatorService_ValidateWorkflow_Handler,
		},
		{
			MethodName: "ValidateStep",
			Handler:    _ValidatorService_ValidateStep_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/plugin/v1/plugin.proto",
}

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

Functions

func RegisterOperationServiceServer

func RegisterOperationServiceServer(s grpc.ServiceRegistrar, srv OperationServiceServer)

func RegisterPluginServiceServer

func RegisterPluginServiceServer(s grpc.ServiceRegistrar, srv PluginServiceServer)

func RegisterStepTypeServiceServer added in v0.5.0

func RegisterStepTypeServiceServer(s grpc.ServiceRegistrar, srv StepTypeServiceServer)

func RegisterValidatorServiceServer added in v0.5.0

func RegisterValidatorServiceServer(s grpc.ServiceRegistrar, srv ValidatorServiceServer)

Types

type ExecuteRequest

type ExecuteRequest struct {
	Operation string            `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	Inputs    map[string][]byte `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecuteRequest) Descriptor deprecated

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetInputs

func (x *ExecuteRequest) GetInputs() map[string][]byte

func (*ExecuteRequest) GetOperation

func (x *ExecuteRequest) GetOperation() string

func (*ExecuteRequest) ProtoMessage

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect

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

func (*ExecuteRequest) Reset

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String

func (x *ExecuteRequest) String() string

type ExecuteResponse

type ExecuteResponse struct {
	Success bool              `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Output  string            `protobuf:"bytes,2,opt,name=output,proto3" json:"output,omitempty"`
	Data    map[string][]byte `` /* 135-byte string literal not displayed */
	Error   string            `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteResponse) Descriptor deprecated

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

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetData

func (x *ExecuteResponse) GetData() map[string][]byte

func (*ExecuteResponse) GetError

func (x *ExecuteResponse) GetError() string

func (*ExecuteResponse) GetOutput

func (x *ExecuteResponse) GetOutput() string

func (*ExecuteResponse) GetSuccess

func (x *ExecuteResponse) GetSuccess() bool

func (*ExecuteResponse) ProtoMessage

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect

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

func (*ExecuteResponse) Reset

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String

func (x *ExecuteResponse) String() string

type ExecuteStepRequest added in v0.5.0

type ExecuteStepRequest struct {
	StepName string `protobuf:"bytes,1,opt,name=step_name,json=stepName,proto3" json:"step_name,omitempty"`
	StepType string `protobuf:"bytes,2,opt,name=step_type,json=stepType,proto3" json:"step_type,omitempty"`
	Config   []byte `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
	Inputs   []byte `protobuf:"bytes,4,opt,name=inputs,proto3" json:"inputs,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteStepRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExecuteStepRequest.ProtoReflect.Descriptor instead.

func (*ExecuteStepRequest) GetConfig added in v0.5.0

func (x *ExecuteStepRequest) GetConfig() []byte

func (*ExecuteStepRequest) GetInputs added in v0.5.0

func (x *ExecuteStepRequest) GetInputs() []byte

func (*ExecuteStepRequest) GetStepName added in v0.5.0

func (x *ExecuteStepRequest) GetStepName() string

func (*ExecuteStepRequest) GetStepType added in v0.5.0

func (x *ExecuteStepRequest) GetStepType() string

func (*ExecuteStepRequest) ProtoMessage added in v0.5.0

func (*ExecuteStepRequest) ProtoMessage()

func (*ExecuteStepRequest) ProtoReflect added in v0.5.0

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

func (*ExecuteStepRequest) Reset added in v0.5.0

func (x *ExecuteStepRequest) Reset()

func (*ExecuteStepRequest) String added in v0.5.0

func (x *ExecuteStepRequest) String() string

type ExecuteStepResponse added in v0.5.0

type ExecuteStepResponse struct {
	Output   string `protobuf:"bytes,1,opt,name=output,proto3" json:"output,omitempty"`
	Data     []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	ExitCode int32  `protobuf:"varint,3,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteStepResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ExecuteStepResponse.ProtoReflect.Descriptor instead.

func (*ExecuteStepResponse) GetData added in v0.5.0

func (x *ExecuteStepResponse) GetData() []byte

func (*ExecuteStepResponse) GetExitCode added in v0.5.0

func (x *ExecuteStepResponse) GetExitCode() int32

func (*ExecuteStepResponse) GetOutput added in v0.5.0

func (x *ExecuteStepResponse) GetOutput() string

func (*ExecuteStepResponse) ProtoMessage added in v0.5.0

func (*ExecuteStepResponse) ProtoMessage()

func (*ExecuteStepResponse) ProtoReflect added in v0.5.0

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

func (*ExecuteStepResponse) Reset added in v0.5.0

func (x *ExecuteStepResponse) Reset()

func (*ExecuteStepResponse) String added in v0.5.0

func (x *ExecuteStepResponse) String() string

type GetInfoRequest

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

func (*GetInfoRequest) Descriptor deprecated

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

Deprecated: Use GetInfoRequest.ProtoReflect.Descriptor instead.

func (*GetInfoRequest) ProtoMessage

func (*GetInfoRequest) ProtoMessage()

func (*GetInfoRequest) ProtoReflect

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

func (*GetInfoRequest) Reset

func (x *GetInfoRequest) Reset()

func (*GetInfoRequest) String

func (x *GetInfoRequest) String() string

type GetInfoResponse

type GetInfoResponse struct {
	Name         string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Version      string   `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Description  string   `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Capabilities []string `protobuf:"bytes,4,rep,name=capabilities,proto3" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

func (*GetInfoResponse) Descriptor deprecated

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

Deprecated: Use GetInfoResponse.ProtoReflect.Descriptor instead.

func (*GetInfoResponse) GetCapabilities

func (x *GetInfoResponse) GetCapabilities() []string

func (*GetInfoResponse) GetDescription

func (x *GetInfoResponse) GetDescription() string

func (*GetInfoResponse) GetName

func (x *GetInfoResponse) GetName() string

func (*GetInfoResponse) GetVersion

func (x *GetInfoResponse) GetVersion() string

func (*GetInfoResponse) ProtoMessage

func (*GetInfoResponse) ProtoMessage()

func (*GetInfoResponse) ProtoReflect

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

func (*GetInfoResponse) Reset

func (x *GetInfoResponse) Reset()

func (*GetInfoResponse) String

func (x *GetInfoResponse) String() string

type GetOperationRequest

type GetOperationRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOperationRequest) Descriptor deprecated

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

Deprecated: Use GetOperationRequest.ProtoReflect.Descriptor instead.

func (*GetOperationRequest) GetName

func (x *GetOperationRequest) GetName() string

func (*GetOperationRequest) ProtoMessage

func (*GetOperationRequest) ProtoMessage()

func (*GetOperationRequest) ProtoReflect

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

func (*GetOperationRequest) Reset

func (x *GetOperationRequest) Reset()

func (*GetOperationRequest) String

func (x *GetOperationRequest) String() string

type GetOperationResponse

type GetOperationResponse struct {
	Operation *OperationSchema `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	// contains filtered or unexported fields
}

func (*GetOperationResponse) Descriptor deprecated

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

Deprecated: Use GetOperationResponse.ProtoReflect.Descriptor instead.

func (*GetOperationResponse) GetOperation

func (x *GetOperationResponse) GetOperation() *OperationSchema

func (*GetOperationResponse) ProtoMessage

func (*GetOperationResponse) ProtoMessage()

func (*GetOperationResponse) ProtoReflect

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

func (*GetOperationResponse) Reset

func (x *GetOperationResponse) Reset()

func (*GetOperationResponse) String

func (x *GetOperationResponse) String() string

type InitRequest

type InitRequest struct {
	Config map[string][]byte `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*InitRequest) Descriptor deprecated

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

Deprecated: Use InitRequest.ProtoReflect.Descriptor instead.

func (*InitRequest) GetConfig

func (x *InitRequest) GetConfig() map[string][]byte

func (*InitRequest) ProtoMessage

func (*InitRequest) ProtoMessage()

func (*InitRequest) ProtoReflect

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

func (*InitRequest) Reset

func (x *InitRequest) Reset()

func (*InitRequest) String

func (x *InitRequest) String() string

type InitResponse

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

func (*InitResponse) Descriptor deprecated

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

Deprecated: Use InitResponse.ProtoReflect.Descriptor instead.

func (*InitResponse) ProtoMessage

func (*InitResponse) ProtoMessage()

func (*InitResponse) ProtoReflect

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

func (*InitResponse) Reset

func (x *InitResponse) Reset()

func (*InitResponse) String

func (x *InitResponse) String() string

type InputSchema

type InputSchema struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type        string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Required    bool   `protobuf:"varint,3,opt,name=required,proto3" json:"required,omitempty"`
	Default     string `protobuf:"bytes,4,opt,name=default,proto3" json:"default,omitempty"`
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	Validation  string `protobuf:"bytes,6,opt,name=validation,proto3" json:"validation,omitempty"`
	// contains filtered or unexported fields
}

func (*InputSchema) Descriptor deprecated

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

Deprecated: Use InputSchema.ProtoReflect.Descriptor instead.

func (*InputSchema) GetDefault

func (x *InputSchema) GetDefault() string

func (*InputSchema) GetDescription

func (x *InputSchema) GetDescription() string

func (*InputSchema) GetName

func (x *InputSchema) GetName() string

func (*InputSchema) GetRequired

func (x *InputSchema) GetRequired() bool

func (*InputSchema) GetType

func (x *InputSchema) GetType() string

func (*InputSchema) GetValidation

func (x *InputSchema) GetValidation() string

func (*InputSchema) ProtoMessage

func (*InputSchema) ProtoMessage()

func (*InputSchema) ProtoReflect

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

func (*InputSchema) Reset

func (x *InputSchema) Reset()

func (*InputSchema) String

func (x *InputSchema) String() string

type ListOperationsRequest

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

func (*ListOperationsRequest) Descriptor deprecated

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

Deprecated: Use ListOperationsRequest.ProtoReflect.Descriptor instead.

func (*ListOperationsRequest) ProtoMessage

func (*ListOperationsRequest) ProtoMessage()

func (*ListOperationsRequest) ProtoReflect

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

func (*ListOperationsRequest) Reset

func (x *ListOperationsRequest) Reset()

func (*ListOperationsRequest) String

func (x *ListOperationsRequest) String() string

type ListOperationsResponse

type ListOperationsResponse struct {
	Operations []*OperationSchema `protobuf:"bytes,1,rep,name=operations,proto3" json:"operations,omitempty"`
	// contains filtered or unexported fields
}

func (*ListOperationsResponse) Descriptor deprecated

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

Deprecated: Use ListOperationsResponse.ProtoReflect.Descriptor instead.

func (*ListOperationsResponse) GetOperations

func (x *ListOperationsResponse) GetOperations() []*OperationSchema

func (*ListOperationsResponse) ProtoMessage

func (*ListOperationsResponse) ProtoMessage()

func (*ListOperationsResponse) ProtoReflect

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

func (*ListOperationsResponse) Reset

func (x *ListOperationsResponse) Reset()

func (*ListOperationsResponse) String

func (x *ListOperationsResponse) String() string

type ListStepTypesRequest added in v0.5.0

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

func (*ListStepTypesRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ListStepTypesRequest.ProtoReflect.Descriptor instead.

func (*ListStepTypesRequest) ProtoMessage added in v0.5.0

func (*ListStepTypesRequest) ProtoMessage()

func (*ListStepTypesRequest) ProtoReflect added in v0.5.0

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

func (*ListStepTypesRequest) Reset added in v0.5.0

func (x *ListStepTypesRequest) Reset()

func (*ListStepTypesRequest) String added in v0.5.0

func (x *ListStepTypesRequest) String() string

type ListStepTypesResponse added in v0.5.0

type ListStepTypesResponse struct {
	StepTypes []*StepTypeInfo `protobuf:"bytes,1,rep,name=step_types,json=stepTypes,proto3" json:"step_types,omitempty"`
	// contains filtered or unexported fields
}

func (*ListStepTypesResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ListStepTypesResponse.ProtoReflect.Descriptor instead.

func (*ListStepTypesResponse) GetStepTypes added in v0.5.0

func (x *ListStepTypesResponse) GetStepTypes() []*StepTypeInfo

func (*ListStepTypesResponse) ProtoMessage added in v0.5.0

func (*ListStepTypesResponse) ProtoMessage()

func (*ListStepTypesResponse) ProtoReflect added in v0.5.0

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

func (*ListStepTypesResponse) Reset added in v0.5.0

func (x *ListStepTypesResponse) Reset()

func (*ListStepTypesResponse) String added in v0.5.0

func (x *ListStepTypesResponse) String() string

type OperationSchema

type OperationSchema struct {
	Name        string          `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string          `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	Inputs      []*InputSchema  `protobuf:"bytes,3,rep,name=inputs,proto3" json:"inputs,omitempty"`
	Outputs     []*OutputSchema `protobuf:"bytes,4,rep,name=outputs,proto3" json:"outputs,omitempty"`
	// contains filtered or unexported fields
}

func (*OperationSchema) Descriptor deprecated

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

Deprecated: Use OperationSchema.ProtoReflect.Descriptor instead.

func (*OperationSchema) GetDescription

func (x *OperationSchema) GetDescription() string

func (*OperationSchema) GetInputs

func (x *OperationSchema) GetInputs() []*InputSchema

func (*OperationSchema) GetName

func (x *OperationSchema) GetName() string

func (*OperationSchema) GetOutputs

func (x *OperationSchema) GetOutputs() []*OutputSchema

func (*OperationSchema) ProtoMessage

func (*OperationSchema) ProtoMessage()

func (*OperationSchema) ProtoReflect

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

func (*OperationSchema) Reset

func (x *OperationSchema) Reset()

func (*OperationSchema) String

func (x *OperationSchema) String() string

type OperationServiceClient

type OperationServiceClient interface {
	ListOperations(ctx context.Context, in *ListOperationsRequest, opts ...grpc.CallOption) (*ListOperationsResponse, error)
	GetOperation(ctx context.Context, in *GetOperationRequest, opts ...grpc.CallOption) (*GetOperationResponse, error)
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
}

OperationServiceClient is the client API for OperationService 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.

type OperationServiceServer

type OperationServiceServer interface {
	ListOperations(context.Context, *ListOperationsRequest) (*ListOperationsResponse, error)
	GetOperation(context.Context, *GetOperationRequest) (*GetOperationResponse, error)
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
	// contains filtered or unexported methods
}

OperationServiceServer is the server API for OperationService service. All implementations must embed UnimplementedOperationServiceServer for forward compatibility.

type OutputSchema

type OutputSchema struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type        string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*OutputSchema) Descriptor deprecated

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

Deprecated: Use OutputSchema.ProtoReflect.Descriptor instead.

func (*OutputSchema) GetDescription

func (x *OutputSchema) GetDescription() string

func (*OutputSchema) GetName

func (x *OutputSchema) GetName() string

func (*OutputSchema) GetType

func (x *OutputSchema) GetType() string

func (*OutputSchema) ProtoMessage

func (*OutputSchema) ProtoMessage()

func (*OutputSchema) ProtoReflect

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

func (*OutputSchema) Reset

func (x *OutputSchema) Reset()

func (*OutputSchema) String

func (x *OutputSchema) String() string

type PluginServiceClient

type PluginServiceClient interface {
	GetInfo(ctx context.Context, in *GetInfoRequest, opts ...grpc.CallOption) (*GetInfoResponse, error)
	Init(ctx context.Context, in *InitRequest, opts ...grpc.CallOption) (*InitResponse, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
}

PluginServiceClient is the client API for PluginService 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.

type PluginServiceServer

type PluginServiceServer interface {
	GetInfo(context.Context, *GetInfoRequest) (*GetInfoResponse, error)
	Init(context.Context, *InitRequest) (*InitResponse, error)
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
	// contains filtered or unexported methods
}

PluginServiceServer is the server API for PluginService service. All implementations must embed UnimplementedPluginServiceServer for forward compatibility.

type Severity added in v0.5.0

type Severity int32

Severity of a validation issue. SEVERITY_UNSPECIFIED (proto3 zero value) is treated as ERROR by the host.

const (
	Severity_SEVERITY_UNSPECIFIED Severity = 0
	Severity_SEVERITY_WARNING     Severity = 1
	Severity_SEVERITY_ERROR       Severity = 2
	Severity_SEVERITY_INFO        Severity = 3
)

func (Severity) Descriptor added in v0.5.0

func (Severity) Descriptor() protoreflect.EnumDescriptor

func (Severity) Enum added in v0.5.0

func (x Severity) Enum() *Severity

func (Severity) EnumDescriptor deprecated added in v0.5.0

func (Severity) EnumDescriptor() ([]byte, []int)

Deprecated: Use Severity.Descriptor instead.

func (Severity) Number added in v0.5.0

func (x Severity) Number() protoreflect.EnumNumber

func (Severity) String added in v0.5.0

func (x Severity) String() string

func (Severity) Type added in v0.5.0

type ShutdownRequest

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

func (*ShutdownRequest) Descriptor deprecated

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

Deprecated: Use ShutdownRequest.ProtoReflect.Descriptor instead.

func (*ShutdownRequest) ProtoMessage

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) ProtoReflect

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

func (*ShutdownRequest) Reset

func (x *ShutdownRequest) Reset()

func (*ShutdownRequest) String

func (x *ShutdownRequest) String() string

type ShutdownResponse

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

func (*ShutdownResponse) Descriptor deprecated

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

Deprecated: Use ShutdownResponse.ProtoReflect.Descriptor instead.

func (*ShutdownResponse) ProtoMessage

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) ProtoReflect

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

func (*ShutdownResponse) Reset

func (x *ShutdownResponse) Reset()

func (*ShutdownResponse) String

func (x *ShutdownResponse) String() string

type StepTypeInfo added in v0.5.0

type StepTypeInfo struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*StepTypeInfo) Descriptor deprecated added in v0.5.0

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

Deprecated: Use StepTypeInfo.ProtoReflect.Descriptor instead.

func (*StepTypeInfo) GetDescription added in v0.5.0

func (x *StepTypeInfo) GetDescription() string

func (*StepTypeInfo) GetName added in v0.5.0

func (x *StepTypeInfo) GetName() string

func (*StepTypeInfo) ProtoMessage added in v0.5.0

func (*StepTypeInfo) ProtoMessage()

func (*StepTypeInfo) ProtoReflect added in v0.5.0

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

func (*StepTypeInfo) Reset added in v0.5.0

func (x *StepTypeInfo) Reset()

func (*StepTypeInfo) String added in v0.5.0

func (x *StepTypeInfo) String() string

type StepTypeServiceClient added in v0.5.0

type StepTypeServiceClient interface {
	ListStepTypes(ctx context.Context, in *ListStepTypesRequest, opts ...grpc.CallOption) (*ListStepTypesResponse, error)
	ExecuteStep(ctx context.Context, in *ExecuteStepRequest, opts ...grpc.CallOption) (*ExecuteStepResponse, error)
}

StepTypeServiceClient is the client API for StepTypeService 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 NewStepTypeServiceClient added in v0.5.0

func NewStepTypeServiceClient(cc grpc.ClientConnInterface) StepTypeServiceClient

type StepTypeServiceServer added in v0.5.0

type StepTypeServiceServer interface {
	ListStepTypes(context.Context, *ListStepTypesRequest) (*ListStepTypesResponse, error)
	ExecuteStep(context.Context, *ExecuteStepRequest) (*ExecuteStepResponse, error)
	// contains filtered or unexported methods
}

StepTypeServiceServer is the server API for StepTypeService service. All implementations must embed UnimplementedStepTypeServiceServer for forward compatibility.

type UnimplementedOperationServiceServer

type UnimplementedOperationServiceServer struct{}

UnimplementedOperationServiceServer 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 (UnimplementedOperationServiceServer) Execute

func (UnimplementedOperationServiceServer) GetOperation

func (UnimplementedOperationServiceServer) ListOperations

type UnimplementedPluginServiceServer

type UnimplementedPluginServiceServer struct{}

UnimplementedPluginServiceServer 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 (UnimplementedPluginServiceServer) GetInfo

func (UnimplementedPluginServiceServer) Init

func (UnimplementedPluginServiceServer) Shutdown

type UnimplementedStepTypeServiceServer added in v0.5.0

type UnimplementedStepTypeServiceServer struct{}

UnimplementedStepTypeServiceServer 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 (UnimplementedStepTypeServiceServer) ExecuteStep added in v0.5.0

func (UnimplementedStepTypeServiceServer) ListStepTypes added in v0.5.0

type UnimplementedValidatorServiceServer added in v0.5.0

type UnimplementedValidatorServiceServer struct{}

UnimplementedValidatorServiceServer 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 (UnimplementedValidatorServiceServer) ValidateStep added in v0.5.0

func (UnimplementedValidatorServiceServer) ValidateWorkflow added in v0.5.0

type UnsafeOperationServiceServer

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

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

type UnsafePluginServiceServer

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

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

type UnsafeStepTypeServiceServer added in v0.5.0

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

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

type UnsafeValidatorServiceServer added in v0.5.0

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

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

type ValidateStepRequest added in v0.5.0

type ValidateStepRequest struct {
	WorkflowJson []byte `protobuf:"bytes,1,opt,name=workflow_json,json=workflowJson,proto3" json:"workflow_json,omitempty"`
	StepName     string `protobuf:"bytes,2,opt,name=step_name,json=stepName,proto3" json:"step_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateStepRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ValidateStepRequest.ProtoReflect.Descriptor instead.

func (*ValidateStepRequest) GetStepName added in v0.5.0

func (x *ValidateStepRequest) GetStepName() string

func (*ValidateStepRequest) GetWorkflowJson added in v0.5.0

func (x *ValidateStepRequest) GetWorkflowJson() []byte

func (*ValidateStepRequest) ProtoMessage added in v0.5.0

func (*ValidateStepRequest) ProtoMessage()

func (*ValidateStepRequest) ProtoReflect added in v0.5.0

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

func (*ValidateStepRequest) Reset added in v0.5.0

func (x *ValidateStepRequest) Reset()

func (*ValidateStepRequest) String added in v0.5.0

func (x *ValidateStepRequest) String() string

type ValidateStepResponse added in v0.5.0

type ValidateStepResponse struct {
	Issues []*ValidationIssue `protobuf:"bytes,1,rep,name=issues,proto3" json:"issues,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateStepResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ValidateStepResponse.ProtoReflect.Descriptor instead.

func (*ValidateStepResponse) GetIssues added in v0.5.0

func (x *ValidateStepResponse) GetIssues() []*ValidationIssue

func (*ValidateStepResponse) ProtoMessage added in v0.5.0

func (*ValidateStepResponse) ProtoMessage()

func (*ValidateStepResponse) ProtoReflect added in v0.5.0

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

func (*ValidateStepResponse) Reset added in v0.5.0

func (x *ValidateStepResponse) Reset()

func (*ValidateStepResponse) String added in v0.5.0

func (x *ValidateStepResponse) String() string

type ValidateWorkflowRequest added in v0.5.0

type ValidateWorkflowRequest struct {
	WorkflowJson []byte `protobuf:"bytes,1,opt,name=workflow_json,json=workflowJson,proto3" json:"workflow_json,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateWorkflowRequest) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ValidateWorkflowRequest.ProtoReflect.Descriptor instead.

func (*ValidateWorkflowRequest) GetWorkflowJson added in v0.5.0

func (x *ValidateWorkflowRequest) GetWorkflowJson() []byte

func (*ValidateWorkflowRequest) ProtoMessage added in v0.5.0

func (*ValidateWorkflowRequest) ProtoMessage()

func (*ValidateWorkflowRequest) ProtoReflect added in v0.5.0

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

func (*ValidateWorkflowRequest) Reset added in v0.5.0

func (x *ValidateWorkflowRequest) Reset()

func (*ValidateWorkflowRequest) String added in v0.5.0

func (x *ValidateWorkflowRequest) String() string

type ValidateWorkflowResponse added in v0.5.0

type ValidateWorkflowResponse struct {
	Issues []*ValidationIssue `protobuf:"bytes,1,rep,name=issues,proto3" json:"issues,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidateWorkflowResponse) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ValidateWorkflowResponse.ProtoReflect.Descriptor instead.

func (*ValidateWorkflowResponse) GetIssues added in v0.5.0

func (x *ValidateWorkflowResponse) GetIssues() []*ValidationIssue

func (*ValidateWorkflowResponse) ProtoMessage added in v0.5.0

func (*ValidateWorkflowResponse) ProtoMessage()

func (*ValidateWorkflowResponse) ProtoReflect added in v0.5.0

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

func (*ValidateWorkflowResponse) Reset added in v0.5.0

func (x *ValidateWorkflowResponse) Reset()

func (*ValidateWorkflowResponse) String added in v0.5.0

func (x *ValidateWorkflowResponse) String() string

type ValidationIssue added in v0.5.0

type ValidationIssue struct {
	Severity Severity `protobuf:"varint,1,opt,name=severity,proto3,enum=plugin.v1.Severity" json:"severity,omitempty"`
	Message  string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Step     string   `protobuf:"bytes,3,opt,name=step,proto3" json:"step,omitempty"`
	Field    string   `protobuf:"bytes,4,opt,name=field,proto3" json:"field,omitempty"`
	// contains filtered or unexported fields
}

func (*ValidationIssue) Descriptor deprecated added in v0.5.0

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

Deprecated: Use ValidationIssue.ProtoReflect.Descriptor instead.

func (*ValidationIssue) GetField added in v0.5.0

func (x *ValidationIssue) GetField() string

func (*ValidationIssue) GetMessage added in v0.5.0

func (x *ValidationIssue) GetMessage() string

func (*ValidationIssue) GetSeverity added in v0.5.0

func (x *ValidationIssue) GetSeverity() Severity

func (*ValidationIssue) GetStep added in v0.5.0

func (x *ValidationIssue) GetStep() string

func (*ValidationIssue) ProtoMessage added in v0.5.0

func (*ValidationIssue) ProtoMessage()

func (*ValidationIssue) ProtoReflect added in v0.5.0

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

func (*ValidationIssue) Reset added in v0.5.0

func (x *ValidationIssue) Reset()

func (*ValidationIssue) String added in v0.5.0

func (x *ValidationIssue) String() string

type ValidatorServiceClient added in v0.5.0

type ValidatorServiceClient interface {
	ValidateWorkflow(ctx context.Context, in *ValidateWorkflowRequest, opts ...grpc.CallOption) (*ValidateWorkflowResponse, error)
	ValidateStep(ctx context.Context, in *ValidateStepRequest, opts ...grpc.CallOption) (*ValidateStepResponse, error)
}

ValidatorServiceClient is the client API for ValidatorService 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 NewValidatorServiceClient added in v0.5.0

func NewValidatorServiceClient(cc grpc.ClientConnInterface) ValidatorServiceClient

type ValidatorServiceServer added in v0.5.0

type ValidatorServiceServer interface {
	ValidateWorkflow(context.Context, *ValidateWorkflowRequest) (*ValidateWorkflowResponse, error)
	ValidateStep(context.Context, *ValidateStepRequest) (*ValidateStepResponse, error)
	// contains filtered or unexported methods
}

ValidatorServiceServer is the server API for ValidatorService service. All implementations must embed UnimplementedValidatorServiceServer for forward compatibility.

Jump to

Keyboard shortcuts

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