workflows

package
v1.7.25 Latest Latest
Warning

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

 Go to latest Published: Jul 26, 2023 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WorkflowsDefinitionService_ListFlowDefinitions_FullMethodName  = "/api.v1alpha1.workflows.WorkflowsDefinitionService/ListFlowDefinitions"
	WorkflowsDefinitionService_SaveFlowDefinition_FullMethodName   = "/api.v1alpha1.workflows.WorkflowsDefinitionService/SaveFlowDefinition"
	WorkflowsDefinitionService_GetFlowDefinition_FullMethodName    = "/api.v1alpha1.workflows.WorkflowsDefinitionService/GetFlowDefinition"
	WorkflowsDefinitionService_DeleteFlowDefinition_FullMethodName = "/api.v1alpha1.workflows.WorkflowsDefinitionService/DeleteFlowDefinition"
)

Variables

View Source 
var File_api_v1alpha1_workflows_entities_proto protoreflect.FileDescriptor
View Source 
var File_api_v1alpha1_workflows_service_proto protoreflect.FileDescriptor
View Source 
var WorkflowsDefinitionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.v1alpha1.workflows.WorkflowsDefinitionService",
	HandlerType: (*WorkflowsDefinitionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListFlowDefinitions",
			Handler:    _WorkflowsDefinitionService_ListFlowDefinitions_Handler,
		},
		{
			MethodName: "SaveFlowDefinition",
			Handler:    _WorkflowsDefinitionService_SaveFlowDefinition_Handler,
		},
		{
			MethodName: "GetFlowDefinition",
			Handler:    _WorkflowsDefinitionService_GetFlowDefinition_Handler,
		},
		{
			MethodName: "DeleteFlowDefinition",
			Handler:    _WorkflowsDefinitionService_DeleteFlowDefinition_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/v1alpha1/workflows/service.proto",
}

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

Functions

func RegisterWorkflowsDefinitionServiceServer 

func RegisterWorkflowsDefinitionServiceServer(s grpc.ServiceRegistrar, srv WorkflowsDefinitionServiceServer)

Types

type DeleteFlowDefinitionRequest 

type DeleteFlowDefinitionRequest struct {

	// The ID of the flow definition to delete
	FlowDefinitionId string `protobuf:"bytes,1,opt,name=flow_definition_id,json=flowDefinitionId,proto3" json:"flow_definition_id,omitempty"`
	// contains filtered or unexported fields
}

DeleteFlowDefinitionsRequest is the request object for deleting a flow definition

func (*DeleteFlowDefinitionRequest) Descriptor deprecated 

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

Deprecated: Use DeleteFlowDefinitionRequest.ProtoReflect.Descriptor instead.

func (*DeleteFlowDefinitionRequest) GetFlowDefinitionId 

func (x *DeleteFlowDefinitionRequest) GetFlowDefinitionId() string

func (*DeleteFlowDefinitionRequest) ProtoMessage 

func (*DeleteFlowDefinitionRequest) ProtoMessage()

func (*DeleteFlowDefinitionRequest) ProtoReflect 

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

func (*DeleteFlowDefinitionRequest) Reset 

func (x *DeleteFlowDefinitionRequest) Reset()

func (*DeleteFlowDefinitionRequest) String 

func (x *DeleteFlowDefinitionRequest) String() string

type DeleteFlowDefinitionResponse 

type DeleteFlowDefinitionResponse struct {

	// true if the flow definition was deleted
	Result bool `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

DeleteFlowDefinitionsResponse is the response object for deleting a flow definition

func (*DeleteFlowDefinitionResponse) Descriptor deprecated 

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

Deprecated: Use DeleteFlowDefinitionResponse.ProtoReflect.Descriptor instead.

func (*DeleteFlowDefinitionResponse) GetResult 

func (x *DeleteFlowDefinitionResponse) GetResult() bool

func (*DeleteFlowDefinitionResponse) ProtoMessage 

func (*DeleteFlowDefinitionResponse) ProtoMessage()

func (*DeleteFlowDefinitionResponse) ProtoReflect 

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

func (*DeleteFlowDefinitionResponse) Reset 

func (x *DeleteFlowDefinitionResponse) Reset()

func (*DeleteFlowDefinitionResponse) String 

func (x *DeleteFlowDefinitionResponse) String() string

type GetFlowDefinitionRequest 

type GetFlowDefinitionRequest struct {

	// The ID of the flow definition to get
	FlowDefinitionId string `protobuf:"bytes,1,opt,name=flow_definition_id,json=flowDefinitionId,proto3" json:"flow_definition_id,omitempty"`
	// contains filtered or unexported fields
}

GetFlowDefinitionsRequest is the request object for getting a flow definition

func (*GetFlowDefinitionRequest) Descriptor deprecated 

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

Deprecated: Use GetFlowDefinitionRequest.ProtoReflect.Descriptor instead.

func (*GetFlowDefinitionRequest) GetFlowDefinitionId 

func (x *GetFlowDefinitionRequest) GetFlowDefinitionId() string

func (*GetFlowDefinitionRequest) ProtoMessage 

func (*GetFlowDefinitionRequest) ProtoMessage()

func (*GetFlowDefinitionRequest) ProtoReflect 

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

func (*GetFlowDefinitionRequest) Reset 

func (x *GetFlowDefinitionRequest) Reset()

func (*GetFlowDefinitionRequest) String 

func (x *GetFlowDefinitionRequest) String() string

type GetFlowDefinitionResponse 

type GetFlowDefinitionResponse struct {

	// The flow definition that was retrieved
	FlowDefinition *workflows.FlowDefinition `protobuf:"bytes,1,opt,name=flow_definition,json=flowDefinition,proto3" json:"flow_definition,omitempty"`
	// contains filtered or unexported fields
}

GetFlowDefinitionsResponse is the response object for getting a flow definition

func (*GetFlowDefinitionResponse) Descriptor deprecated 

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

Deprecated: Use GetFlowDefinitionResponse.ProtoReflect.Descriptor instead.

func (*GetFlowDefinitionResponse) GetFlowDefinition 

func (x *GetFlowDefinitionResponse) GetFlowDefinition() *workflows.FlowDefinition

func (*GetFlowDefinitionResponse) ProtoMessage 

func (*GetFlowDefinitionResponse) ProtoMessage()

func (*GetFlowDefinitionResponse) ProtoReflect 

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

func (*GetFlowDefinitionResponse) Reset 

func (x *GetFlowDefinitionResponse) Reset()

func (*GetFlowDefinitionResponse) String 

func (x *GetFlowDefinitionResponse) String() string

type ListFlowDefinitionsRequest 

type ListFlowDefinitionsRequest struct {

	// The filter to apply to the list of flow definitions
	Filter string `protobuf:"bytes,1,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

ListFlowDefinitionsRequest is the request object for listing flow definitions

func (*ListFlowDefinitionsRequest) Descriptor deprecated 

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

Deprecated: Use ListFlowDefinitionsRequest.ProtoReflect.Descriptor instead.

func (*ListFlowDefinitionsRequest) GetFilter 

func (x *ListFlowDefinitionsRequest) GetFilter() string

func (*ListFlowDefinitionsRequest) ProtoMessage 

func (*ListFlowDefinitionsRequest) ProtoMessage()

func (*ListFlowDefinitionsRequest) ProtoReflect 

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

func (*ListFlowDefinitionsRequest) Reset 

func (x *ListFlowDefinitionsRequest) Reset()

func (*ListFlowDefinitionsRequest) String 

func (x *ListFlowDefinitionsRequest) String() string

type ListFlowDefinitionsResponse 

type ListFlowDefinitionsResponse struct {

	// The list of flow definitions
	FlowDefinitions []*workflows.FlowDefinition `protobuf:"bytes,1,rep,name=flow_definitions,json=flowDefinitions,proto3" json:"flow_definitions,omitempty"`
	// contains filtered or unexported fields
}

ListFlowDefinitionsResponse is the response object for listing flow definitions

func (*ListFlowDefinitionsResponse) Descriptor deprecated 

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

Deprecated: Use ListFlowDefinitionsResponse.ProtoReflect.Descriptor instead.

func (*ListFlowDefinitionsResponse) GetFlowDefinitions 

func (x *ListFlowDefinitionsResponse) GetFlowDefinitions() []*workflows.FlowDefinition

func (*ListFlowDefinitionsResponse) ProtoMessage 

func (*ListFlowDefinitionsResponse) ProtoMessage()

func (*ListFlowDefinitionsResponse) ProtoReflect 

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

func (*ListFlowDefinitionsResponse) Reset 

func (x *ListFlowDefinitionsResponse) Reset()

func (*ListFlowDefinitionsResponse) String 

func (x *ListFlowDefinitionsResponse) String() string

type SaveFlowDefinitionRequest 

type SaveFlowDefinitionRequest struct {

	// The flow definition to save
	FlowDefinition *workflows.FlowDefinition `protobuf:"bytes,1,opt,name=flow_definition,json=flowDefinition,proto3" json:"flow_definition,omitempty"`
	// The fields to update
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

SaveFlowDefinitionRequest is the request object for creating/updating a flow definition

func (*SaveFlowDefinitionRequest) Descriptor deprecated 

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

Deprecated: Use SaveFlowDefinitionRequest.ProtoReflect.Descriptor instead.

func (*SaveFlowDefinitionRequest) GetFlowDefinition 

func (x *SaveFlowDefinitionRequest) GetFlowDefinition() *workflows.FlowDefinition

func (*SaveFlowDefinitionRequest) GetUpdateMask 

func (x *SaveFlowDefinitionRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*SaveFlowDefinitionRequest) ProtoMessage 

func (*SaveFlowDefinitionRequest) ProtoMessage()

func (*SaveFlowDefinitionRequest) ProtoReflect 

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

func (*SaveFlowDefinitionRequest) Reset 

func (x *SaveFlowDefinitionRequest) Reset()

func (*SaveFlowDefinitionRequest) String 

func (x *SaveFlowDefinitionRequest) String() string

type SaveFlowDefinitionResponse 

type SaveFlowDefinitionResponse struct {

	// The ID of the flow definition that was saved
	FlowDefinitionId string `protobuf:"bytes,1,opt,name=flow_definition_id,json=flowDefinitionId,proto3" json:"flow_definition_id,omitempty"`
	// The flow definition that was saved
	FlowDefinition *workflows.FlowDefinition `protobuf:"bytes,2,opt,name=flow_definition,json=flowDefinition,proto3" json:"flow_definition,omitempty"`
	// contains filtered or unexported fields
}

SaveFlowDefinitionResponse is the response object for creating/updating a flow definition

func (*SaveFlowDefinitionResponse) Descriptor deprecated 

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

Deprecated: Use SaveFlowDefinitionResponse.ProtoReflect.Descriptor instead.

func (*SaveFlowDefinitionResponse) GetFlowDefinition 

func (x *SaveFlowDefinitionResponse) GetFlowDefinition() *workflows.FlowDefinition

func (*SaveFlowDefinitionResponse) GetFlowDefinitionId 

func (x *SaveFlowDefinitionResponse) GetFlowDefinitionId() string

func (*SaveFlowDefinitionResponse) ProtoMessage 

func (*SaveFlowDefinitionResponse) ProtoMessage()

func (*SaveFlowDefinitionResponse) ProtoReflect 

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

func (*SaveFlowDefinitionResponse) Reset 

func (x *SaveFlowDefinitionResponse) Reset()

func (*SaveFlowDefinitionResponse) String 

func (x *SaveFlowDefinitionResponse) String() string

type UnimplementedWorkflowsDefinitionServiceServer 

type UnimplementedWorkflowsDefinitionServiceServer struct {
}

UnimplementedWorkflowsDefinitionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkflowsDefinitionServiceServer) DeleteFlowDefinition 

func (UnimplementedWorkflowsDefinitionServiceServer) DeleteFlowDefinition(context.Context, *DeleteFlowDefinitionRequest) (*DeleteFlowDefinitionResponse, error)

func (UnimplementedWorkflowsDefinitionServiceServer) GetFlowDefinition 

func (UnimplementedWorkflowsDefinitionServiceServer) GetFlowDefinition(context.Context, *GetFlowDefinitionRequest) (*GetFlowDefinitionResponse, error)

func (UnimplementedWorkflowsDefinitionServiceServer) ListFlowDefinitions 

func (UnimplementedWorkflowsDefinitionServiceServer) ListFlowDefinitions(context.Context, *ListFlowDefinitionsRequest) (*ListFlowDefinitionsResponse, error)

func (UnimplementedWorkflowsDefinitionServiceServer) SaveFlowDefinition 

func (UnimplementedWorkflowsDefinitionServiceServer) SaveFlowDefinition(context.Context, *SaveFlowDefinitionRequest) (*SaveFlowDefinitionResponse, error)

type UnsafeWorkflowsDefinitionServiceServer 

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

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

type WorkflowsDefinitionServiceClient 

type WorkflowsDefinitionServiceClient interface {
	// ListFlowDefinitions lists flow definitions
	ListFlowDefinitions(ctx context.Context, in *ListFlowDefinitionsRequest, opts ...grpc.CallOption) (*ListFlowDefinitionsResponse, error)
	// SaveFlowDefinition creates or updates a flow definition
	SaveFlowDefinition(ctx context.Context, in *SaveFlowDefinitionRequest, opts ...grpc.CallOption) (*SaveFlowDefinitionResponse, error)
	// GetFlowDefinition gets a flow definition
	GetFlowDefinition(ctx context.Context, in *GetFlowDefinitionRequest, opts ...grpc.CallOption) (*GetFlowDefinitionResponse, error)
	// DeleteFlowDefinition deletes a flow definition
	DeleteFlowDefinition(ctx context.Context, in *DeleteFlowDefinitionRequest, opts ...grpc.CallOption) (*DeleteFlowDefinitionResponse, error)
}

WorkflowsDefinitionServiceClient is the client API for WorkflowsDefinitionService 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 NewWorkflowsDefinitionServiceClient 

func NewWorkflowsDefinitionServiceClient(cc grpc.ClientConnInterface) WorkflowsDefinitionServiceClient

type WorkflowsDefinitionServiceServer 

type WorkflowsDefinitionServiceServer interface {
	// ListFlowDefinitions lists flow definitions
	ListFlowDefinitions(context.Context, *ListFlowDefinitionsRequest) (*ListFlowDefinitionsResponse, error)
	// SaveFlowDefinition creates or updates a flow definition
	SaveFlowDefinition(context.Context, *SaveFlowDefinitionRequest) (*SaveFlowDefinitionResponse, error)
	// GetFlowDefinition gets a flow definition
	GetFlowDefinition(context.Context, *GetFlowDefinitionRequest) (*GetFlowDefinitionResponse, error)
	// DeleteFlowDefinition deletes a flow definition
	DeleteFlowDefinition(context.Context, *DeleteFlowDefinitionRequest) (*DeleteFlowDefinitionResponse, error)
	// contains filtered or unexported methods
}

WorkflowsDefinitionServiceServer is the server API for WorkflowsDefinitionService service. All implementations must embed UnimplementedWorkflowsDefinitionServiceServer for forward compatibility

Source Files

View all Source files

Directories

Path Synopsis

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.