rpc

package
v19.2.0 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2026 License: MIT Imports: 14 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",
		6: "WORKFLOW_STATE_SYSTEM_FAILED",
	}
	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,
		"WORKFLOW_STATE_SYSTEM_FAILED": 6,
	}
)

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"`
	Result      *v19.Result            `protobuf:"bytes,7,opt,name=result" json:"result,omitempty"`
	// 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) GetCreatedAt added in v19.1.0 

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

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() *v19.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 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"`
	Args                      []*v19.Value         `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"`
	Kwargs                    []*v19.NamedValue    `protobuf:"bytes,4,rep,name=kwargs" json:"kwargs,omitempty"`
	NamespaceId               *int64               `protobuf:"varint,5,opt,name=namespace_id" json:"namespace_id,omitempty"`
	ScheduleToCompleteTimeout *durationpb.Duration `` /* 133-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StartWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use StartWorkflowRequest.ProtoReflect.Descriptor instead.

func (*StartWorkflowRequest) GetArgs added in v19.2.0 

func (x *StartWorkflowRequest) GetArgs() []*v19.Value

func (*StartWorkflowRequest) GetIdentityKey 

func (x *StartWorkflowRequest) GetIdentityKey() string

func (*StartWorkflowRequest) GetKwargs added in v19.2.0 

func (x *StartWorkflowRequest) GetKwargs() []*v19.NamedValue

func (*StartWorkflowRequest) GetNamespaceId added in v19.1.0 

func (x *StartWorkflowRequest) GetNamespaceId() int64

func (*StartWorkflowRequest) GetScheduleToCompleteTimeout added in v19.2.0 

func (x *StartWorkflowRequest) GetScheduleToCompleteTimeout() *durationpb.Duration

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) CancelWorkflow(context.Context, *CancelWorkflowRequest) (*CancelWorkflowResponse, error)

func (UnimplementedAutoFlowServer) GetWorkflow added in v19.1.0 

func (UnimplementedAutoFlowServer) GetWorkflow(context.Context, *GetWorkflowRequest) (*GetWorkflowResponse, error)

func (UnimplementedAutoFlowServer) StartWorkflow 

func (UnimplementedAutoFlowServer) StartWorkflow(context.Context, *StartWorkflowRequest) (*StartWorkflowResponse, error)

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
	WorkflowState_WORKFLOW_STATE_SYSTEM_FAILED WorkflowState = 6
)

func (WorkflowState) Descriptor added in v19.1.0 

func (WorkflowState) Descriptor() protoreflect.EnumDescriptor

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 (x WorkflowState) Number() protoreflect.EnumNumber

func (WorkflowState) String added in v19.1.0 

func (x WorkflowState) String() string

func (WorkflowState) Type added in v19.1.0 

func (WorkflowState) Type() protoreflect.EnumType

Source Files

View all Source files

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.