Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterRunnerControllerServiceServer(s grpc.ServiceRegistrar, srv RunnerControllerServiceServer)
- type AdmitJobRequest
- type AdmitJobResponse
- 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 {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,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) GetData ¶ added in v18.7.0
func (x *AdmitJobRequest) GetData() []byte
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 {
Admitted bool `protobuf:"varint,1,opt,name=admitted,proto3" json:"admitted,omitempty"`
// 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) GetAdmitted ¶ added in v18.7.0
func (x *AdmitJobResponse) GetAdmitted() bool
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 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.
Source Files