Documentation
¶
Index ¶
Constants ¶
const (
JobRouter_GetJob_FullMethodName = "/gitlab.agent.runner.rpc.JobRouter/GetJob"
)
Variables ¶
var File_internal_module_runner_rpc_rpc_proto protoreflect.FileDescriptor
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 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 ¶
func (UnimplementedJobRouterServer) GetJob(context.Context, *GetJobRequest) (*GetJobResponse, error)
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.
Source Files