Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

v1

package

Go to main page

Versions in this module

v1

v1.0.6

Apr 18, 2024

v1.0.5

Apr 17, 2024

v1.0.4

Apr 17, 2024

v1.0.3

Apr 17, 2024

v1.0.2

Apr 17, 2024

v1.0.1

Apr 17, 2024

v1.0.0

Apr 17, 2024

Changes in this version

+ const OperationServiceAddTask

+ const OperationServiceAddTaskGroup

+ const OperationServiceAddWorker

+ const OperationServiceAddWorkerGroup

+ const OperationServiceAllTaskGroup

+ const OperationServiceAllWorkerGroup

+ const OperationServiceCancelExecTask

+ const OperationServiceDeleteTask

+ const OperationServiceDeleteTaskGroup

+ const OperationServiceDeleteWorker

+ const OperationServiceDeleteWorkerGroup

+ const OperationServiceDisableTask

+ const OperationServiceDisableWorker

+ const OperationServiceEnableTask

+ const OperationServiceEnableWorker

+ const OperationServiceExecTask

+ const OperationServiceGetLog

+ const OperationServicePageLog

+ const OperationServicePageTask

+ const OperationServicePageWorker

+ const OperationServiceUpdateTask

+ const OperationServiceUpdateTaskGroup

+ const OperationServiceUpdateWorker

+ const OperationServiceUpdateWorkerGroup

+ const Service_AddTaskGroup_FullMethodName

+ const Service_AddTask_FullMethodName

+ const Service_AddWorkerGroup_FullMethodName

+ const Service_AddWorker_FullMethodName

+ const Service_AllTaskGroup_FullMethodName

+ const Service_AllWorkerGroup_FullMethodName

+ const Service_CancelExecTask_FullMethodName

+ const Service_DeleteTaskGroup_FullMethodName

+ const Service_DeleteTask_FullMethodName

+ const Service_DeleteWorkerGroup_FullMethodName

+ const Service_DeleteWorker_FullMethodName

+ const Service_DisableTask_FullMethodName

+ const Service_DisableWorker_FullMethodName

+ const Service_EnableTask_FullMethodName

+ const Service_EnableWorker_FullMethodName

+ const Service_ExecTask_FullMethodName

+ const Service_GetLog_FullMethodName

+ const Service_PageLog_FullMethodName

+ const Service_PageTask_FullMethodName

+ const Service_PageWorker_FullMethodName

+ const Service_UpdateTaskGroup_FullMethodName

+ const Service_UpdateTask_FullMethodName

+ const Service_UpdateWorkerGroup_FullMethodName

+ const Service_UpdateWorker_FullMethodName

+ var File_cron_server_log_proto protoreflect.FileDescriptor

+ var File_cron_server_service_proto protoreflect.FileDescriptor

+ var File_cron_server_task_proto protoreflect.FileDescriptor

+ var File_cron_server_worker_proto protoreflect.FileDescriptor

+ var Service_ServiceDesc = grpc.ServiceDesc

+ func RegisterServiceHTTPServer(s *http.Server, srv ServiceHTTPServer)

+ func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)

+ type AddTaskGroupReply struct

+ Id uint32

+ func (*AddTaskGroupReply) Descriptor() ([]byte, []int)

+ func (*AddTaskGroupReply) ProtoMessage()

+ func (m *AddTaskGroupReply) Validate() error

+ func (m *AddTaskGroupReply) ValidateAll() error

+ func (x *AddTaskGroupReply) GetId() uint32

+ func (x *AddTaskGroupReply) ProtoReflect() protoreflect.Message

+ func (x *AddTaskGroupReply) Reset()

+ func (x *AddTaskGroupReply) String() string

+ type AddTaskGroupReplyMultiError []error

+ func (m AddTaskGroupReplyMultiError) AllErrors() []error

+ func (m AddTaskGroupReplyMultiError) Error() string

+ type AddTaskGroupReplyValidationError struct

+ func (e AddTaskGroupReplyValidationError) Cause() error

+ func (e AddTaskGroupReplyValidationError) Error() string

+ func (e AddTaskGroupReplyValidationError) ErrorName() string

+ func (e AddTaskGroupReplyValidationError) Field() string

+ func (e AddTaskGroupReplyValidationError) Key() bool

+ func (e AddTaskGroupReplyValidationError) Reason() string

+ type AddTaskGroupRequest struct

+ Description string

+ Name string

+ func (*AddTaskGroupRequest) Descriptor() ([]byte, []int)

+ func (*AddTaskGroupRequest) ProtoMessage()

+ func (m *AddTaskGroupRequest) Validate() error

+ func (m *AddTaskGroupRequest) ValidateAll() error

+ func (x *AddTaskGroupRequest) GetDescription() string

+ func (x *AddTaskGroupRequest) GetName() string

+ func (x *AddTaskGroupRequest) ProtoReflect() protoreflect.Message

+ func (x *AddTaskGroupRequest) Reset()

+ func (x *AddTaskGroupRequest) String() string

+ type AddTaskGroupRequestMultiError []error

+ func (m AddTaskGroupRequestMultiError) AllErrors() []error

+ func (m AddTaskGroupRequestMultiError) Error() string

+ type AddTaskGroupRequestValidationError struct

+ func (e AddTaskGroupRequestValidationError) Cause() error

+ func (e AddTaskGroupRequestValidationError) Error() string

+ func (e AddTaskGroupRequestValidationError) ErrorName() string

+ func (e AddTaskGroupRequestValidationError) Field() string

+ func (e AddTaskGroupRequestValidationError) Key() bool

+ func (e AddTaskGroupRequestValidationError) Reason() string

+ type AddTaskReply struct

+ Id uint32

+ func (*AddTaskReply) Descriptor() ([]byte, []int)

+ func (*AddTaskReply) ProtoMessage()

+ func (m *AddTaskReply) Validate() error

+ func (m *AddTaskReply) ValidateAll() error

+ func (x *AddTaskReply) GetId() uint32

+ func (x *AddTaskReply) ProtoReflect() protoreflect.Message

+ func (x *AddTaskReply) Reset()

+ func (x *AddTaskReply) String() string

+ type AddTaskReplyMultiError []error

+ func (m AddTaskReplyMultiError) AllErrors() []error

+ func (m AddTaskReplyMultiError) Error() string

+ type AddTaskReplyValidationError struct

+ func (e AddTaskReplyValidationError) Cause() error

+ func (e AddTaskReplyValidationError) Error() string

+ func (e AddTaskReplyValidationError) ErrorName() string

+ func (e AddTaskReplyValidationError) Field() string

+ func (e AddTaskReplyValidationError) Key() bool

+ func (e AddTaskReplyValidationError) Reason() string

+ type AddTaskRequest struct

+ Description string

+ ExecType string

+ ExecValue string

+ ExpectCode *uint32

+ GroupId uint32

+ MaxExecTime *uint32

+ Name string

+ RetryCount *uint32

+ RetryWaitTime *uint32

+ SelectType string

+ Spec string

+ Tag string

+ WorkerGroupId *uint32

+ WorkerId *uint32

+ func (*AddTaskRequest) Descriptor() ([]byte, []int)

+ func (*AddTaskRequest) ProtoMessage()

+ func (m *AddTaskRequest) Validate() error

+ func (m *AddTaskRequest) ValidateAll() error

+ func (x *AddTaskRequest) GetDescription() string

+ func (x *AddTaskRequest) GetExecType() string

+ func (x *AddTaskRequest) GetExecValue() string

+ func (x *AddTaskRequest) GetExpectCode() uint32

+ func (x *AddTaskRequest) GetGroupId() uint32

+ func (x *AddTaskRequest) GetMaxExecTime() uint32

+ func (x *AddTaskRequest) GetName() string

+ func (x *AddTaskRequest) GetRetryCount() uint32

+ func (x *AddTaskRequest) GetRetryWaitTime() uint32

+ func (x *AddTaskRequest) GetSelectType() string

+ func (x *AddTaskRequest) GetSpec() string

+ func (x *AddTaskRequest) GetTag() string

+ func (x *AddTaskRequest) GetWorkerGroupId() uint32

+ func (x *AddTaskRequest) GetWorkerId() uint32

+ func (x *AddTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *AddTaskRequest) Reset()

+ func (x *AddTaskRequest) String() string

+ type AddTaskRequestMultiError []error

+ func (m AddTaskRequestMultiError) AllErrors() []error

+ func (m AddTaskRequestMultiError) Error() string

+ type AddTaskRequestValidationError struct

+ func (e AddTaskRequestValidationError) Cause() error

+ func (e AddTaskRequestValidationError) Error() string

+ func (e AddTaskRequestValidationError) ErrorName() string

+ func (e AddTaskRequestValidationError) Field() string

+ func (e AddTaskRequestValidationError) Key() bool

+ func (e AddTaskRequestValidationError) Reason() string

+ type AddWorkerGroupReply struct

+ Id uint32

+ func (*AddWorkerGroupReply) Descriptor() ([]byte, []int)

+ func (*AddWorkerGroupReply) ProtoMessage()

+ func (m *AddWorkerGroupReply) Validate() error

+ func (m *AddWorkerGroupReply) ValidateAll() error

+ func (x *AddWorkerGroupReply) GetId() uint32

+ func (x *AddWorkerGroupReply) ProtoReflect() protoreflect.Message

+ func (x *AddWorkerGroupReply) Reset()

+ func (x *AddWorkerGroupReply) String() string

+ type AddWorkerGroupReplyMultiError []error

+ func (m AddWorkerGroupReplyMultiError) AllErrors() []error

+ func (m AddWorkerGroupReplyMultiError) Error() string

+ type AddWorkerGroupReplyValidationError struct

+ func (e AddWorkerGroupReplyValidationError) Cause() error

+ func (e AddWorkerGroupReplyValidationError) Error() string

+ func (e AddWorkerGroupReplyValidationError) ErrorName() string

+ func (e AddWorkerGroupReplyValidationError) Field() string

+ func (e AddWorkerGroupReplyValidationError) Key() bool

+ func (e AddWorkerGroupReplyValidationError) Reason() string

+ type AddWorkerGroupRequest struct

+ Description string

+ Name string

+ func (*AddWorkerGroupRequest) Descriptor() ([]byte, []int)

+ func (*AddWorkerGroupRequest) ProtoMessage()

+ func (m *AddWorkerGroupRequest) Validate() error

+ func (m *AddWorkerGroupRequest) ValidateAll() error

+ func (x *AddWorkerGroupRequest) GetDescription() string

+ func (x *AddWorkerGroupRequest) GetName() string

+ func (x *AddWorkerGroupRequest) ProtoReflect() protoreflect.Message

+ func (x *AddWorkerGroupRequest) Reset()

+ func (x *AddWorkerGroupRequest) String() string

+ type AddWorkerGroupRequestMultiError []error

+ func (m AddWorkerGroupRequestMultiError) AllErrors() []error

+ func (m AddWorkerGroupRequestMultiError) Error() string

+ type AddWorkerGroupRequestValidationError struct

+ func (e AddWorkerGroupRequestValidationError) Cause() error

+ func (e AddWorkerGroupRequestValidationError) Error() string

+ func (e AddWorkerGroupRequestValidationError) ErrorName() string

+ func (e AddWorkerGroupRequestValidationError) Field() string

+ func (e AddWorkerGroupRequestValidationError) Key() bool

+ func (e AddWorkerGroupRequestValidationError) Reason() string

+ type AddWorkerReply struct

+ Id uint32

+ func (*AddWorkerReply) Descriptor() ([]byte, []int)

+ func (*AddWorkerReply) ProtoMessage()

+ func (m *AddWorkerReply) Validate() error

+ func (m *AddWorkerReply) ValidateAll() error

+ func (x *AddWorkerReply) GetId() uint32

+ func (x *AddWorkerReply) ProtoReflect() protoreflect.Message

+ func (x *AddWorkerReply) Reset()

+ func (x *AddWorkerReply) String() string

+ type AddWorkerReplyMultiError []error

+ func (m AddWorkerReplyMultiError) AllErrors() []error

+ func (m AddWorkerReplyMultiError) Error() string

+ type AddWorkerReplyValidationError struct

+ func (e AddWorkerReplyValidationError) Cause() error

+ func (e AddWorkerReplyValidationError) Error() string

+ func (e AddWorkerReplyValidationError) ErrorName() string

+ func (e AddWorkerReplyValidationError) Field() string

+ func (e AddWorkerReplyValidationError) Key() bool

+ func (e AddWorkerReplyValidationError) Reason() string

+ type AddWorkerRequest struct

+ Description string

+ GroupId *uint32

+ Ip string

+ Name string

+ func (*AddWorkerRequest) Descriptor() ([]byte, []int)

+ func (*AddWorkerRequest) ProtoMessage()

+ func (m *AddWorkerRequest) Validate() error

+ func (m *AddWorkerRequest) ValidateAll() error

+ func (x *AddWorkerRequest) GetDescription() string

+ func (x *AddWorkerRequest) GetGroupId() uint32

+ func (x *AddWorkerRequest) GetIp() string

+ func (x *AddWorkerRequest) GetName() string

+ func (x *AddWorkerRequest) ProtoReflect() protoreflect.Message

+ func (x *AddWorkerRequest) Reset()

+ func (x *AddWorkerRequest) String() string

+ type AddWorkerRequestMultiError []error

+ func (m AddWorkerRequestMultiError) AllErrors() []error

+ func (m AddWorkerRequestMultiError) Error() string

+ type AddWorkerRequestValidationError struct

+ func (e AddWorkerRequestValidationError) Cause() error

+ func (e AddWorkerRequestValidationError) Error() string

+ func (e AddWorkerRequestValidationError) ErrorName() string

+ func (e AddWorkerRequestValidationError) Field() string

+ func (e AddWorkerRequestValidationError) Key() bool

+ func (e AddWorkerRequestValidationError) Reason() string

+ type AllTaskGroupReply struct

+ List []*TaskGroup

+ func (*AllTaskGroupReply) Descriptor() ([]byte, []int)

+ func (*AllTaskGroupReply) ProtoMessage()

+ func (m *AllTaskGroupReply) Validate() error

+ func (m *AllTaskGroupReply) ValidateAll() error

+ func (x *AllTaskGroupReply) GetList() []*TaskGroup

+ func (x *AllTaskGroupReply) ProtoReflect() protoreflect.Message

+ func (x *AllTaskGroupReply) Reset()

+ func (x *AllTaskGroupReply) String() string

+ type AllTaskGroupReplyMultiError []error

+ func (m AllTaskGroupReplyMultiError) AllErrors() []error

+ func (m AllTaskGroupReplyMultiError) Error() string

+ type AllTaskGroupReplyValidationError struct

+ func (e AllTaskGroupReplyValidationError) Cause() error

+ func (e AllTaskGroupReplyValidationError) Error() string

+ func (e AllTaskGroupReplyValidationError) ErrorName() string

+ func (e AllTaskGroupReplyValidationError) Field() string

+ func (e AllTaskGroupReplyValidationError) Key() bool

+ func (e AllTaskGroupReplyValidationError) Reason() string

+ type AllWorkerGroupReply struct

+ List []*WorkerGroup

+ func (*AllWorkerGroupReply) Descriptor() ([]byte, []int)

+ func (*AllWorkerGroupReply) ProtoMessage()

+ func (m *AllWorkerGroupReply) Validate() error

+ func (m *AllWorkerGroupReply) ValidateAll() error

+ func (x *AllWorkerGroupReply) GetList() []*WorkerGroup

+ func (x *AllWorkerGroupReply) ProtoReflect() protoreflect.Message

+ func (x *AllWorkerGroupReply) Reset()

+ func (x *AllWorkerGroupReply) String() string

+ type AllWorkerGroupReplyMultiError []error

+ func (m AllWorkerGroupReplyMultiError) AllErrors() []error

+ func (m AllWorkerGroupReplyMultiError) Error() string

+ type AllWorkerGroupReplyValidationError struct

+ func (e AllWorkerGroupReplyValidationError) Cause() error

+ func (e AllWorkerGroupReplyValidationError) Error() string

+ func (e AllWorkerGroupReplyValidationError) ErrorName() string

+ func (e AllWorkerGroupReplyValidationError) Field() string

+ func (e AllWorkerGroupReplyValidationError) Key() bool

+ func (e AllWorkerGroupReplyValidationError) Reason() string

+ type CancelExecTaskRequest struct

+ Uuid string

+ func (*CancelExecTaskRequest) Descriptor() ([]byte, []int)

+ func (*CancelExecTaskRequest) ProtoMessage()

+ func (m *CancelExecTaskRequest) Validate() error

+ func (m *CancelExecTaskRequest) ValidateAll() error

+ func (x *CancelExecTaskRequest) GetUuid() string

+ func (x *CancelExecTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *CancelExecTaskRequest) Reset()

+ func (x *CancelExecTaskRequest) String() string

+ type CancelExecTaskRequestMultiError []error

+ func (m CancelExecTaskRequestMultiError) AllErrors() []error

+ func (m CancelExecTaskRequestMultiError) Error() string

+ type CancelExecTaskRequestValidationError struct

+ func (e CancelExecTaskRequestValidationError) Cause() error

+ func (e CancelExecTaskRequestValidationError) Error() string

+ func (e CancelExecTaskRequestValidationError) ErrorName() string

+ func (e CancelExecTaskRequestValidationError) Field() string

+ func (e CancelExecTaskRequestValidationError) Key() bool

+ func (e CancelExecTaskRequestValidationError) Reason() string

+ type DeleteTaskGroupRequest struct

+ Id uint32

+ func (*DeleteTaskGroupRequest) Descriptor() ([]byte, []int)

+ func (*DeleteTaskGroupRequest) ProtoMessage()

+ func (m *DeleteTaskGroupRequest) Validate() error

+ func (m *DeleteTaskGroupRequest) ValidateAll() error

+ func (x *DeleteTaskGroupRequest) GetId() uint32

+ func (x *DeleteTaskGroupRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteTaskGroupRequest) Reset()

+ func (x *DeleteTaskGroupRequest) String() string

+ type DeleteTaskGroupRequestMultiError []error

+ func (m DeleteTaskGroupRequestMultiError) AllErrors() []error

+ func (m DeleteTaskGroupRequestMultiError) Error() string

+ type DeleteTaskGroupRequestValidationError struct

+ func (e DeleteTaskGroupRequestValidationError) Cause() error

+ func (e DeleteTaskGroupRequestValidationError) Error() string

+ func (e DeleteTaskGroupRequestValidationError) ErrorName() string

+ func (e DeleteTaskGroupRequestValidationError) Field() string

+ func (e DeleteTaskGroupRequestValidationError) Key() bool

+ func (e DeleteTaskGroupRequestValidationError) Reason() string

+ type DeleteTaskRequest struct

+ Id uint32

+ func (*DeleteTaskRequest) Descriptor() ([]byte, []int)

+ func (*DeleteTaskRequest) ProtoMessage()

+ func (m *DeleteTaskRequest) Validate() error

+ func (m *DeleteTaskRequest) ValidateAll() error

+ func (x *DeleteTaskRequest) GetId() uint32

+ func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteTaskRequest) Reset()

+ func (x *DeleteTaskRequest) String() string

+ type DeleteTaskRequestMultiError []error

+ func (m DeleteTaskRequestMultiError) AllErrors() []error

+ func (m DeleteTaskRequestMultiError) Error() string

+ type DeleteTaskRequestValidationError struct

+ func (e DeleteTaskRequestValidationError) Cause() error

+ func (e DeleteTaskRequestValidationError) Error() string

+ func (e DeleteTaskRequestValidationError) ErrorName() string

+ func (e DeleteTaskRequestValidationError) Field() string

+ func (e DeleteTaskRequestValidationError) Key() bool

+ func (e DeleteTaskRequestValidationError) Reason() string

+ type DeleteWorkerGroupRequest struct

+ Id uint32

+ func (*DeleteWorkerGroupRequest) Descriptor() ([]byte, []int)

+ func (*DeleteWorkerGroupRequest) ProtoMessage()

+ func (m *DeleteWorkerGroupRequest) Validate() error

+ func (m *DeleteWorkerGroupRequest) ValidateAll() error

+ func (x *DeleteWorkerGroupRequest) GetId() uint32

+ func (x *DeleteWorkerGroupRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteWorkerGroupRequest) Reset()

+ func (x *DeleteWorkerGroupRequest) String() string

+ type DeleteWorkerGroupRequestMultiError []error

+ func (m DeleteWorkerGroupRequestMultiError) AllErrors() []error

+ func (m DeleteWorkerGroupRequestMultiError) Error() string

+ type DeleteWorkerGroupRequestValidationError struct

+ func (e DeleteWorkerGroupRequestValidationError) Cause() error

+ func (e DeleteWorkerGroupRequestValidationError) Error() string

+ func (e DeleteWorkerGroupRequestValidationError) ErrorName() string

+ func (e DeleteWorkerGroupRequestValidationError) Field() string

+ func (e DeleteWorkerGroupRequestValidationError) Key() bool

+ func (e DeleteWorkerGroupRequestValidationError) Reason() string

+ type DeleteWorkerRequest struct

+ Id uint32

+ func (*DeleteWorkerRequest) Descriptor() ([]byte, []int)

+ func (*DeleteWorkerRequest) ProtoMessage()

+ func (m *DeleteWorkerRequest) Validate() error

+ func (m *DeleteWorkerRequest) ValidateAll() error

+ func (x *DeleteWorkerRequest) GetId() uint32

+ func (x *DeleteWorkerRequest) ProtoReflect() protoreflect.Message

+ func (x *DeleteWorkerRequest) Reset()

+ func (x *DeleteWorkerRequest) String() string

+ type DeleteWorkerRequestMultiError []error

+ func (m DeleteWorkerRequestMultiError) AllErrors() []error

+ func (m DeleteWorkerRequestMultiError) Error() string

+ type DeleteWorkerRequestValidationError struct

+ func (e DeleteWorkerRequestValidationError) Cause() error

+ func (e DeleteWorkerRequestValidationError) Error() string

+ func (e DeleteWorkerRequestValidationError) ErrorName() string

+ func (e DeleteWorkerRequestValidationError) Field() string

+ func (e DeleteWorkerRequestValidationError) Key() bool

+ func (e DeleteWorkerRequestValidationError) Reason() string

+ type DisableTaskRequest struct

+ Id uint32

+ func (*DisableTaskRequest) Descriptor() ([]byte, []int)

+ func (*DisableTaskRequest) ProtoMessage()

+ func (m *DisableTaskRequest) Validate() error

+ func (m *DisableTaskRequest) ValidateAll() error

+ func (x *DisableTaskRequest) GetId() uint32

+ func (x *DisableTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *DisableTaskRequest) Reset()

+ func (x *DisableTaskRequest) String() string

+ type DisableTaskRequestMultiError []error

+ func (m DisableTaskRequestMultiError) AllErrors() []error

+ func (m DisableTaskRequestMultiError) Error() string

+ type DisableTaskRequestValidationError struct

+ func (e DisableTaskRequestValidationError) Cause() error

+ func (e DisableTaskRequestValidationError) Error() string

+ func (e DisableTaskRequestValidationError) ErrorName() string

+ func (e DisableTaskRequestValidationError) Field() string

+ func (e DisableTaskRequestValidationError) Key() bool

+ func (e DisableTaskRequestValidationError) Reason() string

+ type DisableWorkerRequest struct

+ Id uint32

+ func (*DisableWorkerRequest) Descriptor() ([]byte, []int)

+ func (*DisableWorkerRequest) ProtoMessage()

+ func (m *DisableWorkerRequest) Validate() error

+ func (m *DisableWorkerRequest) ValidateAll() error

+ func (x *DisableWorkerRequest) GetId() uint32

+ func (x *DisableWorkerRequest) ProtoReflect() protoreflect.Message

+ func (x *DisableWorkerRequest) Reset()

+ func (x *DisableWorkerRequest) String() string

+ type DisableWorkerRequestMultiError []error

+ func (m DisableWorkerRequestMultiError) AllErrors() []error

+ func (m DisableWorkerRequestMultiError) Error() string

+ type DisableWorkerRequestValidationError struct

+ func (e DisableWorkerRequestValidationError) Cause() error

+ func (e DisableWorkerRequestValidationError) Error() string

+ func (e DisableWorkerRequestValidationError) ErrorName() string

+ func (e DisableWorkerRequestValidationError) Field() string

+ func (e DisableWorkerRequestValidationError) Key() bool

+ func (e DisableWorkerRequestValidationError) Reason() string

+ type EnableTaskRequest struct

+ Id uint32

+ func (*EnableTaskRequest) Descriptor() ([]byte, []int)

+ func (*EnableTaskRequest) ProtoMessage()

+ func (m *EnableTaskRequest) Validate() error

+ func (m *EnableTaskRequest) ValidateAll() error

+ func (x *EnableTaskRequest) GetId() uint32

+ func (x *EnableTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *EnableTaskRequest) Reset()

+ func (x *EnableTaskRequest) String() string

+ type EnableTaskRequestMultiError []error

+ func (m EnableTaskRequestMultiError) AllErrors() []error

+ func (m EnableTaskRequestMultiError) Error() string

+ type EnableTaskRequestValidationError struct

+ func (e EnableTaskRequestValidationError) Cause() error

+ func (e EnableTaskRequestValidationError) Error() string

+ func (e EnableTaskRequestValidationError) ErrorName() string

+ func (e EnableTaskRequestValidationError) Field() string

+ func (e EnableTaskRequestValidationError) Key() bool

+ func (e EnableTaskRequestValidationError) Reason() string

+ type EnableWorkerRequest struct

+ Id uint32

+ func (*EnableWorkerRequest) Descriptor() ([]byte, []int)

+ func (*EnableWorkerRequest) ProtoMessage()

+ func (m *EnableWorkerRequest) Validate() error

+ func (m *EnableWorkerRequest) ValidateAll() error

+ func (x *EnableWorkerRequest) GetId() uint32

+ func (x *EnableWorkerRequest) ProtoReflect() protoreflect.Message

+ func (x *EnableWorkerRequest) Reset()

+ func (x *EnableWorkerRequest) String() string

+ type EnableWorkerRequestMultiError []error

+ func (m EnableWorkerRequestMultiError) AllErrors() []error

+ func (m EnableWorkerRequestMultiError) Error() string

+ type EnableWorkerRequestValidationError struct

+ func (e EnableWorkerRequestValidationError) Cause() error

+ func (e EnableWorkerRequestValidationError) Error() string

+ func (e EnableWorkerRequestValidationError) ErrorName() string

+ func (e EnableWorkerRequestValidationError) Field() string

+ func (e EnableWorkerRequestValidationError) Key() bool

+ func (e EnableWorkerRequestValidationError) Reason() string

+ type ExecTaskRequest struct

+ Id uint32

+ func (*ExecTaskRequest) Descriptor() ([]byte, []int)

+ func (*ExecTaskRequest) ProtoMessage()

+ func (m *ExecTaskRequest) Validate() error

+ func (m *ExecTaskRequest) ValidateAll() error

+ func (x *ExecTaskRequest) GetId() uint32

+ func (x *ExecTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *ExecTaskRequest) Reset()

+ func (x *ExecTaskRequest) String() string

+ type ExecTaskRequestMultiError []error

+ func (m ExecTaskRequestMultiError) AllErrors() []error

+ func (m ExecTaskRequestMultiError) Error() string

+ type ExecTaskRequestValidationError struct

+ func (e ExecTaskRequestValidationError) Cause() error

+ func (e ExecTaskRequestValidationError) Error() string

+ func (e ExecTaskRequestValidationError) ErrorName() string

+ func (e ExecTaskRequestValidationError) Field() string

+ func (e ExecTaskRequestValidationError) Key() bool

+ func (e ExecTaskRequestValidationError) Reason() string

+ type GetLogRequest struct

+ Id uint32

+ func (*GetLogRequest) Descriptor() ([]byte, []int)

+ func (*GetLogRequest) ProtoMessage()

+ func (m *GetLogRequest) Validate() error

+ func (m *GetLogRequest) ValidateAll() error

+ func (x *GetLogRequest) GetId() uint32

+ func (x *GetLogRequest) ProtoReflect() protoreflect.Message

+ func (x *GetLogRequest) Reset()

+ func (x *GetLogRequest) String() string

+ type GetLogRequestMultiError []error

+ func (m GetLogRequestMultiError) AllErrors() []error

+ func (m GetLogRequestMultiError) Error() string

+ type GetLogRequestValidationError struct

+ func (e GetLogRequestValidationError) Cause() error

+ func (e GetLogRequestValidationError) Error() string

+ func (e GetLogRequestValidationError) ErrorName() string

+ func (e GetLogRequestValidationError) Field() string

+ func (e GetLogRequestValidationError) Key() bool

+ func (e GetLogRequestValidationError) Reason() string

+ type Log struct

+ Content string

+ End int64

+ Id uint32

+ Start int64

+ Status string

+ TaskId uint32

+ TaskSnapshot string

+ Uuid string

+ WorkerId uint32

+ WorkerSnapshot string

+ func (*Log) Descriptor() ([]byte, []int)

+ func (*Log) ProtoMessage()

+ func (m *Log) Validate() error

+ func (m *Log) ValidateAll() error

+ func (x *Log) GetContent() string

+ func (x *Log) GetEnd() int64

+ func (x *Log) GetId() uint32

+ func (x *Log) GetStart() int64

+ func (x *Log) GetStatus() string

+ func (x *Log) GetTaskId() uint32

+ func (x *Log) GetTaskSnapshot() string

+ func (x *Log) GetUuid() string

+ func (x *Log) GetWorkerId() uint32

+ func (x *Log) GetWorkerSnapshot() string

+ func (x *Log) ProtoReflect() protoreflect.Message

+ func (x *Log) Reset()

+ func (x *Log) String() string

+ type LogMultiError []error

+ func (m LogMultiError) AllErrors() []error

+ func (m LogMultiError) Error() string

+ type LogValidationError struct

+ func (e LogValidationError) Cause() error

+ func (e LogValidationError) Error() string

+ func (e LogValidationError) ErrorName() string

+ func (e LogValidationError) Field() string

+ func (e LogValidationError) Key() bool

+ func (e LogValidationError) Reason() string

+ type PageLogReply struct

+ List []*Log

+ Total uint32

+ func (*PageLogReply) Descriptor() ([]byte, []int)

+ func (*PageLogReply) ProtoMessage()

+ func (m *PageLogReply) Validate() error

+ func (m *PageLogReply) ValidateAll() error

+ func (x *PageLogReply) GetList() []*Log

+ func (x *PageLogReply) GetTotal() uint32

+ func (x *PageLogReply) ProtoReflect() protoreflect.Message

+ func (x *PageLogReply) Reset()

+ func (x *PageLogReply) String() string

+ type PageLogReplyMultiError []error

+ func (m PageLogReplyMultiError) AllErrors() []error

+ func (m PageLogReplyMultiError) Error() string

+ type PageLogReplyValidationError struct

+ func (e PageLogReplyValidationError) Cause() error

+ func (e PageLogReplyValidationError) Error() string

+ func (e PageLogReplyValidationError) ErrorName() string

+ func (e PageLogReplyValidationError) Field() string

+ func (e PageLogReplyValidationError) Key() bool

+ func (e PageLogReplyValidationError) Reason() string

+ type PageLogRequest struct

+ Page uint32

+ PageSize uint32

+ TaskId uint32

+ func (*PageLogRequest) Descriptor() ([]byte, []int)

+ func (*PageLogRequest) ProtoMessage()

+ func (m *PageLogRequest) Validate() error

+ func (m *PageLogRequest) ValidateAll() error

+ func (x *PageLogRequest) GetPage() uint32

+ func (x *PageLogRequest) GetPageSize() uint32

+ func (x *PageLogRequest) GetTaskId() uint32

+ func (x *PageLogRequest) ProtoReflect() protoreflect.Message

+ func (x *PageLogRequest) Reset()

+ func (x *PageLogRequest) String() string

+ type PageLogRequestMultiError []error

+ func (m PageLogRequestMultiError) AllErrors() []error

+ func (m PageLogRequestMultiError) Error() string

+ type PageLogRequestValidationError struct

+ func (e PageLogRequestValidationError) Cause() error

+ func (e PageLogRequestValidationError) Error() string

+ func (e PageLogRequestValidationError) ErrorName() string

+ func (e PageLogRequestValidationError) Field() string

+ func (e PageLogRequestValidationError) Key() bool

+ func (e PageLogRequestValidationError) Reason() string

+ type PageTaskReply struct

+ List []*Task

+ Total uint32

+ func (*PageTaskReply) Descriptor() ([]byte, []int)

+ func (*PageTaskReply) ProtoMessage()

+ func (m *PageTaskReply) Validate() error

+ func (m *PageTaskReply) ValidateAll() error

+ func (x *PageTaskReply) GetList() []*Task

+ func (x *PageTaskReply) GetTotal() uint32

+ func (x *PageTaskReply) ProtoReflect() protoreflect.Message

+ func (x *PageTaskReply) Reset()

+ func (x *PageTaskReply) String() string

+ type PageTaskReplyMultiError []error

+ func (m PageTaskReplyMultiError) AllErrors() []error

+ func (m PageTaskReplyMultiError) Error() string

+ type PageTaskReplyValidationError struct

+ func (e PageTaskReplyValidationError) Cause() error

+ func (e PageTaskReplyValidationError) Error() string

+ func (e PageTaskReplyValidationError) ErrorName() string

+ func (e PageTaskReplyValidationError) Field() string

+ func (e PageTaskReplyValidationError) Key() bool

+ func (e PageTaskReplyValidationError) Reason() string

+ type PageTaskRequest struct

+ Ip *string

+ Name *string

+ Page uint32

+ PageSize uint32

+ Status *bool

+ Tag *string

+ func (*PageTaskRequest) Descriptor() ([]byte, []int)

+ func (*PageTaskRequest) ProtoMessage()

+ func (m *PageTaskRequest) Validate() error

+ func (m *PageTaskRequest) ValidateAll() error

+ func (x *PageTaskRequest) GetIp() string

+ func (x *PageTaskRequest) GetName() string

+ func (x *PageTaskRequest) GetPage() uint32

+ func (x *PageTaskRequest) GetPageSize() uint32

+ func (x *PageTaskRequest) GetStatus() bool

+ func (x *PageTaskRequest) GetTag() string

+ func (x *PageTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *PageTaskRequest) Reset()

+ func (x *PageTaskRequest) String() string

+ type PageTaskRequestMultiError []error

+ func (m PageTaskRequestMultiError) AllErrors() []error

+ func (m PageTaskRequestMultiError) Error() string

+ type PageTaskRequestValidationError struct

+ func (e PageTaskRequestValidationError) Cause() error

+ func (e PageTaskRequestValidationError) Error() string

+ func (e PageTaskRequestValidationError) ErrorName() string

+ func (e PageTaskRequestValidationError) Field() string

+ func (e PageTaskRequestValidationError) Key() bool

+ func (e PageTaskRequestValidationError) Reason() string

+ type PageWorkerReply struct

+ List []*Worker

+ Total uint32

+ func (*PageWorkerReply) Descriptor() ([]byte, []int)

+ func (*PageWorkerReply) ProtoMessage()

+ func (m *PageWorkerReply) Validate() error

+ func (m *PageWorkerReply) ValidateAll() error

+ func (x *PageWorkerReply) GetList() []*Worker

+ func (x *PageWorkerReply) GetTotal() uint32

+ func (x *PageWorkerReply) ProtoReflect() protoreflect.Message

+ func (x *PageWorkerReply) Reset()

+ func (x *PageWorkerReply) String() string

+ type PageWorkerReplyMultiError []error

+ func (m PageWorkerReplyMultiError) AllErrors() []error

+ func (m PageWorkerReplyMultiError) Error() string

+ type PageWorkerReplyValidationError struct

+ func (e PageWorkerReplyValidationError) Cause() error

+ func (e PageWorkerReplyValidationError) Error() string

+ func (e PageWorkerReplyValidationError) ErrorName() string

+ func (e PageWorkerReplyValidationError) Field() string

+ func (e PageWorkerReplyValidationError) Key() bool

+ func (e PageWorkerReplyValidationError) Reason() string

+ type PageWorkerRequest struct

+ GroupId *uint32

+ Name *string

+ Page uint32

+ PageSize uint32

+ func (*PageWorkerRequest) Descriptor() ([]byte, []int)

+ func (*PageWorkerRequest) ProtoMessage()

+ func (m *PageWorkerRequest) Validate() error

+ func (m *PageWorkerRequest) ValidateAll() error

+ func (x *PageWorkerRequest) GetGroupId() uint32

+ func (x *PageWorkerRequest) GetName() string

+ func (x *PageWorkerRequest) GetPage() uint32

+ func (x *PageWorkerRequest) GetPageSize() uint32

+ func (x *PageWorkerRequest) ProtoReflect() protoreflect.Message

+ func (x *PageWorkerRequest) Reset()

+ func (x *PageWorkerRequest) String() string

+ type PageWorkerRequestMultiError []error

+ func (m PageWorkerRequestMultiError) AllErrors() []error

+ func (m PageWorkerRequestMultiError) Error() string

+ type PageWorkerRequestValidationError struct

+ func (e PageWorkerRequestValidationError) Cause() error

+ func (e PageWorkerRequestValidationError) Error() string

+ func (e PageWorkerRequestValidationError) ErrorName() string

+ func (e PageWorkerRequestValidationError) Field() string

+ func (e PageWorkerRequestValidationError) Key() bool

+ func (e PageWorkerRequestValidationError) Reason() string

+ type ServiceClient interface

+ AddTask func(ctx context.Context, in *AddTaskRequest, opts ...grpc.CallOption) (*AddTaskReply, error)

+ AddTaskGroup func(ctx context.Context, in *AddTaskGroupRequest, opts ...grpc.CallOption) (*AddTaskGroupReply, error)

+ AddWorker func(ctx context.Context, in *AddWorkerRequest, opts ...grpc.CallOption) (*AddWorkerReply, error)

+ AddWorkerGroup func(ctx context.Context, in *AddWorkerGroupRequest, opts ...grpc.CallOption) (*AddWorkerGroupReply, error)

+ AllTaskGroup func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AllTaskGroupReply, error)

+ AllWorkerGroup func(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AllWorkerGroupReply, error)

+ CancelExecTask func(ctx context.Context, in *CancelExecTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DeleteTask func(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DeleteTaskGroup func(ctx context.Context, in *DeleteTaskGroupRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DeleteWorker func(ctx context.Context, in *DeleteWorkerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DeleteWorkerGroup func(ctx context.Context, in *DeleteWorkerGroupRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DisableTask func(ctx context.Context, in *DisableTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ DisableWorker func(ctx context.Context, in *DisableWorkerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ EnableTask func(ctx context.Context, in *EnableTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ EnableWorker func(ctx context.Context, in *EnableWorkerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ ExecTask func(ctx context.Context, in *ExecTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetLog func(ctx context.Context, in *GetLogRequest, opts ...grpc.CallOption) (*Log, error)

+ PageLog func(ctx context.Context, in *PageLogRequest, opts ...grpc.CallOption) (*PageLogReply, error)

+ PageTask func(ctx context.Context, in *PageTaskRequest, opts ...grpc.CallOption) (*PageTaskReply, error)

+ PageWorker func(ctx context.Context, in *PageWorkerRequest, opts ...grpc.CallOption) (*PageWorkerReply, error)

+ UpdateTask func(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ UpdateTaskGroup func(ctx context.Context, in *UpdateTaskGroupRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ UpdateWorker func(ctx context.Context, in *UpdateWorkerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ UpdateWorkerGroup func(ctx context.Context, in *UpdateWorkerGroupRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

+ type ServiceHTTPClient interface

+ AddTask func(ctx context.Context, req *AddTaskRequest, opts ...http.CallOption) (rsp *AddTaskReply, err error)

+ AddTaskGroup func(ctx context.Context, req *AddTaskGroupRequest, opts ...http.CallOption) (rsp *AddTaskGroupReply, err error)

+ AddWorker func(ctx context.Context, req *AddWorkerRequest, opts ...http.CallOption) (rsp *AddWorkerReply, err error)

+ AddWorkerGroup func(ctx context.Context, req *AddWorkerGroupRequest, opts ...http.CallOption) (rsp *AddWorkerGroupReply, err error)

+ AllTaskGroup func(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *AllTaskGroupReply, err error)

+ AllWorkerGroup func(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *AllWorkerGroupReply, err error)

+ CancelExecTask func(ctx context.Context, req *CancelExecTaskRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ DeleteTask func(ctx context.Context, req *DeleteTaskRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ DeleteTaskGroup func(ctx context.Context, req *DeleteTaskGroupRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ DeleteWorker func(ctx context.Context, req *DeleteWorkerRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ DeleteWorkerGroup func(ctx context.Context, req *DeleteWorkerGroupRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ DisableTask func(ctx context.Context, req *DisableTaskRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ DisableWorker func(ctx context.Context, req *DisableWorkerRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ EnableTask func(ctx context.Context, req *EnableTaskRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ EnableWorker func(ctx context.Context, req *EnableWorkerRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ ExecTask func(ctx context.Context, req *ExecTaskRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ GetLog func(ctx context.Context, req *GetLogRequest, opts ...http.CallOption) (rsp *Log, err error)

+ PageLog func(ctx context.Context, req *PageLogRequest, opts ...http.CallOption) (rsp *PageLogReply, err error)

+ PageTask func(ctx context.Context, req *PageTaskRequest, opts ...http.CallOption) (rsp *PageTaskReply, err error)

+ PageWorker func(ctx context.Context, req *PageWorkerRequest, opts ...http.CallOption) (rsp *PageWorkerReply, err error)

+ UpdateTask func(ctx context.Context, req *UpdateTaskRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ UpdateTaskGroup func(ctx context.Context, req *UpdateTaskGroupRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ UpdateWorker func(ctx context.Context, req *UpdateWorkerRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ UpdateWorkerGroup func(ctx context.Context, req *UpdateWorkerGroupRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)

+ func NewServiceHTTPClient(client *http.Client) ServiceHTTPClient

+ type ServiceHTTPClientImpl struct

+ func (c *ServiceHTTPClientImpl) AddTask(ctx context.Context, in *AddTaskRequest, opts ...http.CallOption) (*AddTaskReply, error)

+ func (c *ServiceHTTPClientImpl) AddTaskGroup(ctx context.Context, in *AddTaskGroupRequest, opts ...http.CallOption) (*AddTaskGroupReply, error)

+ func (c *ServiceHTTPClientImpl) AddWorker(ctx context.Context, in *AddWorkerRequest, opts ...http.CallOption) (*AddWorkerReply, error)

+ func (c *ServiceHTTPClientImpl) AddWorkerGroup(ctx context.Context, in *AddWorkerGroupRequest, opts ...http.CallOption) (*AddWorkerGroupReply, error)

+ func (c *ServiceHTTPClientImpl) AllTaskGroup(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*AllTaskGroupReply, error)

+ func (c *ServiceHTTPClientImpl) AllWorkerGroup(ctx context.Context, in *emptypb.Empty, opts ...http.CallOption) (*AllWorkerGroupReply, error)

+ func (c *ServiceHTTPClientImpl) CancelExecTask(ctx context.Context, in *CancelExecTaskRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ func (c *ServiceHTTPClientImpl) DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ func (c *ServiceHTTPClientImpl) DeleteTaskGroup(ctx context.Context, in *DeleteTaskGroupRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ func (c *ServiceHTTPClientImpl) DeleteWorker(ctx context.Context, in *DeleteWorkerRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ func (c *ServiceHTTPClientImpl) DeleteWorkerGroup(ctx context.Context, in *DeleteWorkerGroupRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ func (c *ServiceHTTPClientImpl) DisableTask(ctx context.Context, in *DisableTaskRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ func (c *ServiceHTTPClientImpl) DisableWorker(ctx context.Context, in *DisableWorkerRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ func (c *ServiceHTTPClientImpl) EnableTask(ctx context.Context, in *EnableTaskRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ func (c *ServiceHTTPClientImpl) EnableWorker(ctx context.Context, in *EnableWorkerRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ func (c *ServiceHTTPClientImpl) ExecTask(ctx context.Context, in *ExecTaskRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ func (c *ServiceHTTPClientImpl) GetLog(ctx context.Context, in *GetLogRequest, opts ...http.CallOption) (*Log, error)

+ func (c *ServiceHTTPClientImpl) PageLog(ctx context.Context, in *PageLogRequest, opts ...http.CallOption) (*PageLogReply, error)

+ func (c *ServiceHTTPClientImpl) PageTask(ctx context.Context, in *PageTaskRequest, opts ...http.CallOption) (*PageTaskReply, error)

+ func (c *ServiceHTTPClientImpl) PageWorker(ctx context.Context, in *PageWorkerRequest, opts ...http.CallOption) (*PageWorkerReply, error)

+ func (c *ServiceHTTPClientImpl) UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ func (c *ServiceHTTPClientImpl) UpdateTaskGroup(ctx context.Context, in *UpdateTaskGroupRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ func (c *ServiceHTTPClientImpl) UpdateWorker(ctx context.Context, in *UpdateWorkerRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ func (c *ServiceHTTPClientImpl) UpdateWorkerGroup(ctx context.Context, in *UpdateWorkerGroupRequest, opts ...http.CallOption) (*emptypb.Empty, error)

+ type ServiceHTTPServer interface

+ AddTask func(context.Context, *AddTaskRequest) (*AddTaskReply, error)

+ AddTaskGroup func(context.Context, *AddTaskGroupRequest) (*AddTaskGroupReply, error)

+ AddWorker func(context.Context, *AddWorkerRequest) (*AddWorkerReply, error)

+ AddWorkerGroup func(context.Context, *AddWorkerGroupRequest) (*AddWorkerGroupReply, error)

+ AllTaskGroup func(context.Context, *emptypb.Empty) (*AllTaskGroupReply, error)

+ AllWorkerGroup func(context.Context, *emptypb.Empty) (*AllWorkerGroupReply, error)

+ CancelExecTask func(context.Context, *CancelExecTaskRequest) (*emptypb.Empty, error)

+ DeleteTask func(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)

+ DeleteTaskGroup func(context.Context, *DeleteTaskGroupRequest) (*emptypb.Empty, error)

+ DeleteWorker func(context.Context, *DeleteWorkerRequest) (*emptypb.Empty, error)

+ DeleteWorkerGroup func(context.Context, *DeleteWorkerGroupRequest) (*emptypb.Empty, error)

+ DisableTask func(context.Context, *DisableTaskRequest) (*emptypb.Empty, error)

+ DisableWorker func(context.Context, *DisableWorkerRequest) (*emptypb.Empty, error)

+ EnableTask func(context.Context, *EnableTaskRequest) (*emptypb.Empty, error)

+ EnableWorker func(context.Context, *EnableWorkerRequest) (*emptypb.Empty, error)

+ ExecTask func(context.Context, *ExecTaskRequest) (*emptypb.Empty, error)

+ GetLog func(context.Context, *GetLogRequest) (*Log, error)

+ PageLog func(context.Context, *PageLogRequest) (*PageLogReply, error)

+ PageTask func(context.Context, *PageTaskRequest) (*PageTaskReply, error)

+ PageWorker func(context.Context, *PageWorkerRequest) (*PageWorkerReply, error)

+ UpdateTask func(context.Context, *UpdateTaskRequest) (*emptypb.Empty, error)

+ UpdateTaskGroup func(context.Context, *UpdateTaskGroupRequest) (*emptypb.Empty, error)

+ UpdateWorker func(context.Context, *UpdateWorkerRequest) (*emptypb.Empty, error)

+ UpdateWorkerGroup func(context.Context, *UpdateWorkerGroupRequest) (*emptypb.Empty, error)

+ type ServiceServer interface

+ AddTask func(context.Context, *AddTaskRequest) (*AddTaskReply, error)

+ AddTaskGroup func(context.Context, *AddTaskGroupRequest) (*AddTaskGroupReply, error)

+ AddWorker func(context.Context, *AddWorkerRequest) (*AddWorkerReply, error)

+ AddWorkerGroup func(context.Context, *AddWorkerGroupRequest) (*AddWorkerGroupReply, error)

+ AllTaskGroup func(context.Context, *emptypb.Empty) (*AllTaskGroupReply, error)

+ AllWorkerGroup func(context.Context, *emptypb.Empty) (*AllWorkerGroupReply, error)

+ CancelExecTask func(context.Context, *CancelExecTaskRequest) (*emptypb.Empty, error)

+ DeleteTask func(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)

+ DeleteTaskGroup func(context.Context, *DeleteTaskGroupRequest) (*emptypb.Empty, error)

+ DeleteWorker func(context.Context, *DeleteWorkerRequest) (*emptypb.Empty, error)

+ DeleteWorkerGroup func(context.Context, *DeleteWorkerGroupRequest) (*emptypb.Empty, error)

+ DisableTask func(context.Context, *DisableTaskRequest) (*emptypb.Empty, error)

+ DisableWorker func(context.Context, *DisableWorkerRequest) (*emptypb.Empty, error)

+ EnableTask func(context.Context, *EnableTaskRequest) (*emptypb.Empty, error)

+ EnableWorker func(context.Context, *EnableWorkerRequest) (*emptypb.Empty, error)

+ ExecTask func(context.Context, *ExecTaskRequest) (*emptypb.Empty, error)

+ GetLog func(context.Context, *GetLogRequest) (*Log, error)

+ PageLog func(context.Context, *PageLogRequest) (*PageLogReply, error)

+ PageTask func(context.Context, *PageTaskRequest) (*PageTaskReply, error)

+ PageWorker func(context.Context, *PageWorkerRequest) (*PageWorkerReply, error)

+ UpdateTask func(context.Context, *UpdateTaskRequest) (*emptypb.Empty, error)

+ UpdateTaskGroup func(context.Context, *UpdateTaskGroupRequest) (*emptypb.Empty, error)

+ UpdateWorker func(context.Context, *UpdateWorkerRequest) (*emptypb.Empty, error)

+ UpdateWorkerGroup func(context.Context, *UpdateWorkerGroupRequest) (*emptypb.Empty, error)

+ type Task struct

+ CreatedAt uint32

+ Description string

+ ExecType string

+ ExecValue string

+ ExpectCode uint32

+ Group *TaskGroup

+ GroupId uint32

+ Id uint32

+ MaxExecTime uint32

+ Name string

+ RetryCount uint32

+ RetryWaitTime uint32

+ SelectType string

+ Spec string

+ Status bool

+ Tag string

+ UpdatedAt uint32

+ WorkerGroupId *uint32

+ WorkerId *uint32

+ func (*Task) Descriptor() ([]byte, []int)

+ func (*Task) ProtoMessage()

+ func (m *Task) Validate() error

+ func (m *Task) ValidateAll() error

+ func (x *Task) GetCreatedAt() uint32

+ func (x *Task) GetDescription() string

+ func (x *Task) GetExecType() string

+ func (x *Task) GetExecValue() string

+ func (x *Task) GetExpectCode() uint32

+ func (x *Task) GetGroup() *TaskGroup

+ func (x *Task) GetGroupId() uint32

+ func (x *Task) GetId() uint32

+ func (x *Task) GetMaxExecTime() uint32

+ func (x *Task) GetName() string

+ func (x *Task) GetRetryCount() uint32

+ func (x *Task) GetRetryWaitTime() uint32

+ func (x *Task) GetSelectType() string

+ func (x *Task) GetSpec() string

+ func (x *Task) GetStatus() bool

+ func (x *Task) GetTag() string

+ func (x *Task) GetUpdatedAt() uint32

+ func (x *Task) GetWorkerGroupId() uint32

+ func (x *Task) GetWorkerId() uint32

+ func (x *Task) ProtoReflect() protoreflect.Message

+ func (x *Task) Reset()

+ func (x *Task) String() string

+ type TaskGroup struct

+ CreatedAt uint32

+ Description string

+ Id uint32

+ Name string

+ UpdatedAt uint32

+ func (*TaskGroup) Descriptor() ([]byte, []int)

+ func (*TaskGroup) ProtoMessage()

+ func (m *TaskGroup) Validate() error

+ func (m *TaskGroup) ValidateAll() error

+ func (x *TaskGroup) GetCreatedAt() uint32

+ func (x *TaskGroup) GetDescription() string

+ func (x *TaskGroup) GetId() uint32

+ func (x *TaskGroup) GetName() string

+ func (x *TaskGroup) GetUpdatedAt() uint32

+ func (x *TaskGroup) ProtoReflect() protoreflect.Message

+ func (x *TaskGroup) Reset()

+ func (x *TaskGroup) String() string

+ type TaskGroupMultiError []error

+ func (m TaskGroupMultiError) AllErrors() []error

+ func (m TaskGroupMultiError) Error() string

+ type TaskGroupValidationError struct

+ func (e TaskGroupValidationError) Cause() error

+ func (e TaskGroupValidationError) Error() string

+ func (e TaskGroupValidationError) ErrorName() string

+ func (e TaskGroupValidationError) Field() string

+ func (e TaskGroupValidationError) Key() bool

+ func (e TaskGroupValidationError) Reason() string

+ type TaskMultiError []error

+ func (m TaskMultiError) AllErrors() []error

+ func (m TaskMultiError) Error() 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 UnimplementedServiceServer struct

+ func (UnimplementedServiceServer) AddTask(context.Context, *AddTaskRequest) (*AddTaskReply, error)

+ func (UnimplementedServiceServer) AddTaskGroup(context.Context, *AddTaskGroupRequest) (*AddTaskGroupReply, error)

+ func (UnimplementedServiceServer) AddWorker(context.Context, *AddWorkerRequest) (*AddWorkerReply, error)

+ func (UnimplementedServiceServer) AddWorkerGroup(context.Context, *AddWorkerGroupRequest) (*AddWorkerGroupReply, error)

+ func (UnimplementedServiceServer) AllTaskGroup(context.Context, *emptypb.Empty) (*AllTaskGroupReply, error)

+ func (UnimplementedServiceServer) AllWorkerGroup(context.Context, *emptypb.Empty) (*AllWorkerGroupReply, error)

+ func (UnimplementedServiceServer) CancelExecTask(context.Context, *CancelExecTaskRequest) (*emptypb.Empty, error)

+ func (UnimplementedServiceServer) DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)

+ func (UnimplementedServiceServer) DeleteTaskGroup(context.Context, *DeleteTaskGroupRequest) (*emptypb.Empty, error)

+ func (UnimplementedServiceServer) DeleteWorker(context.Context, *DeleteWorkerRequest) (*emptypb.Empty, error)

+ func (UnimplementedServiceServer) DeleteWorkerGroup(context.Context, *DeleteWorkerGroupRequest) (*emptypb.Empty, error)

+ func (UnimplementedServiceServer) DisableTask(context.Context, *DisableTaskRequest) (*emptypb.Empty, error)

+ func (UnimplementedServiceServer) DisableWorker(context.Context, *DisableWorkerRequest) (*emptypb.Empty, error)

+ func (UnimplementedServiceServer) EnableTask(context.Context, *EnableTaskRequest) (*emptypb.Empty, error)

+ func (UnimplementedServiceServer) EnableWorker(context.Context, *EnableWorkerRequest) (*emptypb.Empty, error)

+ func (UnimplementedServiceServer) ExecTask(context.Context, *ExecTaskRequest) (*emptypb.Empty, error)

+ func (UnimplementedServiceServer) GetLog(context.Context, *GetLogRequest) (*Log, error)

+ func (UnimplementedServiceServer) PageLog(context.Context, *PageLogRequest) (*PageLogReply, error)

+ func (UnimplementedServiceServer) PageTask(context.Context, *PageTaskRequest) (*PageTaskReply, error)

+ func (UnimplementedServiceServer) PageWorker(context.Context, *PageWorkerRequest) (*PageWorkerReply, error)

+ func (UnimplementedServiceServer) UpdateTask(context.Context, *UpdateTaskRequest) (*emptypb.Empty, error)

+ func (UnimplementedServiceServer) UpdateTaskGroup(context.Context, *UpdateTaskGroupRequest) (*emptypb.Empty, error)

+ func (UnimplementedServiceServer) UpdateWorker(context.Context, *UpdateWorkerRequest) (*emptypb.Empty, error)

+ func (UnimplementedServiceServer) UpdateWorkerGroup(context.Context, *UpdateWorkerGroupRequest) (*emptypb.Empty, error)

+ type UnsafeServiceServer interface

+ type UpdateTaskGroupRequest struct

+ Description string

+ Id uint32

+ Name string

+ func (*UpdateTaskGroupRequest) Descriptor() ([]byte, []int)

+ func (*UpdateTaskGroupRequest) ProtoMessage()

+ func (m *UpdateTaskGroupRequest) Validate() error

+ func (m *UpdateTaskGroupRequest) ValidateAll() error

+ func (x *UpdateTaskGroupRequest) GetDescription() string

+ func (x *UpdateTaskGroupRequest) GetId() uint32

+ func (x *UpdateTaskGroupRequest) GetName() string

+ func (x *UpdateTaskGroupRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateTaskGroupRequest) Reset()

+ func (x *UpdateTaskGroupRequest) String() string

+ type UpdateTaskGroupRequestMultiError []error

+ func (m UpdateTaskGroupRequestMultiError) AllErrors() []error

+ func (m UpdateTaskGroupRequestMultiError) Error() string

+ type UpdateTaskGroupRequestValidationError struct

+ func (e UpdateTaskGroupRequestValidationError) Cause() error

+ func (e UpdateTaskGroupRequestValidationError) Error() string

+ func (e UpdateTaskGroupRequestValidationError) ErrorName() string

+ func (e UpdateTaskGroupRequestValidationError) Field() string

+ func (e UpdateTaskGroupRequestValidationError) Key() bool

+ func (e UpdateTaskGroupRequestValidationError) Reason() string

+ type UpdateTaskRequest struct

+ Description string

+ ExecType string

+ ExecValue string

+ ExpectCode uint32

+ GroupId uint32

+ Id uint32

+ MaxExecTime uint32

+ Name string

+ RetryCount uint32

+ RetryWaitTime uint32

+ SelectType string

+ Spec string

+ Tag string

+ WorkerGroupId *uint32

+ WorkerId *uint32

+ func (*UpdateTaskRequest) Descriptor() ([]byte, []int)

+ func (*UpdateTaskRequest) ProtoMessage()

+ func (m *UpdateTaskRequest) Validate() error

+ func (m *UpdateTaskRequest) ValidateAll() error

+ func (x *UpdateTaskRequest) GetDescription() string

+ func (x *UpdateTaskRequest) GetExecType() string

+ func (x *UpdateTaskRequest) GetExecValue() string

+ func (x *UpdateTaskRequest) GetExpectCode() uint32

+ func (x *UpdateTaskRequest) GetGroupId() uint32

+ func (x *UpdateTaskRequest) GetId() uint32

+ func (x *UpdateTaskRequest) GetMaxExecTime() uint32

+ func (x *UpdateTaskRequest) GetName() string

+ func (x *UpdateTaskRequest) GetRetryCount() uint32

+ func (x *UpdateTaskRequest) GetRetryWaitTime() uint32

+ func (x *UpdateTaskRequest) GetSelectType() string

+ func (x *UpdateTaskRequest) GetSpec() string

+ func (x *UpdateTaskRequest) GetTag() string

+ func (x *UpdateTaskRequest) GetWorkerGroupId() uint32

+ func (x *UpdateTaskRequest) GetWorkerId() uint32

+ func (x *UpdateTaskRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateTaskRequest) Reset()

+ func (x *UpdateTaskRequest) String() string

+ type UpdateTaskRequestMultiError []error

+ func (m UpdateTaskRequestMultiError) AllErrors() []error

+ func (m UpdateTaskRequestMultiError) Error() string

+ type UpdateTaskRequestValidationError struct

+ func (e UpdateTaskRequestValidationError) Cause() error

+ func (e UpdateTaskRequestValidationError) Error() string

+ func (e UpdateTaskRequestValidationError) ErrorName() string

+ func (e UpdateTaskRequestValidationError) Field() string

+ func (e UpdateTaskRequestValidationError) Key() bool

+ func (e UpdateTaskRequestValidationError) Reason() string

+ type UpdateWorkerGroupRequest struct

+ Description string

+ Id uint32

+ Name string

+ func (*UpdateWorkerGroupRequest) Descriptor() ([]byte, []int)

+ func (*UpdateWorkerGroupRequest) ProtoMessage()

+ func (m *UpdateWorkerGroupRequest) Validate() error

+ func (m *UpdateWorkerGroupRequest) ValidateAll() error

+ func (x *UpdateWorkerGroupRequest) GetDescription() string

+ func (x *UpdateWorkerGroupRequest) GetId() uint32

+ func (x *UpdateWorkerGroupRequest) GetName() string

+ func (x *UpdateWorkerGroupRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateWorkerGroupRequest) Reset()

+ func (x *UpdateWorkerGroupRequest) String() string

+ type UpdateWorkerGroupRequestMultiError []error

+ func (m UpdateWorkerGroupRequestMultiError) AllErrors() []error

+ func (m UpdateWorkerGroupRequestMultiError) Error() string

+ type UpdateWorkerGroupRequestValidationError struct

+ func (e UpdateWorkerGroupRequestValidationError) Cause() error

+ func (e UpdateWorkerGroupRequestValidationError) Error() string

+ func (e UpdateWorkerGroupRequestValidationError) ErrorName() string

+ func (e UpdateWorkerGroupRequestValidationError) Field() string

+ func (e UpdateWorkerGroupRequestValidationError) Key() bool

+ func (e UpdateWorkerGroupRequestValidationError) Reason() string

+ type UpdateWorkerRequest struct

+ Description string

+ GroupId *uint32

+ Id uint32

+ Ip string

+ Name string

+ func (*UpdateWorkerRequest) Descriptor() ([]byte, []int)

+ func (*UpdateWorkerRequest) ProtoMessage()

+ func (m *UpdateWorkerRequest) Validate() error

+ func (m *UpdateWorkerRequest) ValidateAll() error

+ func (x *UpdateWorkerRequest) GetDescription() string

+ func (x *UpdateWorkerRequest) GetGroupId() uint32

+ func (x *UpdateWorkerRequest) GetId() uint32

+ func (x *UpdateWorkerRequest) GetIp() string

+ func (x *UpdateWorkerRequest) GetName() string

+ func (x *UpdateWorkerRequest) ProtoReflect() protoreflect.Message

+ func (x *UpdateWorkerRequest) Reset()

+ func (x *UpdateWorkerRequest) String() string

+ type UpdateWorkerRequestMultiError []error

+ func (m UpdateWorkerRequestMultiError) AllErrors() []error

+ func (m UpdateWorkerRequestMultiError) Error() string

+ type UpdateWorkerRequestValidationError struct

+ func (e UpdateWorkerRequestValidationError) Cause() error

+ func (e UpdateWorkerRequestValidationError) Error() string

+ func (e UpdateWorkerRequestValidationError) ErrorName() string

+ func (e UpdateWorkerRequestValidationError) Field() string

+ func (e UpdateWorkerRequestValidationError) Key() bool

+ func (e UpdateWorkerRequestValidationError) Reason() string

+ type Worker struct

+ CreatedAt uint32

+ Description string

+ Group *WorkerGroup

+ GroupId *uint32

+ Id uint32

+ Ip string

+ Name string

+ Status bool

+ UpdatedAt uint32

+ func (*Worker) Descriptor() ([]byte, []int)

+ func (*Worker) ProtoMessage()

+ func (m *Worker) Validate() error

+ func (m *Worker) ValidateAll() error

+ func (x *Worker) GetCreatedAt() uint32

+ func (x *Worker) GetDescription() string

+ func (x *Worker) GetGroup() *WorkerGroup

+ func (x *Worker) GetGroupId() uint32

+ func (x *Worker) GetId() uint32

+ func (x *Worker) GetIp() string

+ func (x *Worker) GetName() string

+ func (x *Worker) GetStatus() bool

+ func (x *Worker) GetUpdatedAt() uint32

+ func (x *Worker) ProtoReflect() protoreflect.Message

+ func (x *Worker) Reset()

+ func (x *Worker) String() string

+ type WorkerGroup struct

+ CreatedAt uint32

+ Description string

+ Id uint32

+ Name string

+ UpdatedAt uint32

+ func (*WorkerGroup) Descriptor() ([]byte, []int)

+ func (*WorkerGroup) ProtoMessage()

+ func (m *WorkerGroup) Validate() error

+ func (m *WorkerGroup) ValidateAll() error

+ func (x *WorkerGroup) GetCreatedAt() uint32

+ func (x *WorkerGroup) GetDescription() string

+ func (x *WorkerGroup) GetId() uint32

+ func (x *WorkerGroup) GetName() string

+ func (x *WorkerGroup) GetUpdatedAt() uint32

+ func (x *WorkerGroup) ProtoReflect() protoreflect.Message

+ func (x *WorkerGroup) Reset()

+ func (x *WorkerGroup) String() string

+ type WorkerGroupMultiError []error

+ func (m WorkerGroupMultiError) AllErrors() []error

+ func (m WorkerGroupMultiError) Error() string

+ type WorkerGroupValidationError struct

+ func (e WorkerGroupValidationError) Cause() error

+ func (e WorkerGroupValidationError) Error() string

+ func (e WorkerGroupValidationError) ErrorName() string

+ func (e WorkerGroupValidationError) Field() string

+ func (e WorkerGroupValidationError) Key() bool

+ func (e WorkerGroupValidationError) Reason() string

+ type WorkerMultiError []error

+ func (m WorkerMultiError) AllErrors() []error

+ func (m WorkerMultiError) Error() string

+ type WorkerValidationError struct

+ func (e WorkerValidationError) Cause() error

+ func (e WorkerValidationError) Error() string

+ func (e WorkerValidationError) ErrorName() string

+ func (e WorkerValidationError) Field() string

+ func (e WorkerValidationError) Key() bool

+ func (e WorkerValidationError) Reason() string