Versions in this module Expand all Collapse all v0 v0.0.1 Jul 10, 2021 Changes in this version + var File_scheduler_scheduler_proto protoreflect.FileDescriptor + func RegisterSchedulerServer(s *grpc.Server, srv SchedulerServer) + type CompleteTaskRequest struct + Now *timestamp.Timestamp + Result *any.Any + TaskId string + TaskName string + func (*CompleteTaskRequest) Descriptor() ([]byte, []int) + func (*CompleteTaskRequest) ProtoMessage() + func (m *CompleteTaskRequest) Validate() error + func (x *CompleteTaskRequest) GetNow() *timestamp.Timestamp + func (x *CompleteTaskRequest) GetResult() *any.Any + func (x *CompleteTaskRequest) GetTaskId() string + func (x *CompleteTaskRequest) GetTaskName() string + func (x *CompleteTaskRequest) ProtoReflect() protoreflect.Message + func (x *CompleteTaskRequest) Reset() + func (x *CompleteTaskRequest) String() string + type CompleteTaskRequestValidationError struct + func (e CompleteTaskRequestValidationError) Cause() error + func (e CompleteTaskRequestValidationError) Error() string + func (e CompleteTaskRequestValidationError) ErrorName() string + func (e CompleteTaskRequestValidationError) Field() string + func (e CompleteTaskRequestValidationError) Key() bool + func (e CompleteTaskRequestValidationError) Reason() string + type CompleteTaskResponse struct + func (*CompleteTaskResponse) Descriptor() ([]byte, []int) + func (*CompleteTaskResponse) ProtoMessage() + func (m *CompleteTaskResponse) Validate() error + func (x *CompleteTaskResponse) ProtoReflect() protoreflect.Message + func (x *CompleteTaskResponse) Reset() + func (x *CompleteTaskResponse) String() string + type CompleteTaskResponseValidationError struct + func (e CompleteTaskResponseValidationError) Cause() error + func (e CompleteTaskResponseValidationError) Error() string + func (e CompleteTaskResponseValidationError) ErrorName() string + func (e CompleteTaskResponseValidationError) Field() string + func (e CompleteTaskResponseValidationError) Key() bool + func (e CompleteTaskResponseValidationError) Reason() string + type HeartbeatRequest struct + HeartbeatTime *timestamp.Timestamp + TaskId string + func (*HeartbeatRequest) Descriptor() ([]byte, []int) + func (*HeartbeatRequest) ProtoMessage() + func (m *HeartbeatRequest) Validate() error + func (x *HeartbeatRequest) GetHeartbeatTime() *timestamp.Timestamp + func (x *HeartbeatRequest) GetTaskId() string + func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message + func (x *HeartbeatRequest) Reset() + func (x *HeartbeatRequest) String() string + type HeartbeatRequestValidationError struct + func (e HeartbeatRequestValidationError) Cause() error + func (e HeartbeatRequestValidationError) Error() string + func (e HeartbeatRequestValidationError) ErrorName() string + func (e HeartbeatRequestValidationError) Field() string + func (e HeartbeatRequestValidationError) Key() bool + func (e HeartbeatRequestValidationError) Reason() string + type HeartbeatResponse struct + func (*HeartbeatResponse) Descriptor() ([]byte, []int) + func (*HeartbeatResponse) ProtoMessage() + func (m *HeartbeatResponse) Validate() error + func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message + func (x *HeartbeatResponse) Reset() + func (x *HeartbeatResponse) String() string + type HeartbeatResponseValidationError struct + func (e HeartbeatResponseValidationError) Cause() error + func (e HeartbeatResponseValidationError) Error() string + func (e HeartbeatResponseValidationError) ErrorName() string + func (e HeartbeatResponseValidationError) Field() string + func (e HeartbeatResponseValidationError) Key() bool + func (e HeartbeatResponseValidationError) Reason() string + type ScheduleRequest struct + HeartbeatInterval *duration.Duration + HeartbeatTimeout *duration.Duration + LastTaskResult *any.Any + Report *common.Target + ScheduleId string + Task *job.Task + func (*ScheduleRequest) Descriptor() ([]byte, []int) + func (*ScheduleRequest) ProtoMessage() + func (m *ScheduleRequest) Validate() error + func (x *ScheduleRequest) GetHeartbeatInterval() *duration.Duration + func (x *ScheduleRequest) GetHeartbeatTimeout() *duration.Duration + func (x *ScheduleRequest) GetLastTaskResult() *any.Any + func (x *ScheduleRequest) GetReport() *common.Target + func (x *ScheduleRequest) GetScheduleId() string + func (x *ScheduleRequest) GetTask() *job.Task + func (x *ScheduleRequest) ProtoReflect() protoreflect.Message + func (x *ScheduleRequest) Reset() + func (x *ScheduleRequest) String() string + type ScheduleRequestValidationError struct + func (e ScheduleRequestValidationError) Cause() error + func (e ScheduleRequestValidationError) Error() string + func (e ScheduleRequestValidationError) ErrorName() string + func (e ScheduleRequestValidationError) Field() string + func (e ScheduleRequestValidationError) Key() bool + func (e ScheduleRequestValidationError) Reason() string + type ScheduleResponse struct + func (*ScheduleResponse) Descriptor() ([]byte, []int) + func (*ScheduleResponse) ProtoMessage() + func (m *ScheduleResponse) Validate() error + func (x *ScheduleResponse) ProtoReflect() protoreflect.Message + func (x *ScheduleResponse) Reset() + func (x *ScheduleResponse) String() string + type ScheduleResponseValidationError struct + func (e ScheduleResponseValidationError) Cause() error + func (e ScheduleResponseValidationError) Error() string + func (e ScheduleResponseValidationError) ErrorName() string + func (e ScheduleResponseValidationError) Field() string + func (e ScheduleResponseValidationError) Key() bool + func (e ScheduleResponseValidationError) Reason() string + type SchedulerClient interface + CompleteTask func(ctx context.Context, in *CompleteTaskRequest, opts ...grpc.CallOption) (*CompleteTaskResponse, error) + Heartbeat func(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error) + Schedule func(ctx context.Context, in *ScheduleRequest, opts ...grpc.CallOption) (*ScheduleResponse, error) + SetFailTask func(ctx context.Context, in *SetFailTaskRequest, opts ...grpc.CallOption) (*SetFailTaskResponse, error) + func NewSchedulerClient(cc grpc.ClientConnInterface) SchedulerClient + type SchedulerServer interface + CompleteTask func(context.Context, *CompleteTaskRequest) (*CompleteTaskResponse, error) + Heartbeat func(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error) + Schedule func(context.Context, *ScheduleRequest) (*ScheduleResponse, error) + SetFailTask func(context.Context, *SetFailTaskRequest) (*SetFailTaskResponse, error) + type SetFailTaskRequest struct + Now *timestamp.Timestamp + Reason string + TaskId string + func (*SetFailTaskRequest) Descriptor() ([]byte, []int) + func (*SetFailTaskRequest) ProtoMessage() + func (m *SetFailTaskRequest) Validate() error + func (x *SetFailTaskRequest) GetNow() *timestamp.Timestamp + func (x *SetFailTaskRequest) GetReason() string + func (x *SetFailTaskRequest) GetTaskId() string + func (x *SetFailTaskRequest) ProtoReflect() protoreflect.Message + func (x *SetFailTaskRequest) Reset() + func (x *SetFailTaskRequest) String() string + type SetFailTaskRequestValidationError struct + func (e SetFailTaskRequestValidationError) Cause() error + func (e SetFailTaskRequestValidationError) Error() string + func (e SetFailTaskRequestValidationError) ErrorName() string + func (e SetFailTaskRequestValidationError) Field() string + func (e SetFailTaskRequestValidationError) Key() bool + func (e SetFailTaskRequestValidationError) Reason() string + type SetFailTaskResponse struct + func (*SetFailTaskResponse) Descriptor() ([]byte, []int) + func (*SetFailTaskResponse) ProtoMessage() + func (m *SetFailTaskResponse) Validate() error + func (x *SetFailTaskResponse) ProtoReflect() protoreflect.Message + func (x *SetFailTaskResponse) Reset() + func (x *SetFailTaskResponse) String() string + type SetFailTaskResponseValidationError struct + func (e SetFailTaskResponseValidationError) Cause() error + func (e SetFailTaskResponseValidationError) Error() string + func (e SetFailTaskResponseValidationError) ErrorName() string + func (e SetFailTaskResponseValidationError) Field() string + func (e SetFailTaskResponseValidationError) Key() bool + func (e SetFailTaskResponseValidationError) Reason() string + type UnimplementedSchedulerServer struct + func (*UnimplementedSchedulerServer) CompleteTask(context.Context, *CompleteTaskRequest) (*CompleteTaskResponse, error) + func (*UnimplementedSchedulerServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error) + func (*UnimplementedSchedulerServer) Schedule(context.Context, *ScheduleRequest) (*ScheduleResponse, error) + func (*UnimplementedSchedulerServer) SetFailTask(context.Context, *SetFailTaskRequest) (*SetFailTaskResponse, error)