Versions in this module Expand all Collapse all v0 v0.0.1 Jul 10, 2021 Changes in this version + var File_job_job_proto protoreflect.FileDescriptor + var Job_TaskStrategy_name = map[int32]string + var Job_TaskStrategy_value = map[string]int32 + var Status_name = map[int32]string + var Status_value = map[string]int32 + func RegisterTimerServer(s *grpc.Server, srv TimerServer) + type InquireJobRequest struct + AppId string + JobId string + func (*InquireJobRequest) Descriptor() ([]byte, []int) + func (*InquireJobRequest) ProtoMessage() + func (m *InquireJobRequest) Validate() error + func (x *InquireJobRequest) GetAppId() string + func (x *InquireJobRequest) GetJobId() string + func (x *InquireJobRequest) ProtoReflect() protoreflect.Message + func (x *InquireJobRequest) Reset() + func (x *InquireJobRequest) String() string + type InquireJobRequestValidationError struct + func (e InquireJobRequestValidationError) Cause() error + func (e InquireJobRequestValidationError) Error() string + func (e InquireJobRequestValidationError) ErrorName() string + func (e InquireJobRequestValidationError) Field() string + func (e InquireJobRequestValidationError) Key() bool + func (e InquireJobRequestValidationError) Reason() string + type InquireJobResponse struct + Id string + Job *Job + Status Status + func (*InquireJobResponse) Descriptor() ([]byte, []int) + func (*InquireJobResponse) ProtoMessage() + func (m *InquireJobResponse) Validate() error + func (x *InquireJobResponse) GetId() string + func (x *InquireJobResponse) GetJob() *Job + func (x *InquireJobResponse) GetStatus() Status + func (x *InquireJobResponse) ProtoReflect() protoreflect.Message + func (x *InquireJobResponse) Reset() + func (x *InquireJobResponse) String() string + type InquireJobResponseValidationError struct + func (e InquireJobResponseValidationError) Cause() error + func (e InquireJobResponseValidationError) Error() string + func (e InquireJobResponseValidationError) ErrorName() string + func (e InquireJobResponseValidationError) Field() string + func (e InquireJobResponseValidationError) Key() bool + func (e InquireJobResponseValidationError) Reason() string + type InquireTaskRequest struct + AppId string + TaskId string + func (*InquireTaskRequest) Descriptor() ([]byte, []int) + func (*InquireTaskRequest) ProtoMessage() + func (m *InquireTaskRequest) Validate() error + func (x *InquireTaskRequest) GetAppId() string + func (x *InquireTaskRequest) GetTaskId() string + func (x *InquireTaskRequest) ProtoReflect() protoreflect.Message + func (x *InquireTaskRequest) Reset() + func (x *InquireTaskRequest) String() string + type InquireTaskRequestValidationError struct + func (e InquireTaskRequestValidationError) Cause() error + func (e InquireTaskRequestValidationError) Error() string + func (e InquireTaskRequestValidationError) ErrorName() string + func (e InquireTaskRequestValidationError) Field() string + func (e InquireTaskRequestValidationError) Key() bool + func (e InquireTaskRequestValidationError) Reason() string + type InquireTaskResponse struct + Id string + Status Status + Task *Task + func (*InquireTaskResponse) Descriptor() ([]byte, []int) + func (*InquireTaskResponse) ProtoMessage() + func (m *InquireTaskResponse) Validate() error + func (x *InquireTaskResponse) GetId() string + func (x *InquireTaskResponse) GetStatus() Status + func (x *InquireTaskResponse) GetTask() *Task + func (x *InquireTaskResponse) ProtoReflect() protoreflect.Message + func (x *InquireTaskResponse) Reset() + func (x *InquireTaskResponse) String() string + type InquireTaskResponseValidationError struct + func (e InquireTaskResponseValidationError) Cause() error + func (e InquireTaskResponseValidationError) Error() string + func (e InquireTaskResponseValidationError) ErrorName() string + func (e InquireTaskResponseValidationError) Field() string + func (e InquireTaskResponseValidationError) Key() bool + func (e InquireTaskResponseValidationError) Reason() string + type Job struct + Expire *common.Expire + JobId string + TaskStrategy Job_TaskStrategy + Tasks []*Task + func (*Job) Descriptor() ([]byte, []int) + func (*Job) ProtoMessage() + func (m *Job) Validate() error + func (x *Job) GetExpire() *common.Expire + func (x *Job) GetJobId() string + func (x *Job) GetTaskStrategy() Job_TaskStrategy + func (x *Job) GetTasks() []*Task + func (x *Job) ProtoReflect() protoreflect.Message + func (x *Job) Reset() + func (x *Job) String() string + type JobValidationError struct + func (e JobValidationError) Cause() error + func (e JobValidationError) Error() string + func (e JobValidationError) ErrorName() string + func (e JobValidationError) Field() string + func (e JobValidationError) Key() bool + func (e JobValidationError) Reason() string + type Job_TaskStrategy int32 + const Job_PARALLEL + const Job_SERIAL + func (Job_TaskStrategy) Descriptor() protoreflect.EnumDescriptor + func (Job_TaskStrategy) EnumDescriptor() ([]byte, []int) + func (Job_TaskStrategy) Type() protoreflect.EnumType + func (x Job_TaskStrategy) Enum() *Job_TaskStrategy + func (x Job_TaskStrategy) Number() protoreflect.EnumNumber + func (x Job_TaskStrategy) String() string + type PutTimerJobRequest struct + AppId string + Callback *common.Target + Job *Job + func (*PutTimerJobRequest) Descriptor() ([]byte, []int) + func (*PutTimerJobRequest) ProtoMessage() + func (m *PutTimerJobRequest) Validate() error + func (x *PutTimerJobRequest) GetAppId() string + func (x *PutTimerJobRequest) GetCallback() *common.Target + func (x *PutTimerJobRequest) GetJob() *Job + func (x *PutTimerJobRequest) ProtoReflect() protoreflect.Message + func (x *PutTimerJobRequest) Reset() + func (x *PutTimerJobRequest) String() string + type PutTimerJobRequestValidationError struct + func (e PutTimerJobRequestValidationError) Cause() error + func (e PutTimerJobRequestValidationError) Error() string + func (e PutTimerJobRequestValidationError) ErrorName() string + func (e PutTimerJobRequestValidationError) Field() string + func (e PutTimerJobRequestValidationError) Key() bool + func (e PutTimerJobRequestValidationError) Reason() string + type PutTimerJobResponse struct + Id string + Status Status + func (*PutTimerJobResponse) Descriptor() ([]byte, []int) + func (*PutTimerJobResponse) ProtoMessage() + func (m *PutTimerJobResponse) Validate() error + func (x *PutTimerJobResponse) GetId() string + func (x *PutTimerJobResponse) GetStatus() Status + func (x *PutTimerJobResponse) ProtoReflect() protoreflect.Message + func (x *PutTimerJobResponse) Reset() + func (x *PutTimerJobResponse) String() string + type PutTimerJobResponseValidationError struct + func (e PutTimerJobResponseValidationError) Cause() error + func (e PutTimerJobResponseValidationError) Error() string + func (e PutTimerJobResponseValidationError) ErrorName() string + func (e PutTimerJobResponseValidationError) Field() string + func (e PutTimerJobResponseValidationError) Key() bool + func (e PutTimerJobResponseValidationError) Reason() string + type Status int32 + const Status_COMPLETE + const Status_FAILED + const Status_PENDING + const Status_RUNNING + const Status_UNKNOWN + func (Status) Descriptor() protoreflect.EnumDescriptor + func (Status) EnumDescriptor() ([]byte, []int) + func (Status) Type() protoreflect.EnumType + func (x Status) Enum() *Status + func (x Status) Number() protoreflect.EnumNumber + func (x Status) String() string + type Task struct + Id string + JobId string + LastTaskResult *any.Any + Reason string + Result *any.Any + Target *common.Target + TaskContent *any.Any + TaskId string + TaskName string + func (*Task) Descriptor() ([]byte, []int) + func (*Task) ProtoMessage() + func (m *Task) Validate() error + func (x *Task) GetId() string + func (x *Task) GetJobId() string + func (x *Task) GetLastTaskResult() *any.Any + func (x *Task) GetReason() string + func (x *Task) GetResult() *any.Any + func (x *Task) GetTarget() *common.Target + func (x *Task) GetTaskContent() *any.Any + func (x *Task) GetTaskId() string + func (x *Task) GetTaskName() string + func (x *Task) ProtoReflect() protoreflect.Message + func (x *Task) Reset() + func (x *Task) String() string + type TaskValidationError struct + func (e TaskValidationError) Cause() error + func (e TaskValidationError) Error() string + func (e TaskValidationError) ErrorName() string + func (e TaskValidationError) Field() string + func (e TaskValidationError) Key() bool + func (e TaskValidationError) Reason() string + type TimerClient interface + InquireJob func(ctx context.Context, in *InquireJobRequest, opts ...grpc.CallOption) (*InquireJobResponse, error) + InquireTask func(ctx context.Context, in *InquireJobRequest, opts ...grpc.CallOption) (*InquireJobResponse, error) + PutTimerJob func(ctx context.Context, in *PutTimerJobRequest, opts ...grpc.CallOption) (*PutTimerJobResponse, error) + func NewTimerClient(cc grpc.ClientConnInterface) TimerClient + type TimerServer interface + InquireJob func(context.Context, *InquireJobRequest) (*InquireJobResponse, error) + InquireTask func(context.Context, *InquireJobRequest) (*InquireJobResponse, error) + PutTimerJob func(context.Context, *PutTimerJobRequest) (*PutTimerJobResponse, error) + type UnimplementedTimerServer struct + func (*UnimplementedTimerServer) InquireJob(context.Context, *InquireJobRequest) (*InquireJobResponse, error) + func (*UnimplementedTimerServer) InquireTask(context.Context, *InquireJobRequest) (*InquireJobResponse, error) + func (*UnimplementedTimerServer) PutTimerJob(context.Context, *PutTimerJobRequest) (*PutTimerJobResponse, error)
Go to main page