rpc

package
v18.8.2 Latest Latest
Warning

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

Go to latest
Published: Jan 20, 2026 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	JobRouter_GetJob_FullMethodName = "/gitlab.agent.runner.rpc.JobRouter/GetJob"
)

Variables

View Source
var File_internal_module_runner_rpc_rpc_proto protoreflect.FileDescriptor
View Source
var JobRouter_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gitlab.agent.runner.rpc.JobRouter",
	HandlerType: (*JobRouterServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetJob",
			Handler:    _JobRouter_GetJob_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "internal/module/runner/rpc/rpc.proto",
}

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

Functions

func RegisterJobRouterServer

func RegisterJobRouterServer(s grpc.ServiceRegistrar, srv JobRouterServer)

Types

type GetJobRequest

type GetJobRequest struct {
	JobRequest []byte `protobuf:"bytes,1,opt,name=job_request,json=jobRequest,proto3" json:"job_request,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobRequest) Descriptor deprecated

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetJobRequest

func (x *GetJobRequest) GetJobRequest() []byte

func (*GetJobRequest) ProtoMessage

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect

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

func (*GetJobRequest) Reset

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String

func (x *GetJobRequest) String() string

type GetJobResponse

type GetJobResponse struct {
	JobResponse []byte `protobuf:"bytes,1,opt,name=job_response,json=jobResponse,proto3" json:"job_response,omitempty"`
	// contains filtered or unexported fields
}

func (*GetJobResponse) Descriptor deprecated

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

Deprecated: Use GetJobResponse.ProtoReflect.Descriptor instead.

func (*GetJobResponse) GetJobResponse

func (x *GetJobResponse) GetJobResponse() []byte

func (*GetJobResponse) ProtoMessage

func (*GetJobResponse) ProtoMessage()

func (*GetJobResponse) ProtoReflect

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

func (*GetJobResponse) Reset

func (x *GetJobResponse) Reset()

func (*GetJobResponse) String

func (x *GetJobResponse) String() string

type JobImage added in v18.8.0

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

func (*JobImage) Descriptor deprecated added in v18.8.0

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

Deprecated: Use JobImage.ProtoReflect.Descriptor instead.

func (*JobImage) GetName added in v18.8.0

func (x *JobImage) GetName() string

func (*JobImage) ProtoMessage added in v18.8.0

func (*JobImage) ProtoMessage()

func (*JobImage) ProtoReflect added in v18.8.0

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

func (*JobImage) Reset added in v18.8.0

func (x *JobImage) Reset()

func (*JobImage) String added in v18.8.0

func (x *JobImage) String() string

type JobInfo added in v18.8.0

type JobInfo struct {
	ProjectId       int64  `protobuf:"varint,1,opt,name=project_id,proto3" json:"project_id,omitempty"`
	ProjectName     string `protobuf:"bytes,2,opt,name=project_name,proto3" json:"project_name,omitempty"`
	ProjectFullPath string `protobuf:"bytes,3,opt,name=project_full_path,proto3" json:"project_full_path,omitempty"`
	NamespaceId     int64  `protobuf:"varint,4,opt,name=namespace_id,proto3" json:"namespace_id,omitempty"`
	RootNamespaceId int64  `protobuf:"varint,5,opt,name=root_namespace_id,proto3" json:"root_namespace_id,omitempty"`
	OrganizationId  int64  `protobuf:"varint,6,opt,name=organization_id,proto3" json:"organization_id,omitempty"`
	UserId          int64  `protobuf:"varint,7,opt,name=user_id,proto3" json:"user_id,omitempty"`
	// contains filtered or unexported fields
}

func (*JobInfo) Descriptor deprecated added in v18.8.0

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

Deprecated: Use JobInfo.ProtoReflect.Descriptor instead.

func (*JobInfo) GetNamespaceId added in v18.8.0

func (x *JobInfo) GetNamespaceId() int64

func (*JobInfo) GetOrganizationId added in v18.8.0

func (x *JobInfo) GetOrganizationId() int64

func (*JobInfo) GetProjectFullPath added in v18.8.0

func (x *JobInfo) GetProjectFullPath() string

func (*JobInfo) GetProjectId added in v18.8.0

func (x *JobInfo) GetProjectId() int64

func (*JobInfo) GetProjectName added in v18.8.0

func (x *JobInfo) GetProjectName() string

func (*JobInfo) GetRootNamespaceId added in v18.8.0

func (x *JobInfo) GetRootNamespaceId() int64

func (*JobInfo) GetUserId added in v18.8.0

func (x *JobInfo) GetUserId() int64

func (*JobInfo) ProtoMessage added in v18.8.0

func (*JobInfo) ProtoMessage()

func (*JobInfo) ProtoReflect added in v18.8.0

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

func (*JobInfo) Reset added in v18.8.0

func (x *JobInfo) Reset()

func (*JobInfo) String added in v18.8.0

func (x *JobInfo) String() string

type JobResponse added in v18.8.0

type JobResponse struct {
	JobId    int64     `protobuf:"varint,1,opt,name=job_id,json=id,proto3" json:"job_id,omitempty"`
	JobToken string    `protobuf:"bytes,2,opt,name=job_token,json=token,proto3" json:"job_token,omitempty"`
	JobInfo  *JobInfo  `protobuf:"bytes,3,opt,name=job_info,proto3" json:"job_info,omitempty"`
	JobImage *JobImage `protobuf:"bytes,4,opt,name=job_image,json=image,proto3" json:"job_image,omitempty"`
	// contains filtered or unexported fields
}

func (*JobResponse) Descriptor deprecated added in v18.8.0

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

Deprecated: Use JobResponse.ProtoReflect.Descriptor instead.

func (*JobResponse) GetJobId added in v18.8.0

func (x *JobResponse) GetJobId() int64

func (*JobResponse) GetJobImage added in v18.8.0

func (x *JobResponse) GetJobImage() *JobImage

func (*JobResponse) GetJobInfo added in v18.8.0

func (x *JobResponse) GetJobInfo() *JobInfo

func (*JobResponse) GetJobToken added in v18.8.0

func (x *JobResponse) GetJobToken() string

func (*JobResponse) ProtoMessage added in v18.8.0

func (*JobResponse) ProtoMessage()

func (*JobResponse) ProtoReflect added in v18.8.0

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

func (*JobResponse) Reset added in v18.8.0

func (x *JobResponse) Reset()

func (*JobResponse) String added in v18.8.0

func (x *JobResponse) String() string

type JobRouterClient

type JobRouterClient interface {
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*GetJobResponse, error)
}

JobRouterClient is the client API for JobRouter 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 NewJobRouterClient

func NewJobRouterClient(cc grpc.ClientConnInterface) JobRouterClient

type JobRouterServer

type JobRouterServer interface {
	GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
	// contains filtered or unexported methods
}

JobRouterServer is the server API for JobRouter service. All implementations must embed UnimplementedJobRouterServer for forward compatibility.

type UnimplementedJobRouterServer

type UnimplementedJobRouterServer struct{}

UnimplementedJobRouterServer 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 (UnimplementedJobRouterServer) GetJob

type UnsafeJobRouterServer

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

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

Jump to

Keyboard shortcuts

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