rpc

package
v19.0.0 Latest Latest
Warning

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

Go to latest
Published: May 21, 2026 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	RunnerControllerService_AdmitJob_FullMethodName = "/gitlab.agent.runner_controller.rpc.RunnerControllerService/AdmitJob"
)

Variables

View Source
var File_internal_module_runner_controller_rpc_runner_controller_proto protoreflect.FileDescriptor
View Source
var RunnerControllerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gitlab.agent.runner_controller.rpc.RunnerControllerService",
	HandlerType: (*RunnerControllerServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "AdmitJob",
			Handler:       _RunnerControllerService_AdmitJob_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "internal/module/runner_controller/rpc/runner_controller.proto",
}

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

Functions

func RegisterRunnerControllerServiceServer

func RegisterRunnerControllerServiceServer(s grpc.ServiceRegistrar, srv RunnerControllerServiceServer)

Types

type AdmitJobRequest

type AdmitJobRequest struct {
	ProjectId       int64  `protobuf:"varint,1,opt,name=project_id,json=projectId" json:"project_id,omitempty"`
	ProjectName     string `protobuf:"bytes,2,opt,name=project_name,json=projectName" json:"project_name,omitempty"`
	ProjectFullPath string `protobuf:"bytes,3,opt,name=project_full_path,json=projectFullPath" json:"project_full_path,omitempty"`
	NamespaceId     int64  `protobuf:"varint,4,opt,name=namespace_id,json=namespaceId" json:"namespace_id,omitempty"`
	RootNamespaceId int64  `protobuf:"varint,5,opt,name=root_namespace_id,json=rootNamespaceId" json:"root_namespace_id,omitempty"`
	OrganizationId  int64  `protobuf:"varint,6,opt,name=organization_id,json=organizationId" json:"organization_id,omitempty"`
	UserId          int64  `protobuf:"varint,7,opt,name=user_id,json=userId" json:"user_id,omitempty"`
	Image           *Image `protobuf:"bytes,8,opt,name=image" json:"image,omitempty"`
	RunnerId        int64  `protobuf:"varint,9,opt,name=runner_id,json=runnerId" json:"runner_id,omitempty"`
	JobId           int64  `protobuf:"varint,10,opt,name=job_id,json=jobId" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AdmitJobRequest) Descriptor deprecated

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

Deprecated: Use AdmitJobRequest.ProtoReflect.Descriptor instead.

func (*AdmitJobRequest) GetImage

func (x *AdmitJobRequest) GetImage() *Image

func (*AdmitJobRequest) GetJobId

func (x *AdmitJobRequest) GetJobId() int64

func (*AdmitJobRequest) GetNamespaceId

func (x *AdmitJobRequest) GetNamespaceId() int64

func (*AdmitJobRequest) GetOrganizationId

func (x *AdmitJobRequest) GetOrganizationId() int64

func (*AdmitJobRequest) GetProjectFullPath

func (x *AdmitJobRequest) GetProjectFullPath() string

func (*AdmitJobRequest) GetProjectId

func (x *AdmitJobRequest) GetProjectId() int64

func (*AdmitJobRequest) GetProjectName

func (x *AdmitJobRequest) GetProjectName() string

func (*AdmitJobRequest) GetRootNamespaceId

func (x *AdmitJobRequest) GetRootNamespaceId() int64

func (*AdmitJobRequest) GetRunnerId

func (x *AdmitJobRequest) GetRunnerId() int64

func (*AdmitJobRequest) GetUserId

func (x *AdmitJobRequest) GetUserId() int64

func (*AdmitJobRequest) ProtoMessage

func (*AdmitJobRequest) ProtoMessage()

func (*AdmitJobRequest) ProtoReflect

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

func (*AdmitJobRequest) Reset

func (x *AdmitJobRequest) Reset()

func (*AdmitJobRequest) String

func (x *AdmitJobRequest) String() string

type AdmitJobResponse

type AdmitJobResponse struct {

	// Types that are valid to be assigned to AdmissionResponse:
	//
	//	*AdmitJobResponse_Admitted
	//	*AdmitJobResponse_Rejected
	AdmissionResponse isAdmitJobResponse_AdmissionResponse `protobuf_oneof:"admission_response"`
	// contains filtered or unexported fields
}

func (*AdmitJobResponse) Descriptor deprecated

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

Deprecated: Use AdmitJobResponse.ProtoReflect.Descriptor instead.

func (*AdmitJobResponse) GetAdmissionResponse

func (x *AdmitJobResponse) GetAdmissionResponse() isAdmitJobResponse_AdmissionResponse

func (*AdmitJobResponse) GetAdmitted

func (x *AdmitJobResponse) GetAdmitted() *Admitted

func (*AdmitJobResponse) GetRejected

func (x *AdmitJobResponse) GetRejected() *Rejected

func (*AdmitJobResponse) ProtoMessage

func (*AdmitJobResponse) ProtoMessage()

func (*AdmitJobResponse) ProtoReflect

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

func (*AdmitJobResponse) Reset

func (x *AdmitJobResponse) Reset()

func (*AdmitJobResponse) String

func (x *AdmitJobResponse) String() string

type AdmitJobResponse_Admitted

type AdmitJobResponse_Admitted struct {
	Admitted *Admitted `protobuf:"bytes,1,opt,name=admitted,oneof"`
}

type AdmitJobResponse_Rejected

type AdmitJobResponse_Rejected struct {
	Rejected *Rejected `protobuf:"bytes,2,opt,name=rejected,oneof"`
}

type Admitted

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

func (*Admitted) Descriptor deprecated

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

Deprecated: Use Admitted.ProtoReflect.Descriptor instead.

func (*Admitted) ProtoMessage

func (*Admitted) ProtoMessage()

func (*Admitted) ProtoReflect

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

func (*Admitted) Reset

func (x *Admitted) Reset()

func (*Admitted) String

func (x *Admitted) String() string

type Image

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

func (*Image) Descriptor deprecated

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

Deprecated: Use Image.ProtoReflect.Descriptor instead.

func (*Image) GetName

func (x *Image) GetName() string

func (*Image) ProtoMessage

func (*Image) ProtoMessage()

func (*Image) ProtoReflect

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

func (*Image) Reset

func (x *Image) Reset()

func (*Image) String

func (x *Image) String() string

type Rejected

type Rejected struct {
	Reason string `protobuf:"bytes,1,opt,name=reason" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*Rejected) Descriptor deprecated

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

Deprecated: Use Rejected.ProtoReflect.Descriptor instead.

func (*Rejected) GetReason

func (x *Rejected) GetReason() string

func (*Rejected) ProtoMessage

func (*Rejected) ProtoMessage()

func (*Rejected) ProtoReflect

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

func (*Rejected) Reset

func (x *Rejected) Reset()

func (*Rejected) String

func (x *Rejected) String() string

type RunnerControllerServiceClient

type RunnerControllerServiceClient interface {
	AdmitJob(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[AdmitJobResponse, AdmitJobRequest], error)
}

RunnerControllerServiceClient is the client API for RunnerControllerService 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 RunnerControllerServiceServer

type RunnerControllerServiceServer interface {
	AdmitJob(grpc.BidiStreamingServer[AdmitJobResponse, AdmitJobRequest]) error
	// contains filtered or unexported methods
}

RunnerControllerServiceServer is the server API for RunnerControllerService service. All implementations must embed UnimplementedRunnerControllerServiceServer for forward compatibility.

type RunnerControllerService_AdmitJobClient

type RunnerControllerService_AdmitJobClient = grpc.BidiStreamingClient[AdmitJobResponse, AdmitJobRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type RunnerControllerService_AdmitJobServer

type RunnerControllerService_AdmitJobServer = grpc.BidiStreamingServer[AdmitJobResponse, AdmitJobRequest]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedRunnerControllerServiceServer

type UnimplementedRunnerControllerServiceServer struct{}

UnimplementedRunnerControllerServiceServer 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 (UnimplementedRunnerControllerServiceServer) AdmitJob

type UnsafeRunnerControllerServiceServer

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

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

Jump to

Keyboard shortcuts

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