rpc

package
v19.1.2 Latest Latest
Warning

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

Go to latest
Published: Jul 7, 2026 License: MIT Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source
const (
	AutoFlow_StartWorkflow_FullMethodName  = "/gitlab.agent.autoflow.rpc.AutoFlow/StartWorkflow"
	AutoFlow_GetWorkflow_FullMethodName    = "/gitlab.agent.autoflow.rpc.AutoFlow/GetWorkflow"
	AutoFlow_CancelWorkflow_FullMethodName = "/gitlab.agent.autoflow.rpc.AutoFlow/CancelWorkflow"
)

Variables

View Source
var (
	WorkflowState_name = map[int32]string{
		0: "WORKFLOW_STATE_UNSPECIFIED",
		1: "WORKFLOW_STATE_RUNNING",
		2: "WORKFLOW_STATE_COMPLETED",
		3: "WORKFLOW_STATE_FAILED",
		4: "WORKFLOW_STATE_CANCELED",
		5: "WORKFLOW_STATE_TIMED_OUT",
	}
	WorkflowState_value = map[string]int32{
		"WORKFLOW_STATE_UNSPECIFIED": 0,
		"WORKFLOW_STATE_RUNNING":     1,
		"WORKFLOW_STATE_COMPLETED":   2,
		"WORKFLOW_STATE_FAILED":      3,
		"WORKFLOW_STATE_CANCELED":    4,
		"WORKFLOW_STATE_TIMED_OUT":   5,
	}
)

Enum value maps for WorkflowState.

View Source
var AutoFlow_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gitlab.agent.autoflow.rpc.AutoFlow",
	HandlerType: (*AutoFlowServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartWorkflow",
			Handler:    _AutoFlow_StartWorkflow_Handler,
		},
		{
			MethodName: "GetWorkflow",
			Handler:    _AutoFlow_GetWorkflow_Handler,
		},
		{
			MethodName: "CancelWorkflow",
			Handler:    _AutoFlow_CancelWorkflow_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/module/autoflow/rpc/rpc.proto",
}

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

View Source
var File_internal_module_autoflow_rpc_rpc_proto protoreflect.FileDescriptor

Functions

func RegisterAutoFlowServer

func RegisterAutoFlowServer(s grpc.ServiceRegistrar, srv AutoFlowServer)

Types

type AutoFlowClient

type AutoFlowClient interface {
	StartWorkflow(ctx context.Context, in *StartWorkflowRequest, opts ...grpc.CallOption) (*StartWorkflowResponse, error)
	GetWorkflow(ctx context.Context, in *GetWorkflowRequest, opts ...grpc.CallOption) (*GetWorkflowResponse, error)
	CancelWorkflow(ctx context.Context, in *CancelWorkflowRequest, opts ...grpc.CallOption) (*CancelWorkflowResponse, error)
}

AutoFlowClient is the client API for AutoFlow 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 NewAutoFlowClient

func NewAutoFlowClient(cc grpc.ClientConnInterface) AutoFlowClient

type AutoFlowServer

type AutoFlowServer interface {
	StartWorkflow(context.Context, *StartWorkflowRequest) (*StartWorkflowResponse, error)
	GetWorkflow(context.Context, *GetWorkflowRequest) (*GetWorkflowResponse, error)
	CancelWorkflow(context.Context, *CancelWorkflowRequest) (*CancelWorkflowResponse, error)
	// contains filtered or unexported methods
}

AutoFlowServer is the server API for AutoFlow service. All implementations must embed UnimplementedAutoFlowServer for forward compatibility.

type CancelWorkflowRequest added in v19.1.0

type CancelWorkflowRequest struct {
	WorkflowKey string `protobuf:"bytes,1,opt,name=workflow_key" json:"workflow_key,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelWorkflowRequest) Descriptor deprecated added in v19.1.0

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

Deprecated: Use CancelWorkflowRequest.ProtoReflect.Descriptor instead.

func (*CancelWorkflowRequest) GetWorkflowKey added in v19.1.0

func (x *CancelWorkflowRequest) GetWorkflowKey() string

func (*CancelWorkflowRequest) ProtoMessage added in v19.1.0

func (*CancelWorkflowRequest) ProtoMessage()

func (*CancelWorkflowRequest) ProtoReflect added in v19.1.0

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

func (*CancelWorkflowRequest) Reset added in v19.1.0

func (x *CancelWorkflowRequest) Reset()

func (*CancelWorkflowRequest) String added in v19.1.0

func (x *CancelWorkflowRequest) String() string

type CancelWorkflowResponse added in v19.1.0

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

func (*CancelWorkflowResponse) Descriptor deprecated added in v19.1.0

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

Deprecated: Use CancelWorkflowResponse.ProtoReflect.Descriptor instead.

func (*CancelWorkflowResponse) ProtoMessage added in v19.1.0

func (*CancelWorkflowResponse) ProtoMessage()

func (*CancelWorkflowResponse) ProtoReflect added in v19.1.0

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

func (*CancelWorkflowResponse) Reset added in v19.1.0

func (x *CancelWorkflowResponse) Reset()

func (*CancelWorkflowResponse) String added in v19.1.0

func (x *CancelWorkflowResponse) String() string

type GetWorkflowRequest added in v19.1.0

type GetWorkflowRequest struct {
	WorkflowKey string `protobuf:"bytes,1,opt,name=workflow_key" json:"workflow_key,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowRequest) Descriptor deprecated added in v19.1.0

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

Deprecated: Use GetWorkflowRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowRequest) GetWorkflowKey added in v19.1.0

func (x *GetWorkflowRequest) GetWorkflowKey() string

func (*GetWorkflowRequest) ProtoMessage added in v19.1.0

func (*GetWorkflowRequest) ProtoMessage()

func (*GetWorkflowRequest) ProtoReflect added in v19.1.0

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

func (*GetWorkflowRequest) Reset added in v19.1.0

func (x *GetWorkflowRequest) Reset()

func (*GetWorkflowRequest) String added in v19.1.0

func (x *GetWorkflowRequest) String() string

type GetWorkflowResponse added in v19.1.0

type GetWorkflowResponse struct {
	WorkflowKey string                 `protobuf:"bytes,1,opt,name=workflow_key" json:"workflow_key,omitempty"`
	Name        string                 `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	IdentityKey string                 `protobuf:"bytes,3,opt,name=identity_key" json:"identity_key,omitempty"`
	State       WorkflowState          `protobuf:"varint,4,opt,name=state,enum=gitlab.agent.autoflow.rpc.WorkflowState" json:"state,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=created_at" json:"created_at,omitempty"`
	UpdatedAt   *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=updated_at" json:"updated_at,omitempty"`
	// Types that are valid to be assigned to Result:
	//
	//	*GetWorkflowResponse_Completed_
	//	*GetWorkflowResponse_Error_
	Result isGetWorkflowResponse_Result `protobuf_oneof:"result"`
	// contains filtered or unexported fields
}

func (*GetWorkflowResponse) Descriptor deprecated added in v19.1.0

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

Deprecated: Use GetWorkflowResponse.ProtoReflect.Descriptor instead.

func (*GetWorkflowResponse) GetCompleted added in v19.1.0

func (*GetWorkflowResponse) GetCreatedAt added in v19.1.0

func (x *GetWorkflowResponse) GetCreatedAt() *timestamppb.Timestamp

func (*GetWorkflowResponse) GetError added in v19.1.0

func (*GetWorkflowResponse) GetIdentityKey added in v19.1.0

func (x *GetWorkflowResponse) GetIdentityKey() string

func (*GetWorkflowResponse) GetName added in v19.1.0

func (x *GetWorkflowResponse) GetName() string

func (*GetWorkflowResponse) GetResult added in v19.1.0

func (x *GetWorkflowResponse) GetResult() isGetWorkflowResponse_Result

func (*GetWorkflowResponse) GetState added in v19.1.0

func (x *GetWorkflowResponse) GetState() WorkflowState

func (*GetWorkflowResponse) GetUpdatedAt added in v19.1.0

func (x *GetWorkflowResponse) GetUpdatedAt() *timestamppb.Timestamp

func (*GetWorkflowResponse) GetWorkflowKey added in v19.1.0

func (x *GetWorkflowResponse) GetWorkflowKey() string

func (*GetWorkflowResponse) ProtoMessage added in v19.1.0

func (*GetWorkflowResponse) ProtoMessage()

func (*GetWorkflowResponse) ProtoReflect added in v19.1.0

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

func (*GetWorkflowResponse) Reset added in v19.1.0

func (x *GetWorkflowResponse) Reset()

func (*GetWorkflowResponse) String added in v19.1.0

func (x *GetWorkflowResponse) String() string

type GetWorkflowResponse_Completed added in v19.1.0

type GetWorkflowResponse_Completed struct {
	Output *GetWorkflowResponse_Output `protobuf:"bytes,1,opt,name=output" json:"output,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowResponse_Completed) Descriptor deprecated added in v19.1.0

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

Deprecated: Use GetWorkflowResponse_Completed.ProtoReflect.Descriptor instead.

func (*GetWorkflowResponse_Completed) GetOutput added in v19.1.0

func (*GetWorkflowResponse_Completed) ProtoMessage added in v19.1.0

func (*GetWorkflowResponse_Completed) ProtoMessage()

func (*GetWorkflowResponse_Completed) ProtoReflect added in v19.1.0

func (*GetWorkflowResponse_Completed) Reset added in v19.1.0

func (x *GetWorkflowResponse_Completed) Reset()

func (*GetWorkflowResponse_Completed) String added in v19.1.0

type GetWorkflowResponse_Completed_ added in v19.1.0

type GetWorkflowResponse_Completed_ struct {
	Completed *GetWorkflowResponse_Completed `protobuf:"bytes,7,opt,name=completed,oneof"`
}

type GetWorkflowResponse_Error added in v19.1.0

type GetWorkflowResponse_Error struct {
	Message string `protobuf:"bytes,1,opt,name=message" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkflowResponse_Error) Descriptor deprecated added in v19.1.0

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

Deprecated: Use GetWorkflowResponse_Error.ProtoReflect.Descriptor instead.

func (*GetWorkflowResponse_Error) GetMessage added in v19.1.0

func (x *GetWorkflowResponse_Error) GetMessage() string

func (*GetWorkflowResponse_Error) ProtoMessage added in v19.1.0

func (*GetWorkflowResponse_Error) ProtoMessage()

func (*GetWorkflowResponse_Error) ProtoReflect added in v19.1.0

func (*GetWorkflowResponse_Error) Reset added in v19.1.0

func (x *GetWorkflowResponse_Error) Reset()

func (*GetWorkflowResponse_Error) String added in v19.1.0

func (x *GetWorkflowResponse_Error) String() string

type GetWorkflowResponse_Error_ added in v19.1.0

type GetWorkflowResponse_Error_ struct {
	Error *GetWorkflowResponse_Error `protobuf:"bytes,8,opt,name=error,oneof"`
}

type GetWorkflowResponse_Output added in v19.1.0

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

func (*GetWorkflowResponse_Output) Descriptor deprecated added in v19.1.0

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

Deprecated: Use GetWorkflowResponse_Output.ProtoReflect.Descriptor instead.

func (*GetWorkflowResponse_Output) ProtoMessage added in v19.1.0

func (*GetWorkflowResponse_Output) ProtoMessage()

func (*GetWorkflowResponse_Output) ProtoReflect added in v19.1.0

func (*GetWorkflowResponse_Output) Reset added in v19.1.0

func (x *GetWorkflowResponse_Output) Reset()

func (*GetWorkflowResponse_Output) String added in v19.1.0

func (x *GetWorkflowResponse_Output) String() string

type Secret added in v19.1.0

type Secret struct {
	Key   string `protobuf:"bytes,1,opt,name=key" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Secret) Descriptor deprecated added in v19.1.0

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

Deprecated: Use Secret.ProtoReflect.Descriptor instead.

func (*Secret) GetKey added in v19.1.0

func (x *Secret) GetKey() string

func (*Secret) GetValue added in v19.1.0

func (x *Secret) GetValue() string

func (*Secret) ProtoMessage added in v19.1.0

func (*Secret) ProtoMessage()

func (*Secret) ProtoReflect added in v19.1.0

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

func (*Secret) Reset added in v19.1.0

func (x *Secret) Reset()

func (*Secret) String added in v19.1.0

func (x *Secret) String() string

type StartWorkflowRequest

type StartWorkflowRequest struct {
	IdentityKey        string    `protobuf:"bytes,1,opt,name=identity_key" json:"identity_key,omitempty"`
	WorkflowDefinition []byte    `protobuf:"bytes,2,opt,name=workflow_definition" json:"workflow_definition,omitempty"`
	Secrets            []*Secret `protobuf:"bytes,3,rep,name=secrets" json:"secrets,omitempty"`
	NamespaceId        *int64    `protobuf:"varint,4,opt,name=namespace_id" json:"namespace_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StartWorkflowRequest) Descriptor deprecated

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

Deprecated: Use StartWorkflowRequest.ProtoReflect.Descriptor instead.

func (*StartWorkflowRequest) GetIdentityKey

func (x *StartWorkflowRequest) GetIdentityKey() string

func (*StartWorkflowRequest) GetNamespaceId added in v19.1.0

func (x *StartWorkflowRequest) GetNamespaceId() int64

func (*StartWorkflowRequest) GetSecrets

func (x *StartWorkflowRequest) GetSecrets() []*Secret

func (*StartWorkflowRequest) GetWorkflowDefinition

func (x *StartWorkflowRequest) GetWorkflowDefinition() []byte

func (*StartWorkflowRequest) ProtoMessage

func (*StartWorkflowRequest) ProtoMessage()

func (*StartWorkflowRequest) ProtoReflect

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

func (*StartWorkflowRequest) Reset

func (x *StartWorkflowRequest) Reset()

func (*StartWorkflowRequest) String

func (x *StartWorkflowRequest) String() string

type StartWorkflowResponse

type StartWorkflowResponse struct {
	WorkflowKey string `protobuf:"bytes,1,opt,name=workflow_key" json:"workflow_key,omitempty"`
	// contains filtered or unexported fields
}

func (*StartWorkflowResponse) Descriptor deprecated

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

Deprecated: Use StartWorkflowResponse.ProtoReflect.Descriptor instead.

func (*StartWorkflowResponse) GetWorkflowKey added in v19.1.0

func (x *StartWorkflowResponse) GetWorkflowKey() string

func (*StartWorkflowResponse) ProtoMessage

func (*StartWorkflowResponse) ProtoMessage()

func (*StartWorkflowResponse) ProtoReflect

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

func (*StartWorkflowResponse) Reset

func (x *StartWorkflowResponse) Reset()

func (*StartWorkflowResponse) String

func (x *StartWorkflowResponse) String() string

type UnimplementedAutoFlowServer

type UnimplementedAutoFlowServer struct{}

UnimplementedAutoFlowServer 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 (UnimplementedAutoFlowServer) CancelWorkflow added in v19.1.0

func (UnimplementedAutoFlowServer) GetWorkflow added in v19.1.0

func (UnimplementedAutoFlowServer) StartWorkflow

type UnsafeAutoFlowServer

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

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

type WorkflowState added in v19.1.0

type WorkflowState int32
const (
	WorkflowState_WORKFLOW_STATE_UNSPECIFIED WorkflowState = 0
	WorkflowState_WORKFLOW_STATE_RUNNING     WorkflowState = 1
	WorkflowState_WORKFLOW_STATE_COMPLETED   WorkflowState = 2
	WorkflowState_WORKFLOW_STATE_FAILED      WorkflowState = 3
	WorkflowState_WORKFLOW_STATE_CANCELED    WorkflowState = 4
	WorkflowState_WORKFLOW_STATE_TIMED_OUT   WorkflowState = 5
)

func (WorkflowState) Descriptor added in v19.1.0

func (WorkflowState) Enum added in v19.1.0

func (x WorkflowState) Enum() *WorkflowState

func (WorkflowState) EnumDescriptor deprecated added in v19.1.0

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

Deprecated: Use WorkflowState.Descriptor instead.

func (WorkflowState) Number added in v19.1.0

func (WorkflowState) String added in v19.1.0

func (x WorkflowState) String() string

func (WorkflowState) Type added in v19.1.0

Jump to

Keyboard shortcuts

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