Documentation ¶
Index ¶
- Variables
- func RegisterJobServiceServer(s grpc.ServiceRegistrar, srv JobServiceServer)
- type CreateNewJobReq
- func (*CreateNewJobReq) Descriptor() ([]byte, []int)deprecated
- func (x *CreateNewJobReq) GetAccessCode() string
- func (x *CreateNewJobReq) GetKeyword() string
- func (x *CreateNewJobReq) GetOwner() string
- func (*CreateNewJobReq) ProtoMessage()
- func (x *CreateNewJobReq) ProtoReflect() protoreflect.Message
- func (x *CreateNewJobReq) Reset()
- func (x *CreateNewJobReq) String() string
- type CreateNewJobRes
- type GetJobIsReRunReq
- type GetJobIsReRunRes
- type GetJobListReq
- type GetJobListRes
- type GetJobStatusReq
- func (*GetJobStatusReq) Descriptor() ([]byte, []int)deprecated
- func (x *GetJobStatusReq) GetId() string
- func (x *GetJobStatusReq) GetOwner() string
- func (*GetJobStatusReq) ProtoMessage()
- func (x *GetJobStatusReq) ProtoReflect() protoreflect.Message
- func (x *GetJobStatusReq) Reset()
- func (x *GetJobStatusReq) String() string
- type GetJobStatusRes
- type JobServiceClient
- type JobServiceServer
- type ReRunJobReq
- func (*ReRunJobReq) Descriptor() ([]byte, []int)deprecated
- func (x *ReRunJobReq) GetAccessCode() string
- func (x *ReRunJobReq) GetId() string
- func (x *ReRunJobReq) GetSchedule() bool
- func (*ReRunJobReq) ProtoMessage()
- func (x *ReRunJobReq) ProtoReflect() protoreflect.Message
- func (x *ReRunJobReq) Reset()
- func (x *ReRunJobReq) String() string
- type ReRunJobRes
- type StopJobReq
- type StopJobRes
- type UnimplementedJobServiceServer
- func (UnimplementedJobServiceServer) CreateNewJob(context.Context, *CreateNewJobReq) (*CreateNewJobRes, error)
- func (UnimplementedJobServiceServer) GetJobIsReRun(context.Context, *GetJobIsReRunReq) (*GetJobIsReRunRes, error)
- func (UnimplementedJobServiceServer) GetJobList(context.Context, *GetJobListReq) (*GetJobListRes, error)
- func (UnimplementedJobServiceServer) GetJobStatus(context.Context, *GetJobStatusReq) (*GetJobStatusRes, error)
- func (UnimplementedJobServiceServer) ReRunJob(context.Context, *ReRunJobReq) (*ReRunJobRes, error)
- func (UnimplementedJobServiceServer) StopJob(context.Context, *StopJobReq) (*StopJobRes, error)
- func (UnimplementedJobServiceServer) UpdateJobStatus(context.Context, *UpdateJobStatusReq) (*UpdateJobStatusRes, error)
- type UnsafeJobServiceServer
- type UpdateJobStatusReq
- func (*UpdateJobStatusReq) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateJobStatusReq) GetId() string
- func (x *UpdateJobStatusReq) GetStatus() string
- func (*UpdateJobStatusReq) ProtoMessage()
- func (x *UpdateJobStatusReq) ProtoReflect() protoreflect.Message
- func (x *UpdateJobStatusReq) Reset()
- func (x *UpdateJobStatusReq) String() string
- type UpdateJobStatusRes
- func (*UpdateJobStatusRes) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateJobStatusRes) GetResult() string
- func (*UpdateJobStatusRes) ProtoMessage()
- func (x *UpdateJobStatusRes) ProtoReflect() protoreflect.Message
- func (x *UpdateJobStatusRes) Reset()
- func (x *UpdateJobStatusRes) String() string
Constants ¶
This section is empty.
Variables ¶
var File_pb_svc_manager_job_proto protoreflect.FileDescriptor
var JobService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pb.svc.manager.job.JobService", HandlerType: (*JobServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateNewJob", Handler: _JobService_CreateNewJob_Handler, }, { MethodName: "ReRunJob", Handler: _JobService_ReRunJob_Handler, }, { MethodName: "GetJobStatus", Handler: _JobService_GetJobStatus_Handler, }, { MethodName: "GetJobList", Handler: _JobService_GetJobList_Handler, }, { MethodName: "GetJobIsReRun", Handler: _JobService_GetJobIsReRun_Handler, }, { MethodName: "StopJob", Handler: _JobService_StopJob_Handler, }, { MethodName: "UpdateJobStatus", Handler: _JobService_UpdateJobStatus_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pb/svc/manager/job.proto", }
JobService_ServiceDesc is the grpc.ServiceDesc for JobService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterJobServiceServer ¶
func RegisterJobServiceServer(s grpc.ServiceRegistrar, srv JobServiceServer)
Types ¶
type CreateNewJobReq ¶
type CreateNewJobReq struct { Keyword string `protobuf:"bytes,1,opt,name=keyword,proto3" json:"keyword,omitempty"` Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"` AccessCode string `protobuf:"bytes,3,opt,name=accessCode,proto3" json:"accessCode,omitempty"` // contains filtered or unexported fields }
func (*CreateNewJobReq) Descriptor
deprecated
func (*CreateNewJobReq) Descriptor() ([]byte, []int)
Deprecated: Use CreateNewJobReq.ProtoReflect.Descriptor instead.
func (*CreateNewJobReq) GetAccessCode ¶
func (x *CreateNewJobReq) GetAccessCode() string
func (*CreateNewJobReq) GetKeyword ¶
func (x *CreateNewJobReq) GetKeyword() string
func (*CreateNewJobReq) GetOwner ¶
func (x *CreateNewJobReq) GetOwner() string
func (*CreateNewJobReq) ProtoMessage ¶
func (*CreateNewJobReq) ProtoMessage()
func (*CreateNewJobReq) ProtoReflect ¶
func (x *CreateNewJobReq) ProtoReflect() protoreflect.Message
func (*CreateNewJobReq) Reset ¶
func (x *CreateNewJobReq) Reset()
func (*CreateNewJobReq) String ¶
func (x *CreateNewJobReq) String() string
type CreateNewJobRes ¶
type CreateNewJobRes struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` // contains filtered or unexported fields }
func (*CreateNewJobRes) Descriptor
deprecated
func (*CreateNewJobRes) Descriptor() ([]byte, []int)
Deprecated: Use CreateNewJobRes.ProtoReflect.Descriptor instead.
func (*CreateNewJobRes) GetMsg ¶
func (x *CreateNewJobRes) GetMsg() string
func (*CreateNewJobRes) ProtoMessage ¶
func (*CreateNewJobRes) ProtoMessage()
func (*CreateNewJobRes) ProtoReflect ¶
func (x *CreateNewJobRes) ProtoReflect() protoreflect.Message
func (*CreateNewJobRes) Reset ¶
func (x *CreateNewJobRes) Reset()
func (*CreateNewJobRes) String ¶
func (x *CreateNewJobRes) String() string
type GetJobIsReRunReq ¶
type GetJobIsReRunReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*GetJobIsReRunReq) Descriptor
deprecated
func (*GetJobIsReRunReq) Descriptor() ([]byte, []int)
Deprecated: Use GetJobIsReRunReq.ProtoReflect.Descriptor instead.
func (*GetJobIsReRunReq) GetId ¶
func (x *GetJobIsReRunReq) GetId() string
func (*GetJobIsReRunReq) ProtoMessage ¶
func (*GetJobIsReRunReq) ProtoMessage()
func (*GetJobIsReRunReq) ProtoReflect ¶
func (x *GetJobIsReRunReq) ProtoReflect() protoreflect.Message
func (*GetJobIsReRunReq) Reset ¶
func (x *GetJobIsReRunReq) Reset()
func (*GetJobIsReRunReq) String ¶
func (x *GetJobIsReRunReq) String() string
type GetJobIsReRunRes ¶
type GetJobIsReRunRes struct { Result bool `protobuf:"varint,2,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*GetJobIsReRunRes) Descriptor
deprecated
func (*GetJobIsReRunRes) Descriptor() ([]byte, []int)
Deprecated: Use GetJobIsReRunRes.ProtoReflect.Descriptor instead.
func (*GetJobIsReRunRes) GetResult ¶
func (x *GetJobIsReRunRes) GetResult() bool
func (*GetJobIsReRunRes) ProtoMessage ¶
func (*GetJobIsReRunRes) ProtoMessage()
func (*GetJobIsReRunRes) ProtoReflect ¶
func (x *GetJobIsReRunRes) ProtoReflect() protoreflect.Message
func (*GetJobIsReRunRes) Reset ¶
func (x *GetJobIsReRunRes) Reset()
func (*GetJobIsReRunRes) String ¶
func (x *GetJobIsReRunRes) String() string
type GetJobListReq ¶
type GetJobListReq struct {
// contains filtered or unexported fields
}
func (*GetJobListReq) Descriptor
deprecated
func (*GetJobListReq) Descriptor() ([]byte, []int)
Deprecated: Use GetJobListReq.ProtoReflect.Descriptor instead.
func (*GetJobListReq) ProtoMessage ¶
func (*GetJobListReq) ProtoMessage()
func (*GetJobListReq) ProtoReflect ¶
func (x *GetJobListReq) ProtoReflect() protoreflect.Message
func (*GetJobListReq) Reset ¶
func (x *GetJobListReq) Reset()
func (*GetJobListReq) String ¶
func (x *GetJobListReq) String() string
type GetJobListRes ¶
type GetJobListRes struct { Job []*job.Job `protobuf:"bytes,1,rep,name=Job,proto3" json:"Job,omitempty"` // contains filtered or unexported fields }
func (*GetJobListRes) Descriptor
deprecated
func (*GetJobListRes) Descriptor() ([]byte, []int)
Deprecated: Use GetJobListRes.ProtoReflect.Descriptor instead.
func (*GetJobListRes) GetJob ¶
func (x *GetJobListRes) GetJob() []*job.Job
func (*GetJobListRes) ProtoMessage ¶
func (*GetJobListRes) ProtoMessage()
func (*GetJobListRes) ProtoReflect ¶
func (x *GetJobListRes) ProtoReflect() protoreflect.Message
func (*GetJobListRes) Reset ¶
func (x *GetJobListRes) Reset()
func (*GetJobListRes) String ¶
func (x *GetJobListRes) String() string
type GetJobStatusReq ¶
type GetJobStatusReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"` // contains filtered or unexported fields }
func (*GetJobStatusReq) Descriptor
deprecated
func (*GetJobStatusReq) Descriptor() ([]byte, []int)
Deprecated: Use GetJobStatusReq.ProtoReflect.Descriptor instead.
func (*GetJobStatusReq) GetId ¶
func (x *GetJobStatusReq) GetId() string
func (*GetJobStatusReq) GetOwner ¶
func (x *GetJobStatusReq) GetOwner() string
func (*GetJobStatusReq) ProtoMessage ¶
func (*GetJobStatusReq) ProtoMessage()
func (*GetJobStatusReq) ProtoReflect ¶
func (x *GetJobStatusReq) ProtoReflect() protoreflect.Message
func (*GetJobStatusReq) Reset ¶
func (x *GetJobStatusReq) Reset()
func (*GetJobStatusReq) String ¶
func (x *GetJobStatusReq) String() string
type GetJobStatusRes ¶
type GetJobStatusRes struct { Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*GetJobStatusRes) Descriptor
deprecated
func (*GetJobStatusRes) Descriptor() ([]byte, []int)
Deprecated: Use GetJobStatusRes.ProtoReflect.Descriptor instead.
func (*GetJobStatusRes) GetStatus ¶
func (x *GetJobStatusRes) GetStatus() string
func (*GetJobStatusRes) ProtoMessage ¶
func (*GetJobStatusRes) ProtoMessage()
func (*GetJobStatusRes) ProtoReflect ¶
func (x *GetJobStatusRes) ProtoReflect() protoreflect.Message
func (*GetJobStatusRes) Reset ¶
func (x *GetJobStatusRes) Reset()
func (*GetJobStatusRes) String ¶
func (x *GetJobStatusRes) String() string
type JobServiceClient ¶
type JobServiceClient interface { CreateNewJob(ctx context.Context, in *CreateNewJobReq, opts ...grpc.CallOption) (*CreateNewJobRes, error) ReRunJob(ctx context.Context, in *ReRunJobReq, opts ...grpc.CallOption) (*ReRunJobRes, error) GetJobStatus(ctx context.Context, in *GetJobStatusReq, opts ...grpc.CallOption) (*GetJobStatusRes, error) GetJobList(ctx context.Context, in *GetJobListReq, opts ...grpc.CallOption) (*GetJobListRes, error) GetJobIsReRun(ctx context.Context, in *GetJobIsReRunReq, opts ...grpc.CallOption) (*GetJobIsReRunRes, error) StopJob(ctx context.Context, in *StopJobReq, opts ...grpc.CallOption) (*StopJobRes, error) UpdateJobStatus(ctx context.Context, in *UpdateJobStatusReq, opts ...grpc.CallOption) (*UpdateJobStatusRes, error) }
JobServiceClient is the client API for JobService 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 NewJobServiceClient ¶
func NewJobServiceClient(cc grpc.ClientConnInterface) JobServiceClient
type JobServiceServer ¶
type JobServiceServer interface { CreateNewJob(context.Context, *CreateNewJobReq) (*CreateNewJobRes, error) ReRunJob(context.Context, *ReRunJobReq) (*ReRunJobRes, error) GetJobStatus(context.Context, *GetJobStatusReq) (*GetJobStatusRes, error) GetJobList(context.Context, *GetJobListReq) (*GetJobListRes, error) GetJobIsReRun(context.Context, *GetJobIsReRunReq) (*GetJobIsReRunRes, error) StopJob(context.Context, *StopJobReq) (*StopJobRes, error) UpdateJobStatus(context.Context, *UpdateJobStatusReq) (*UpdateJobStatusRes, error) // contains filtered or unexported methods }
JobServiceServer is the server API for JobService service. All implementations must embed UnimplementedJobServiceServer for forward compatibility
type ReRunJobReq ¶
type ReRunJobReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Schedule bool `protobuf:"varint,2,opt,name=schedule,proto3" json:"schedule,omitempty"` AccessCode string `protobuf:"bytes,3,opt,name=accessCode,proto3" json:"accessCode,omitempty"` // contains filtered or unexported fields }
func (*ReRunJobReq) Descriptor
deprecated
func (*ReRunJobReq) Descriptor() ([]byte, []int)
Deprecated: Use ReRunJobReq.ProtoReflect.Descriptor instead.
func (*ReRunJobReq) GetAccessCode ¶
func (x *ReRunJobReq) GetAccessCode() string
func (*ReRunJobReq) GetId ¶
func (x *ReRunJobReq) GetId() string
func (*ReRunJobReq) GetSchedule ¶
func (x *ReRunJobReq) GetSchedule() bool
func (*ReRunJobReq) ProtoMessage ¶
func (*ReRunJobReq) ProtoMessage()
func (*ReRunJobReq) ProtoReflect ¶
func (x *ReRunJobReq) ProtoReflect() protoreflect.Message
func (*ReRunJobReq) Reset ¶
func (x *ReRunJobReq) Reset()
func (*ReRunJobReq) String ¶
func (x *ReRunJobReq) String() string
type ReRunJobRes ¶
type ReRunJobRes struct { Msg string `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` // contains filtered or unexported fields }
func (*ReRunJobRes) Descriptor
deprecated
func (*ReRunJobRes) Descriptor() ([]byte, []int)
Deprecated: Use ReRunJobRes.ProtoReflect.Descriptor instead.
func (*ReRunJobRes) GetMsg ¶
func (x *ReRunJobRes) GetMsg() string
func (*ReRunJobRes) ProtoMessage ¶
func (*ReRunJobRes) ProtoMessage()
func (*ReRunJobRes) ProtoReflect ¶
func (x *ReRunJobRes) ProtoReflect() protoreflect.Message
func (*ReRunJobRes) Reset ¶
func (x *ReRunJobRes) Reset()
func (*ReRunJobRes) String ¶
func (x *ReRunJobRes) String() string
type StopJobReq ¶
type StopJobReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*StopJobReq) Descriptor
deprecated
func (*StopJobReq) Descriptor() ([]byte, []int)
Deprecated: Use StopJobReq.ProtoReflect.Descriptor instead.
func (*StopJobReq) GetId ¶
func (x *StopJobReq) GetId() string
func (*StopJobReq) ProtoMessage ¶
func (*StopJobReq) ProtoMessage()
func (*StopJobReq) ProtoReflect ¶
func (x *StopJobReq) ProtoReflect() protoreflect.Message
func (*StopJobReq) Reset ¶
func (x *StopJobReq) Reset()
func (*StopJobReq) String ¶
func (x *StopJobReq) String() string
type StopJobRes ¶
type StopJobRes struct { Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*StopJobRes) Descriptor
deprecated
func (*StopJobRes) Descriptor() ([]byte, []int)
Deprecated: Use StopJobRes.ProtoReflect.Descriptor instead.
func (*StopJobRes) GetResult ¶
func (x *StopJobRes) GetResult() string
func (*StopJobRes) ProtoMessage ¶
func (*StopJobRes) ProtoMessage()
func (*StopJobRes) ProtoReflect ¶
func (x *StopJobRes) ProtoReflect() protoreflect.Message
func (*StopJobRes) Reset ¶
func (x *StopJobRes) Reset()
func (*StopJobRes) String ¶
func (x *StopJobRes) String() string
type UnimplementedJobServiceServer ¶
type UnimplementedJobServiceServer struct { }
UnimplementedJobServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedJobServiceServer) CreateNewJob ¶
func (UnimplementedJobServiceServer) CreateNewJob(context.Context, *CreateNewJobReq) (*CreateNewJobRes, error)
func (UnimplementedJobServiceServer) GetJobIsReRun ¶
func (UnimplementedJobServiceServer) GetJobIsReRun(context.Context, *GetJobIsReRunReq) (*GetJobIsReRunRes, error)
func (UnimplementedJobServiceServer) GetJobList ¶
func (UnimplementedJobServiceServer) GetJobList(context.Context, *GetJobListReq) (*GetJobListRes, error)
func (UnimplementedJobServiceServer) GetJobStatus ¶
func (UnimplementedJobServiceServer) GetJobStatus(context.Context, *GetJobStatusReq) (*GetJobStatusRes, error)
func (UnimplementedJobServiceServer) ReRunJob ¶
func (UnimplementedJobServiceServer) ReRunJob(context.Context, *ReRunJobReq) (*ReRunJobRes, error)
func (UnimplementedJobServiceServer) StopJob ¶
func (UnimplementedJobServiceServer) StopJob(context.Context, *StopJobReq) (*StopJobRes, error)
func (UnimplementedJobServiceServer) UpdateJobStatus ¶
func (UnimplementedJobServiceServer) UpdateJobStatus(context.Context, *UpdateJobStatusReq) (*UpdateJobStatusRes, error)
type UnsafeJobServiceServer ¶
type UnsafeJobServiceServer interface {
// contains filtered or unexported methods
}
UnsafeJobServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to JobServiceServer will result in compilation errors.
type UpdateJobStatusReq ¶
type UpdateJobStatusReq struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*UpdateJobStatusReq) Descriptor
deprecated
func (*UpdateJobStatusReq) Descriptor() ([]byte, []int)
Deprecated: Use UpdateJobStatusReq.ProtoReflect.Descriptor instead.
func (*UpdateJobStatusReq) GetId ¶
func (x *UpdateJobStatusReq) GetId() string
func (*UpdateJobStatusReq) GetStatus ¶
func (x *UpdateJobStatusReq) GetStatus() string
func (*UpdateJobStatusReq) ProtoMessage ¶
func (*UpdateJobStatusReq) ProtoMessage()
func (*UpdateJobStatusReq) ProtoReflect ¶
func (x *UpdateJobStatusReq) ProtoReflect() protoreflect.Message
func (*UpdateJobStatusReq) Reset ¶
func (x *UpdateJobStatusReq) Reset()
func (*UpdateJobStatusReq) String ¶
func (x *UpdateJobStatusReq) String() string
type UpdateJobStatusRes ¶
type UpdateJobStatusRes struct { Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"` // contains filtered or unexported fields }
func (*UpdateJobStatusRes) Descriptor
deprecated
func (*UpdateJobStatusRes) Descriptor() ([]byte, []int)
Deprecated: Use UpdateJobStatusRes.ProtoReflect.Descriptor instead.
func (*UpdateJobStatusRes) GetResult ¶
func (x *UpdateJobStatusRes) GetResult() string
func (*UpdateJobStatusRes) ProtoMessage ¶
func (*UpdateJobStatusRes) ProtoMessage()
func (*UpdateJobStatusRes) ProtoReflect ¶
func (x *UpdateJobStatusRes) ProtoReflect() protoreflect.Message
func (*UpdateJobStatusRes) Reset ¶
func (x *UpdateJobStatusRes) Reset()
func (*UpdateJobStatusRes) String ¶
func (x *UpdateJobStatusRes) String() string