Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterJobRouterServer(s grpc.ServiceRegistrar, srv JobRouterServer)
- type GetJobRequest
- type GetJobResponse
- type JobImage
- type JobInfo
- func (*JobInfo) Descriptor() ([]byte, []int)deprecated
- func (x *JobInfo) GetNamespaceId() int64
- func (x *JobInfo) GetOrganizationId() int64
- func (x *JobInfo) GetProjectFullPath() string
- func (x *JobInfo) GetProjectId() int64
- func (x *JobInfo) GetProjectName() string
- func (x *JobInfo) GetRootNamespaceId() int64
- func (x *JobInfo) GetUserId() int64
- func (*JobInfo) ProtoMessage()
- func (x *JobInfo) ProtoReflect() protoreflect.Message
- func (x *JobInfo) Reset()
- func (x *JobInfo) String() string
- type JobResponse
- func (*JobResponse) Descriptor() ([]byte, []int)deprecated
- func (x *JobResponse) GetJobId() int64
- func (x *JobResponse) GetJobImage() *JobImage
- func (x *JobResponse) GetJobInfo() *JobInfo
- func (x *JobResponse) GetJobToken() string
- func (*JobResponse) ProtoMessage()
- func (x *JobResponse) ProtoReflect() protoreflect.Message
- func (x *JobResponse) Reset()
- func (x *JobResponse) String() string
- type JobRouterClient
- type JobRouterServer
- type UnimplementedJobRouterServer
- type UnsafeJobRouterServer
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 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) ProtoMessage ¶ added in v18.8.0
func (*JobImage) ProtoMessage()
func (*JobImage) ProtoReflect ¶ added in v18.8.0
func (x *JobImage) ProtoReflect() protoreflect.Message
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) GetNamespaceId ¶ added in v18.8.0
func (*JobInfo) GetOrganizationId ¶ added in v18.8.0
func (*JobInfo) GetProjectFullPath ¶ added in v18.8.0
func (*JobInfo) GetProjectId ¶ added in v18.8.0
func (*JobInfo) GetProjectName ¶ added in v18.8.0
func (*JobInfo) GetRootNamespaceId ¶ added in v18.8.0
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
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 ¶
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.