Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterRunnerControllerServiceServer(s grpc.ServiceRegistrar, srv RunnerControllerServiceServer)
- type AdmitJobRequest
- func (*AdmitJobRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AdmitJobRequest) GetImage() *Image
- func (x *AdmitJobRequest) GetNamespaceId() int64
- func (x *AdmitJobRequest) GetOrganizationId() int64
- func (x *AdmitJobRequest) GetProjectFullPath() string
- func (x *AdmitJobRequest) GetProjectId() int64
- func (x *AdmitJobRequest) GetProjectName() string
- func (x *AdmitJobRequest) GetRootNamespaceId() int64
- func (x *AdmitJobRequest) GetUserId() int64
- func (*AdmitJobRequest) ProtoMessage()
- func (x *AdmitJobRequest) ProtoReflect() protoreflect.Message
- func (x *AdmitJobRequest) Reset()
- func (x *AdmitJobRequest) String() string
- type AdmitJobResponse
- func (*AdmitJobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AdmitJobResponse) GetAdmissionResponse() isAdmitJobResponse_AdmissionResponse
- func (x *AdmitJobResponse) GetAdmitted() *Admitted
- func (x *AdmitJobResponse) GetRejected() *Rejected
- func (*AdmitJobResponse) ProtoMessage()
- func (x *AdmitJobResponse) ProtoReflect() protoreflect.Message
- func (x *AdmitJobResponse) Reset()
- func (x *AdmitJobResponse) String() string
- type AdmitJobResponse_Admitted
- type AdmitJobResponse_Rejected
- type Admitted
- type Image
- type Rejected
- type RunnerControllerServiceClient
- type RunnerControllerServiceServer
- type RunnerControllerService_AdmitJobClient
- type RunnerControllerService_AdmitJobServer
- type UnimplementedRunnerControllerServiceServer
- type UnsafeRunnerControllerServiceServer
Constants ¶
const (
RunnerControllerService_AdmitJob_FullMethodName = "/gitlab.agent.runner_controller.rpc.RunnerControllerService/AdmitJob"
)
Variables ¶
var File_internal_module_runner_controller_rpc_runner_controller_proto protoreflect.FileDescriptor
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 ¶ added in v18.7.0
type AdmitJobRequest struct {
ProjectId int64 `protobuf:"varint,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
ProjectName string `protobuf:"bytes,2,opt,name=project_name,json=projectName,proto3" json:"project_name,omitempty"`
ProjectFullPath string `protobuf:"bytes,3,opt,name=project_full_path,json=projectFullPath,proto3" json:"project_full_path,omitempty"`
NamespaceId int64 `protobuf:"varint,4,opt,name=namespace_id,json=namespaceId,proto3" json:"namespace_id,omitempty"`
RootNamespaceId int64 `protobuf:"varint,5,opt,name=root_namespace_id,json=rootNamespaceId,proto3" json:"root_namespace_id,omitempty"`
OrganizationId int64 `protobuf:"varint,6,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
UserId int64 `protobuf:"varint,7,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
Image *Image `protobuf:"bytes,8,opt,name=image,proto3" json:"image,omitempty"`
// contains filtered or unexported fields
}
func (*AdmitJobRequest) Descriptor
deprecated
added in
v18.7.0
func (*AdmitJobRequest) Descriptor() ([]byte, []int)
Deprecated: Use AdmitJobRequest.ProtoReflect.Descriptor instead.
func (*AdmitJobRequest) GetImage ¶ added in v18.8.0
func (x *AdmitJobRequest) GetImage() *Image
func (*AdmitJobRequest) GetNamespaceId ¶ added in v18.8.0
func (x *AdmitJobRequest) GetNamespaceId() int64
func (*AdmitJobRequest) GetOrganizationId ¶ added in v18.8.0
func (x *AdmitJobRequest) GetOrganizationId() int64
func (*AdmitJobRequest) GetProjectFullPath ¶ added in v18.8.0
func (x *AdmitJobRequest) GetProjectFullPath() string
func (*AdmitJobRequest) GetProjectId ¶ added in v18.8.0
func (x *AdmitJobRequest) GetProjectId() int64
func (*AdmitJobRequest) GetProjectName ¶ added in v18.8.0
func (x *AdmitJobRequest) GetProjectName() string
func (*AdmitJobRequest) GetRootNamespaceId ¶ added in v18.8.0
func (x *AdmitJobRequest) GetRootNamespaceId() int64
func (*AdmitJobRequest) GetUserId ¶ added in v18.8.0
func (x *AdmitJobRequest) GetUserId() int64
func (*AdmitJobRequest) ProtoMessage ¶ added in v18.7.0
func (*AdmitJobRequest) ProtoMessage()
func (*AdmitJobRequest) ProtoReflect ¶ added in v18.7.0
func (x *AdmitJobRequest) ProtoReflect() protoreflect.Message
func (*AdmitJobRequest) Reset ¶ added in v18.7.0
func (x *AdmitJobRequest) Reset()
func (*AdmitJobRequest) String ¶ added in v18.7.0
func (x *AdmitJobRequest) String() string
type AdmitJobResponse ¶ added in v18.7.0
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
added in
v18.7.0
func (*AdmitJobResponse) Descriptor() ([]byte, []int)
Deprecated: Use AdmitJobResponse.ProtoReflect.Descriptor instead.
func (*AdmitJobResponse) GetAdmissionResponse ¶ added in v18.8.0
func (x *AdmitJobResponse) GetAdmissionResponse() isAdmitJobResponse_AdmissionResponse
func (*AdmitJobResponse) GetAdmitted ¶ added in v18.7.0
func (x *AdmitJobResponse) GetAdmitted() *Admitted
func (*AdmitJobResponse) GetRejected ¶ added in v18.8.0
func (x *AdmitJobResponse) GetRejected() *Rejected
func (*AdmitJobResponse) ProtoMessage ¶ added in v18.7.0
func (*AdmitJobResponse) ProtoMessage()
func (*AdmitJobResponse) ProtoReflect ¶ added in v18.7.0
func (x *AdmitJobResponse) ProtoReflect() protoreflect.Message
func (*AdmitJobResponse) Reset ¶ added in v18.7.0
func (x *AdmitJobResponse) Reset()
func (*AdmitJobResponse) String ¶ added in v18.7.0
func (x *AdmitJobResponse) String() string
type AdmitJobResponse_Admitted ¶ added in v18.8.0
type AdmitJobResponse_Admitted struct {
Admitted *Admitted `protobuf:"bytes,1,opt,name=admitted,proto3,oneof"`
}
type AdmitJobResponse_Rejected ¶ added in v18.8.0
type AdmitJobResponse_Rejected struct {
Rejected *Rejected `protobuf:"bytes,2,opt,name=rejected,proto3,oneof"`
}
type Admitted ¶ added in v18.8.0
type Admitted struct {
// contains filtered or unexported fields
}
func (*Admitted) Descriptor
deprecated
added in
v18.8.0
func (*Admitted) ProtoMessage ¶ added in v18.8.0
func (*Admitted) ProtoMessage()
func (*Admitted) ProtoReflect ¶ added in v18.8.0
func (x *Admitted) ProtoReflect() protoreflect.Message
type Image ¶ added in v18.8.0
type Image struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*Image) Descriptor
deprecated
added in
v18.8.0
func (*Image) ProtoMessage ¶ added in v18.8.0
func (*Image) ProtoMessage()
func (*Image) ProtoReflect ¶ added in v18.8.0
func (x *Image) ProtoReflect() protoreflect.Message
type Rejected ¶ added in v18.8.0
type Rejected struct {
Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
// contains filtered or unexported fields
}
func (*Rejected) Descriptor
deprecated
added in
v18.8.0
func (*Rejected) ProtoMessage ¶ added in v18.8.0
func (*Rejected) ProtoMessage()
func (*Rejected) ProtoReflect ¶ added in v18.8.0
func (x *Rejected) ProtoReflect() protoreflect.Message
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.
func NewRunnerControllerServiceClient ¶
func NewRunnerControllerServiceClient(cc grpc.ClientConnInterface) RunnerControllerServiceClient
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 ¶ added in v18.7.0
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 ¶ added in v18.7.0
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.
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.