v1

package
v1.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 18, 2024 License: MIT Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source
const (
	Service_AllWorkerGroup_FullMethodName    = "/cron_server.Service/AllWorkerGroup"
	Service_AddWorkerGroup_FullMethodName    = "/cron_server.Service/AddWorkerGroup"
	Service_UpdateWorkerGroup_FullMethodName = "/cron_server.Service/UpdateWorkerGroup"
	Service_DeleteWorkerGroup_FullMethodName = "/cron_server.Service/DeleteWorkerGroup"
	Service_PageWorker_FullMethodName        = "/cron_server.Service/PageWorker"
	Service_AddWorker_FullMethodName         = "/cron_server.Service/AddWorker"
	Service_UpdateWorker_FullMethodName      = "/cron_server.Service/UpdateWorker"
	Service_EnableWorker_FullMethodName      = "/cron_server.Service/EnableWorker"
	Service_DisableWorker_FullMethodName     = "/cron_server.Service/DisableWorker"
	Service_DeleteWorker_FullMethodName      = "/cron_server.Service/DeleteWorker"
	Service_AllTaskGroup_FullMethodName      = "/cron_server.Service/AllTaskGroup"
	Service_AddTaskGroup_FullMethodName      = "/cron_server.Service/AddTaskGroup"
	Service_UpdateTaskGroup_FullMethodName   = "/cron_server.Service/UpdateTaskGroup"
	Service_DeleteTaskGroup_FullMethodName   = "/cron_server.Service/DeleteTaskGroup"
	Service_PageTask_FullMethodName          = "/cron_server.Service/PageTask"
	Service_AddTask_FullMethodName           = "/cron_server.Service/AddTask"
	Service_UpdateTask_FullMethodName        = "/cron_server.Service/UpdateTask"
	Service_EnableTask_FullMethodName        = "/cron_server.Service/EnableTask"
	Service_DisableTask_FullMethodName       = "/cron_server.Service/DisableTask"
	Service_DeleteTask_FullMethodName        = "/cron_server.Service/DeleteTask"
	Service_ExecTask_FullMethodName          = "/cron_server.Service/ExecTask"
	Service_CancelExecTask_FullMethodName    = "/cron_server.Service/CancelExecTask"
	Service_PageLog_FullMethodName           = "/cron_server.Service/PageLog"
	Service_GetLog_FullMethodName            = "/cron_server.Service/GetLog"
)
View Source
const OperationServiceAddTask = "/cron_server.Service/AddTask"
View Source
const OperationServiceAddTaskGroup = "/cron_server.Service/AddTaskGroup"
View Source
const OperationServiceAddWorker = "/cron_server.Service/AddWorker"
View Source
const OperationServiceAddWorkerGroup = "/cron_server.Service/AddWorkerGroup"
View Source
const OperationServiceAllTaskGroup = "/cron_server.Service/AllTaskGroup"
View Source
const OperationServiceAllWorkerGroup = "/cron_server.Service/AllWorkerGroup"
View Source
const OperationServiceCancelExecTask = "/cron_server.Service/CancelExecTask"
View Source
const OperationServiceDeleteTask = "/cron_server.Service/DeleteTask"
View Source
const OperationServiceDeleteTaskGroup = "/cron_server.Service/DeleteTaskGroup"
View Source
const OperationServiceDeleteWorker = "/cron_server.Service/DeleteWorker"
View Source
const OperationServiceDeleteWorkerGroup = "/cron_server.Service/DeleteWorkerGroup"
View Source
const OperationServiceDisableTask = "/cron_server.Service/DisableTask"
View Source
const OperationServiceDisableWorker = "/cron_server.Service/DisableWorker"
View Source
const OperationServiceEnableTask = "/cron_server.Service/EnableTask"
View Source
const OperationServiceEnableWorker = "/cron_server.Service/EnableWorker"
View Source
const OperationServiceExecTask = "/cron_server.Service/ExecTask"
View Source
const OperationServiceGetLog = "/cron_server.Service/GetLog"
View Source
const OperationServicePageLog = "/cron_server.Service/PageLog"
View Source
const OperationServicePageTask = "/cron_server.Service/PageTask"
View Source
const OperationServicePageWorker = "/cron_server.Service/PageWorker"
View Source
const OperationServiceUpdateTask = "/cron_server.Service/UpdateTask"
View Source
const OperationServiceUpdateTaskGroup = "/cron_server.Service/UpdateTaskGroup"
View Source
const OperationServiceUpdateWorker = "/cron_server.Service/UpdateWorker"
View Source
const OperationServiceUpdateWorkerGroup = "/cron_server.Service/UpdateWorkerGroup"

Variables

View Source
var File_cron_server_log_proto protoreflect.FileDescriptor
View Source
var File_cron_server_service_proto protoreflect.FileDescriptor
View Source
var File_cron_server_task_proto protoreflect.FileDescriptor
View Source
var File_cron_server_worker_proto protoreflect.FileDescriptor
View Source
var Service_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cron_server.Service",
	HandlerType: (*ServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "AllWorkerGroup",
			Handler:    _Service_AllWorkerGroup_Handler,
		},
		{
			MethodName: "AddWorkerGroup",
			Handler:    _Service_AddWorkerGroup_Handler,
		},
		{
			MethodName: "UpdateWorkerGroup",
			Handler:    _Service_UpdateWorkerGroup_Handler,
		},
		{
			MethodName: "DeleteWorkerGroup",
			Handler:    _Service_DeleteWorkerGroup_Handler,
		},
		{
			MethodName: "PageWorker",
			Handler:    _Service_PageWorker_Handler,
		},
		{
			MethodName: "AddWorker",
			Handler:    _Service_AddWorker_Handler,
		},
		{
			MethodName: "UpdateWorker",
			Handler:    _Service_UpdateWorker_Handler,
		},
		{
			MethodName: "EnableWorker",
			Handler:    _Service_EnableWorker_Handler,
		},
		{
			MethodName: "DisableWorker",
			Handler:    _Service_DisableWorker_Handler,
		},
		{
			MethodName: "DeleteWorker",
			Handler:    _Service_DeleteWorker_Handler,
		},
		{
			MethodName: "AllTaskGroup",
			Handler:    _Service_AllTaskGroup_Handler,
		},
		{
			MethodName: "AddTaskGroup",
			Handler:    _Service_AddTaskGroup_Handler,
		},
		{
			MethodName: "UpdateTaskGroup",
			Handler:    _Service_UpdateTaskGroup_Handler,
		},
		{
			MethodName: "DeleteTaskGroup",
			Handler:    _Service_DeleteTaskGroup_Handler,
		},
		{
			MethodName: "PageTask",
			Handler:    _Service_PageTask_Handler,
		},
		{
			MethodName: "AddTask",
			Handler:    _Service_AddTask_Handler,
		},
		{
			MethodName: "UpdateTask",
			Handler:    _Service_UpdateTask_Handler,
		},
		{
			MethodName: "EnableTask",
			Handler:    _Service_EnableTask_Handler,
		},
		{
			MethodName: "DisableTask",
			Handler:    _Service_DisableTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _Service_DeleteTask_Handler,
		},
		{
			MethodName: "ExecTask",
			Handler:    _Service_ExecTask_Handler,
		},
		{
			MethodName: "CancelExecTask",
			Handler:    _Service_CancelExecTask_Handler,
		},
		{
			MethodName: "PageLog",
			Handler:    _Service_PageLog_Handler,
		},
		{
			MethodName: "GetLog",
			Handler:    _Service_GetLog_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cron_server_service.proto",
}

Service_ServiceDesc is the grpc.ServiceDesc for Service service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterServiceHTTPServer

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

func RegisterServiceServer

func RegisterServiceServer(s grpc.ServiceRegistrar, srv ServiceServer)

Types

type AddTaskGroupReply

type AddTaskGroupReply struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTaskGroupReply) Descriptor deprecated

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

Deprecated: Use AddTaskGroupReply.ProtoReflect.Descriptor instead.

func (*AddTaskGroupReply) GetId

func (x *AddTaskGroupReply) GetId() uint32

func (*AddTaskGroupReply) ProtoMessage

func (*AddTaskGroupReply) ProtoMessage()

func (*AddTaskGroupReply) ProtoReflect

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

func (*AddTaskGroupReply) Reset

func (x *AddTaskGroupReply) Reset()

func (*AddTaskGroupReply) String

func (x *AddTaskGroupReply) String() string

func (*AddTaskGroupReply) Validate

func (m *AddTaskGroupReply) Validate() error

Validate checks the field values on AddTaskGroupReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddTaskGroupReply) ValidateAll

func (m *AddTaskGroupReply) ValidateAll() error

ValidateAll checks the field values on AddTaskGroupReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddTaskGroupReplyMultiError, or nil if none found.

type AddTaskGroupReplyMultiError

type AddTaskGroupReplyMultiError []error

AddTaskGroupReplyMultiError is an error wrapping multiple validation errors returned by AddTaskGroupReply.ValidateAll() if the designated constraints aren't met.

func (AddTaskGroupReplyMultiError) AllErrors

func (m AddTaskGroupReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddTaskGroupReplyMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type AddTaskGroupReplyValidationError

type AddTaskGroupReplyValidationError struct {
	// contains filtered or unexported fields
}

AddTaskGroupReplyValidationError is the validation error returned by AddTaskGroupReply.Validate if the designated constraints aren't met.

func (AddTaskGroupReplyValidationError) Cause

Cause function returns cause value.

func (AddTaskGroupReplyValidationError) Error

Error satisfies the builtin error interface

func (AddTaskGroupReplyValidationError) ErrorName

ErrorName returns error name.

func (AddTaskGroupReplyValidationError) Field

Field function returns field value.

func (AddTaskGroupReplyValidationError) Key

Key function returns key value.

func (AddTaskGroupReplyValidationError) Reason

Reason function returns reason value.

type AddTaskGroupRequest

type AddTaskGroupRequest struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTaskGroupRequest) Descriptor deprecated

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

Deprecated: Use AddTaskGroupRequest.ProtoReflect.Descriptor instead.

func (*AddTaskGroupRequest) GetDescription

func (x *AddTaskGroupRequest) GetDescription() string

func (*AddTaskGroupRequest) GetName

func (x *AddTaskGroupRequest) GetName() string

func (*AddTaskGroupRequest) ProtoMessage

func (*AddTaskGroupRequest) ProtoMessage()

func (*AddTaskGroupRequest) ProtoReflect

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

func (*AddTaskGroupRequest) Reset

func (x *AddTaskGroupRequest) Reset()

func (*AddTaskGroupRequest) String

func (x *AddTaskGroupRequest) String() string

func (*AddTaskGroupRequest) Validate

func (m *AddTaskGroupRequest) Validate() error

Validate checks the field values on AddTaskGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddTaskGroupRequest) ValidateAll

func (m *AddTaskGroupRequest) ValidateAll() error

ValidateAll checks the field values on AddTaskGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddTaskGroupRequestMultiError, or nil if none found.

type AddTaskGroupRequestMultiError

type AddTaskGroupRequestMultiError []error

AddTaskGroupRequestMultiError is an error wrapping multiple validation errors returned by AddTaskGroupRequest.ValidateAll() if the designated constraints aren't met.

func (AddTaskGroupRequestMultiError) AllErrors

func (m AddTaskGroupRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddTaskGroupRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type AddTaskGroupRequestValidationError

type AddTaskGroupRequestValidationError struct {
	// contains filtered or unexported fields
}

AddTaskGroupRequestValidationError is the validation error returned by AddTaskGroupRequest.Validate if the designated constraints aren't met.

func (AddTaskGroupRequestValidationError) Cause

Cause function returns cause value.

func (AddTaskGroupRequestValidationError) Error

Error satisfies the builtin error interface

func (AddTaskGroupRequestValidationError) ErrorName

ErrorName returns error name.

func (AddTaskGroupRequestValidationError) Field

Field function returns field value.

func (AddTaskGroupRequestValidationError) Key

Key function returns key value.

func (AddTaskGroupRequestValidationError) Reason

Reason function returns reason value.

type AddTaskReply

type AddTaskReply struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTaskReply) Descriptor deprecated

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

Deprecated: Use AddTaskReply.ProtoReflect.Descriptor instead.

func (*AddTaskReply) GetId

func (x *AddTaskReply) GetId() uint32

func (*AddTaskReply) ProtoMessage

func (*AddTaskReply) ProtoMessage()

func (*AddTaskReply) ProtoReflect

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

func (*AddTaskReply) Reset

func (x *AddTaskReply) Reset()

func (*AddTaskReply) String

func (x *AddTaskReply) String() string

func (*AddTaskReply) Validate

func (m *AddTaskReply) Validate() error

Validate checks the field values on AddTaskReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddTaskReply) ValidateAll

func (m *AddTaskReply) ValidateAll() error

ValidateAll checks the field values on AddTaskReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddTaskReplyMultiError, or nil if none found.

type AddTaskReplyMultiError

type AddTaskReplyMultiError []error

AddTaskReplyMultiError is an error wrapping multiple validation errors returned by AddTaskReply.ValidateAll() if the designated constraints aren't met.

func (AddTaskReplyMultiError) AllErrors

func (m AddTaskReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddTaskReplyMultiError) Error

func (m AddTaskReplyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AddTaskReplyValidationError

type AddTaskReplyValidationError struct {
	// contains filtered or unexported fields
}

AddTaskReplyValidationError is the validation error returned by AddTaskReply.Validate if the designated constraints aren't met.

func (AddTaskReplyValidationError) Cause

Cause function returns cause value.

func (AddTaskReplyValidationError) Error

Error satisfies the builtin error interface

func (AddTaskReplyValidationError) ErrorName

func (e AddTaskReplyValidationError) ErrorName() string

ErrorName returns error name.

func (AddTaskReplyValidationError) Field

Field function returns field value.

func (AddTaskReplyValidationError) Key

Key function returns key value.

func (AddTaskReplyValidationError) Reason

Reason function returns reason value.

type AddTaskRequest

type AddTaskRequest struct {
	GroupId       uint32  `protobuf:"varint,1,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Name          string  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Tag           string  `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"`
	Spec          string  `protobuf:"bytes,4,opt,name=spec,proto3" json:"spec,omitempty"`
	SelectType    string  `protobuf:"bytes,5,opt,name=select_type,json=selectType,proto3" json:"select_type,omitempty"`
	WorkerGroupId *uint32 `protobuf:"varint,6,opt,name=worker_group_id,json=workerGroupId,proto3,oneof" json:"worker_group_id,omitempty"`
	WorkerId      *uint32 `protobuf:"varint,7,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
	ExecType      string  `protobuf:"bytes,8,opt,name=exec_type,json=execType,proto3" json:"exec_type,omitempty"`
	ExecValue     string  `protobuf:"bytes,9,opt,name=exec_value,json=execValue,proto3" json:"exec_value,omitempty"`
	ExpectCode    *uint32 `protobuf:"varint,10,opt,name=expect_code,json=expectCode,proto3,oneof" json:"expect_code,omitempty"`
	RetryCount    *uint32 `protobuf:"varint,11,opt,name=retry_count,json=retryCount,proto3,oneof" json:"retry_count,omitempty"`
	RetryWaitTime *uint32 `protobuf:"varint,12,opt,name=retry_wait_time,json=retryWaitTime,proto3,oneof" json:"retry_wait_time,omitempty"`
	MaxExecTime   *uint32 `protobuf:"varint,13,opt,name=max_exec_time,json=maxExecTime,proto3,oneof" json:"max_exec_time,omitempty"`
	Description   string  `protobuf:"bytes,14,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTaskRequest) Descriptor deprecated

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

Deprecated: Use AddTaskRequest.ProtoReflect.Descriptor instead.

func (*AddTaskRequest) GetDescription

func (x *AddTaskRequest) GetDescription() string

func (*AddTaskRequest) GetExecType

func (x *AddTaskRequest) GetExecType() string

func (*AddTaskRequest) GetExecValue

func (x *AddTaskRequest) GetExecValue() string

func (*AddTaskRequest) GetExpectCode

func (x *AddTaskRequest) GetExpectCode() uint32

func (*AddTaskRequest) GetGroupId

func (x *AddTaskRequest) GetGroupId() uint32

func (*AddTaskRequest) GetMaxExecTime

func (x *AddTaskRequest) GetMaxExecTime() uint32

func (*AddTaskRequest) GetName

func (x *AddTaskRequest) GetName() string

func (*AddTaskRequest) GetRetryCount

func (x *AddTaskRequest) GetRetryCount() uint32

func (*AddTaskRequest) GetRetryWaitTime

func (x *AddTaskRequest) GetRetryWaitTime() uint32

func (*AddTaskRequest) GetSelectType

func (x *AddTaskRequest) GetSelectType() string

func (*AddTaskRequest) GetSpec

func (x *AddTaskRequest) GetSpec() string

func (*AddTaskRequest) GetTag

func (x *AddTaskRequest) GetTag() string

func (*AddTaskRequest) GetWorkerGroupId

func (x *AddTaskRequest) GetWorkerGroupId() uint32

func (*AddTaskRequest) GetWorkerId

func (x *AddTaskRequest) GetWorkerId() uint32

func (*AddTaskRequest) ProtoMessage

func (*AddTaskRequest) ProtoMessage()

func (*AddTaskRequest) ProtoReflect

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

func (*AddTaskRequest) Reset

func (x *AddTaskRequest) Reset()

func (*AddTaskRequest) String

func (x *AddTaskRequest) String() string

func (*AddTaskRequest) Validate

func (m *AddTaskRequest) Validate() error

Validate checks the field values on AddTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddTaskRequest) ValidateAll

func (m *AddTaskRequest) ValidateAll() error

ValidateAll checks the field values on AddTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddTaskRequestMultiError, or nil if none found.

type AddTaskRequestMultiError

type AddTaskRequestMultiError []error

AddTaskRequestMultiError is an error wrapping multiple validation errors returned by AddTaskRequest.ValidateAll() if the designated constraints aren't met.

func (AddTaskRequestMultiError) AllErrors

func (m AddTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddTaskRequestMultiError) Error

func (m AddTaskRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AddTaskRequestValidationError

type AddTaskRequestValidationError struct {
	// contains filtered or unexported fields
}

AddTaskRequestValidationError is the validation error returned by AddTaskRequest.Validate if the designated constraints aren't met.

func (AddTaskRequestValidationError) Cause

Cause function returns cause value.

func (AddTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (AddTaskRequestValidationError) ErrorName

func (e AddTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (AddTaskRequestValidationError) Field

Field function returns field value.

func (AddTaskRequestValidationError) Key

Key function returns key value.

func (AddTaskRequestValidationError) Reason

Reason function returns reason value.

type AddWorkerGroupReply

type AddWorkerGroupReply struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddWorkerGroupReply) Descriptor deprecated

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

Deprecated: Use AddWorkerGroupReply.ProtoReflect.Descriptor instead.

func (*AddWorkerGroupReply) GetId

func (x *AddWorkerGroupReply) GetId() uint32

func (*AddWorkerGroupReply) ProtoMessage

func (*AddWorkerGroupReply) ProtoMessage()

func (*AddWorkerGroupReply) ProtoReflect

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

func (*AddWorkerGroupReply) Reset

func (x *AddWorkerGroupReply) Reset()

func (*AddWorkerGroupReply) String

func (x *AddWorkerGroupReply) String() string

func (*AddWorkerGroupReply) Validate

func (m *AddWorkerGroupReply) Validate() error

Validate checks the field values on AddWorkerGroupReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddWorkerGroupReply) ValidateAll

func (m *AddWorkerGroupReply) ValidateAll() error

ValidateAll checks the field values on AddWorkerGroupReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddWorkerGroupReplyMultiError, or nil if none found.

type AddWorkerGroupReplyMultiError

type AddWorkerGroupReplyMultiError []error

AddWorkerGroupReplyMultiError is an error wrapping multiple validation errors returned by AddWorkerGroupReply.ValidateAll() if the designated constraints aren't met.

func (AddWorkerGroupReplyMultiError) AllErrors

func (m AddWorkerGroupReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddWorkerGroupReplyMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type AddWorkerGroupReplyValidationError

type AddWorkerGroupReplyValidationError struct {
	// contains filtered or unexported fields
}

AddWorkerGroupReplyValidationError is the validation error returned by AddWorkerGroupReply.Validate if the designated constraints aren't met.

func (AddWorkerGroupReplyValidationError) Cause

Cause function returns cause value.

func (AddWorkerGroupReplyValidationError) Error

Error satisfies the builtin error interface

func (AddWorkerGroupReplyValidationError) ErrorName

ErrorName returns error name.

func (AddWorkerGroupReplyValidationError) Field

Field function returns field value.

func (AddWorkerGroupReplyValidationError) Key

Key function returns key value.

func (AddWorkerGroupReplyValidationError) Reason

Reason function returns reason value.

type AddWorkerGroupRequest

type AddWorkerGroupRequest struct {
	Name        string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*AddWorkerGroupRequest) Descriptor deprecated

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

Deprecated: Use AddWorkerGroupRequest.ProtoReflect.Descriptor instead.

func (*AddWorkerGroupRequest) GetDescription

func (x *AddWorkerGroupRequest) GetDescription() string

func (*AddWorkerGroupRequest) GetName

func (x *AddWorkerGroupRequest) GetName() string

func (*AddWorkerGroupRequest) ProtoMessage

func (*AddWorkerGroupRequest) ProtoMessage()

func (*AddWorkerGroupRequest) ProtoReflect

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

func (*AddWorkerGroupRequest) Reset

func (x *AddWorkerGroupRequest) Reset()

func (*AddWorkerGroupRequest) String

func (x *AddWorkerGroupRequest) String() string

func (*AddWorkerGroupRequest) Validate

func (m *AddWorkerGroupRequest) Validate() error

Validate checks the field values on AddWorkerGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddWorkerGroupRequest) ValidateAll

func (m *AddWorkerGroupRequest) ValidateAll() error

ValidateAll checks the field values on AddWorkerGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddWorkerGroupRequestMultiError, or nil if none found.

type AddWorkerGroupRequestMultiError

type AddWorkerGroupRequestMultiError []error

AddWorkerGroupRequestMultiError is an error wrapping multiple validation errors returned by AddWorkerGroupRequest.ValidateAll() if the designated constraints aren't met.

func (AddWorkerGroupRequestMultiError) AllErrors

func (m AddWorkerGroupRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddWorkerGroupRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type AddWorkerGroupRequestValidationError

type AddWorkerGroupRequestValidationError struct {
	// contains filtered or unexported fields
}

AddWorkerGroupRequestValidationError is the validation error returned by AddWorkerGroupRequest.Validate if the designated constraints aren't met.

func (AddWorkerGroupRequestValidationError) Cause

Cause function returns cause value.

func (AddWorkerGroupRequestValidationError) Error

Error satisfies the builtin error interface

func (AddWorkerGroupRequestValidationError) ErrorName

ErrorName returns error name.

func (AddWorkerGroupRequestValidationError) Field

Field function returns field value.

func (AddWorkerGroupRequestValidationError) Key

Key function returns key value.

func (AddWorkerGroupRequestValidationError) Reason

Reason function returns reason value.

type AddWorkerReply

type AddWorkerReply struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*AddWorkerReply) Descriptor deprecated

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

Deprecated: Use AddWorkerReply.ProtoReflect.Descriptor instead.

func (*AddWorkerReply) GetId

func (x *AddWorkerReply) GetId() uint32

func (*AddWorkerReply) ProtoMessage

func (*AddWorkerReply) ProtoMessage()

func (*AddWorkerReply) ProtoReflect

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

func (*AddWorkerReply) Reset

func (x *AddWorkerReply) Reset()

func (*AddWorkerReply) String

func (x *AddWorkerReply) String() string

func (*AddWorkerReply) Validate

func (m *AddWorkerReply) Validate() error

Validate checks the field values on AddWorkerReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddWorkerReply) ValidateAll

func (m *AddWorkerReply) ValidateAll() error

ValidateAll checks the field values on AddWorkerReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddWorkerReplyMultiError, or nil if none found.

type AddWorkerReplyMultiError

type AddWorkerReplyMultiError []error

AddWorkerReplyMultiError is an error wrapping multiple validation errors returned by AddWorkerReply.ValidateAll() if the designated constraints aren't met.

func (AddWorkerReplyMultiError) AllErrors

func (m AddWorkerReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddWorkerReplyMultiError) Error

func (m AddWorkerReplyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type AddWorkerReplyValidationError

type AddWorkerReplyValidationError struct {
	// contains filtered or unexported fields
}

AddWorkerReplyValidationError is the validation error returned by AddWorkerReply.Validate if the designated constraints aren't met.

func (AddWorkerReplyValidationError) Cause

Cause function returns cause value.

func (AddWorkerReplyValidationError) Error

Error satisfies the builtin error interface

func (AddWorkerReplyValidationError) ErrorName

func (e AddWorkerReplyValidationError) ErrorName() string

ErrorName returns error name.

func (AddWorkerReplyValidationError) Field

Field function returns field value.

func (AddWorkerReplyValidationError) Key

Key function returns key value.

func (AddWorkerReplyValidationError) Reason

Reason function returns reason value.

type AddWorkerRequest

type AddWorkerRequest struct {
	Name        string  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Ip          string  `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	GroupId     *uint32 `protobuf:"varint,3,opt,name=group_id,json=groupId,proto3,oneof" json:"group_id,omitempty"`
	Description string  `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*AddWorkerRequest) Descriptor deprecated

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

Deprecated: Use AddWorkerRequest.ProtoReflect.Descriptor instead.

func (*AddWorkerRequest) GetDescription

func (x *AddWorkerRequest) GetDescription() string

func (*AddWorkerRequest) GetGroupId

func (x *AddWorkerRequest) GetGroupId() uint32

func (*AddWorkerRequest) GetIp

func (x *AddWorkerRequest) GetIp() string

func (*AddWorkerRequest) GetName

func (x *AddWorkerRequest) GetName() string

func (*AddWorkerRequest) ProtoMessage

func (*AddWorkerRequest) ProtoMessage()

func (*AddWorkerRequest) ProtoReflect

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

func (*AddWorkerRequest) Reset

func (x *AddWorkerRequest) Reset()

func (*AddWorkerRequest) String

func (x *AddWorkerRequest) String() string

func (*AddWorkerRequest) Validate

func (m *AddWorkerRequest) Validate() error

Validate checks the field values on AddWorkerRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AddWorkerRequest) ValidateAll

func (m *AddWorkerRequest) ValidateAll() error

ValidateAll checks the field values on AddWorkerRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AddWorkerRequestMultiError, or nil if none found.

type AddWorkerRequestMultiError

type AddWorkerRequestMultiError []error

AddWorkerRequestMultiError is an error wrapping multiple validation errors returned by AddWorkerRequest.ValidateAll() if the designated constraints aren't met.

func (AddWorkerRequestMultiError) AllErrors

func (m AddWorkerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AddWorkerRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type AddWorkerRequestValidationError

type AddWorkerRequestValidationError struct {
	// contains filtered or unexported fields
}

AddWorkerRequestValidationError is the validation error returned by AddWorkerRequest.Validate if the designated constraints aren't met.

func (AddWorkerRequestValidationError) Cause

Cause function returns cause value.

func (AddWorkerRequestValidationError) Error

Error satisfies the builtin error interface

func (AddWorkerRequestValidationError) ErrorName

ErrorName returns error name.

func (AddWorkerRequestValidationError) Field

Field function returns field value.

func (AddWorkerRequestValidationError) Key

Key function returns key value.

func (AddWorkerRequestValidationError) Reason

Reason function returns reason value.

type AllTaskGroupReply

type AllTaskGroupReply struct {
	List []*TaskGroup `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*AllTaskGroupReply) Descriptor deprecated

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

Deprecated: Use AllTaskGroupReply.ProtoReflect.Descriptor instead.

func (*AllTaskGroupReply) GetList

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

func (*AllTaskGroupReply) ProtoMessage

func (*AllTaskGroupReply) ProtoMessage()

func (*AllTaskGroupReply) ProtoReflect

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

func (*AllTaskGroupReply) Reset

func (x *AllTaskGroupReply) Reset()

func (*AllTaskGroupReply) String

func (x *AllTaskGroupReply) String() string

func (*AllTaskGroupReply) Validate

func (m *AllTaskGroupReply) Validate() error

Validate checks the field values on AllTaskGroupReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AllTaskGroupReply) ValidateAll

func (m *AllTaskGroupReply) ValidateAll() error

ValidateAll checks the field values on AllTaskGroupReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AllTaskGroupReplyMultiError, or nil if none found.

type AllTaskGroupReplyMultiError

type AllTaskGroupReplyMultiError []error

AllTaskGroupReplyMultiError is an error wrapping multiple validation errors returned by AllTaskGroupReply.ValidateAll() if the designated constraints aren't met.

func (AllTaskGroupReplyMultiError) AllErrors

func (m AllTaskGroupReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AllTaskGroupReplyMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type AllTaskGroupReplyValidationError

type AllTaskGroupReplyValidationError struct {
	// contains filtered or unexported fields
}

AllTaskGroupReplyValidationError is the validation error returned by AllTaskGroupReply.Validate if the designated constraints aren't met.

func (AllTaskGroupReplyValidationError) Cause

Cause function returns cause value.

func (AllTaskGroupReplyValidationError) Error

Error satisfies the builtin error interface

func (AllTaskGroupReplyValidationError) ErrorName

ErrorName returns error name.

func (AllTaskGroupReplyValidationError) Field

Field function returns field value.

func (AllTaskGroupReplyValidationError) Key

Key function returns key value.

func (AllTaskGroupReplyValidationError) Reason

Reason function returns reason value.

type AllWorkerGroupReply

type AllWorkerGroupReply struct {
	List []*WorkerGroup `protobuf:"bytes,1,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*AllWorkerGroupReply) Descriptor deprecated

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

Deprecated: Use AllWorkerGroupReply.ProtoReflect.Descriptor instead.

func (*AllWorkerGroupReply) GetList

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

func (*AllWorkerGroupReply) ProtoMessage

func (*AllWorkerGroupReply) ProtoMessage()

func (*AllWorkerGroupReply) ProtoReflect

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

func (*AllWorkerGroupReply) Reset

func (x *AllWorkerGroupReply) Reset()

func (*AllWorkerGroupReply) String

func (x *AllWorkerGroupReply) String() string

func (*AllWorkerGroupReply) Validate

func (m *AllWorkerGroupReply) Validate() error

Validate checks the field values on AllWorkerGroupReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*AllWorkerGroupReply) ValidateAll

func (m *AllWorkerGroupReply) ValidateAll() error

ValidateAll checks the field values on AllWorkerGroupReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AllWorkerGroupReplyMultiError, or nil if none found.

type AllWorkerGroupReplyMultiError

type AllWorkerGroupReplyMultiError []error

AllWorkerGroupReplyMultiError is an error wrapping multiple validation errors returned by AllWorkerGroupReply.ValidateAll() if the designated constraints aren't met.

func (AllWorkerGroupReplyMultiError) AllErrors

func (m AllWorkerGroupReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (AllWorkerGroupReplyMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type AllWorkerGroupReplyValidationError

type AllWorkerGroupReplyValidationError struct {
	// contains filtered or unexported fields
}

AllWorkerGroupReplyValidationError is the validation error returned by AllWorkerGroupReply.Validate if the designated constraints aren't met.

func (AllWorkerGroupReplyValidationError) Cause

Cause function returns cause value.

func (AllWorkerGroupReplyValidationError) Error

Error satisfies the builtin error interface

func (AllWorkerGroupReplyValidationError) ErrorName

ErrorName returns error name.

func (AllWorkerGroupReplyValidationError) Field

Field function returns field value.

func (AllWorkerGroupReplyValidationError) Key

Key function returns key value.

func (AllWorkerGroupReplyValidationError) Reason

Reason function returns reason value.

type CancelExecTaskRequest

type CancelExecTaskRequest struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelExecTaskRequest) Descriptor deprecated

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

Deprecated: Use CancelExecTaskRequest.ProtoReflect.Descriptor instead.

func (*CancelExecTaskRequest) GetUuid

func (x *CancelExecTaskRequest) GetUuid() string

func (*CancelExecTaskRequest) ProtoMessage

func (*CancelExecTaskRequest) ProtoMessage()

func (*CancelExecTaskRequest) ProtoReflect

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

func (*CancelExecTaskRequest) Reset

func (x *CancelExecTaskRequest) Reset()

func (*CancelExecTaskRequest) String

func (x *CancelExecTaskRequest) String() string

func (*CancelExecTaskRequest) Validate

func (m *CancelExecTaskRequest) Validate() error

Validate checks the field values on CancelExecTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*CancelExecTaskRequest) ValidateAll

func (m *CancelExecTaskRequest) ValidateAll() error

ValidateAll checks the field values on CancelExecTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CancelExecTaskRequestMultiError, or nil if none found.

type CancelExecTaskRequestMultiError

type CancelExecTaskRequestMultiError []error

CancelExecTaskRequestMultiError is an error wrapping multiple validation errors returned by CancelExecTaskRequest.ValidateAll() if the designated constraints aren't met.

func (CancelExecTaskRequestMultiError) AllErrors

func (m CancelExecTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (CancelExecTaskRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type CancelExecTaskRequestValidationError

type CancelExecTaskRequestValidationError struct {
	// contains filtered or unexported fields
}

CancelExecTaskRequestValidationError is the validation error returned by CancelExecTaskRequest.Validate if the designated constraints aren't met.

func (CancelExecTaskRequestValidationError) Cause

Cause function returns cause value.

func (CancelExecTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (CancelExecTaskRequestValidationError) ErrorName

ErrorName returns error name.

func (CancelExecTaskRequestValidationError) Field

Field function returns field value.

func (CancelExecTaskRequestValidationError) Key

Key function returns key value.

func (CancelExecTaskRequestValidationError) Reason

Reason function returns reason value.

type DeleteTaskGroupRequest

type DeleteTaskGroupRequest struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTaskGroupRequest) Descriptor deprecated

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

Deprecated: Use DeleteTaskGroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskGroupRequest) GetId

func (x *DeleteTaskGroupRequest) GetId() uint32

func (*DeleteTaskGroupRequest) ProtoMessage

func (*DeleteTaskGroupRequest) ProtoMessage()

func (*DeleteTaskGroupRequest) ProtoReflect

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

func (*DeleteTaskGroupRequest) Reset

func (x *DeleteTaskGroupRequest) Reset()

func (*DeleteTaskGroupRequest) String

func (x *DeleteTaskGroupRequest) String() string

func (*DeleteTaskGroupRequest) Validate

func (m *DeleteTaskGroupRequest) Validate() error

Validate checks the field values on DeleteTaskGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DeleteTaskGroupRequest) ValidateAll

func (m *DeleteTaskGroupRequest) ValidateAll() error

ValidateAll checks the field values on DeleteTaskGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteTaskGroupRequestMultiError, or nil if none found.

type DeleteTaskGroupRequestMultiError

type DeleteTaskGroupRequestMultiError []error

DeleteTaskGroupRequestMultiError is an error wrapping multiple validation errors returned by DeleteTaskGroupRequest.ValidateAll() if the designated constraints aren't met.

func (DeleteTaskGroupRequestMultiError) AllErrors

func (m DeleteTaskGroupRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteTaskGroupRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DeleteTaskGroupRequestValidationError

type DeleteTaskGroupRequestValidationError struct {
	// contains filtered or unexported fields
}

DeleteTaskGroupRequestValidationError is the validation error returned by DeleteTaskGroupRequest.Validate if the designated constraints aren't met.

func (DeleteTaskGroupRequestValidationError) Cause

Cause function returns cause value.

func (DeleteTaskGroupRequestValidationError) Error

Error satisfies the builtin error interface

func (DeleteTaskGroupRequestValidationError) ErrorName

ErrorName returns error name.

func (DeleteTaskGroupRequestValidationError) Field

Field function returns field value.

func (DeleteTaskGroupRequestValidationError) Key

Key function returns key value.

func (DeleteTaskGroupRequestValidationError) Reason

Reason function returns reason value.

type DeleteTaskRequest

type DeleteTaskRequest struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteTaskRequest) Descriptor deprecated

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

Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRequest) GetId

func (x *DeleteTaskRequest) GetId() uint32

func (*DeleteTaskRequest) ProtoMessage

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect

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

func (*DeleteTaskRequest) Reset

func (x *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String

func (x *DeleteTaskRequest) String() string

func (*DeleteTaskRequest) Validate

func (m *DeleteTaskRequest) Validate() error

Validate checks the field values on DeleteTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DeleteTaskRequest) ValidateAll

func (m *DeleteTaskRequest) ValidateAll() error

ValidateAll checks the field values on DeleteTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteTaskRequestMultiError, or nil if none found.

type DeleteTaskRequestMultiError

type DeleteTaskRequestMultiError []error

DeleteTaskRequestMultiError is an error wrapping multiple validation errors returned by DeleteTaskRequest.ValidateAll() if the designated constraints aren't met.

func (DeleteTaskRequestMultiError) AllErrors

func (m DeleteTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteTaskRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DeleteTaskRequestValidationError

type DeleteTaskRequestValidationError struct {
	// contains filtered or unexported fields
}

DeleteTaskRequestValidationError is the validation error returned by DeleteTaskRequest.Validate if the designated constraints aren't met.

func (DeleteTaskRequestValidationError) Cause

Cause function returns cause value.

func (DeleteTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (DeleteTaskRequestValidationError) ErrorName

ErrorName returns error name.

func (DeleteTaskRequestValidationError) Field

Field function returns field value.

func (DeleteTaskRequestValidationError) Key

Key function returns key value.

func (DeleteTaskRequestValidationError) Reason

Reason function returns reason value.

type DeleteWorkerGroupRequest

type DeleteWorkerGroupRequest struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteWorkerGroupRequest) Descriptor deprecated

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

Deprecated: Use DeleteWorkerGroupRequest.ProtoReflect.Descriptor instead.

func (*DeleteWorkerGroupRequest) GetId

func (x *DeleteWorkerGroupRequest) GetId() uint32

func (*DeleteWorkerGroupRequest) ProtoMessage

func (*DeleteWorkerGroupRequest) ProtoMessage()

func (*DeleteWorkerGroupRequest) ProtoReflect

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

func (*DeleteWorkerGroupRequest) Reset

func (x *DeleteWorkerGroupRequest) Reset()

func (*DeleteWorkerGroupRequest) String

func (x *DeleteWorkerGroupRequest) String() string

func (*DeleteWorkerGroupRequest) Validate

func (m *DeleteWorkerGroupRequest) Validate() error

Validate checks the field values on DeleteWorkerGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DeleteWorkerGroupRequest) ValidateAll

func (m *DeleteWorkerGroupRequest) ValidateAll() error

ValidateAll checks the field values on DeleteWorkerGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteWorkerGroupRequestMultiError, or nil if none found.

type DeleteWorkerGroupRequestMultiError

type DeleteWorkerGroupRequestMultiError []error

DeleteWorkerGroupRequestMultiError is an error wrapping multiple validation errors returned by DeleteWorkerGroupRequest.ValidateAll() if the designated constraints aren't met.

func (DeleteWorkerGroupRequestMultiError) AllErrors

func (m DeleteWorkerGroupRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteWorkerGroupRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DeleteWorkerGroupRequestValidationError

type DeleteWorkerGroupRequestValidationError struct {
	// contains filtered or unexported fields
}

DeleteWorkerGroupRequestValidationError is the validation error returned by DeleteWorkerGroupRequest.Validate if the designated constraints aren't met.

func (DeleteWorkerGroupRequestValidationError) Cause

Cause function returns cause value.

func (DeleteWorkerGroupRequestValidationError) Error

Error satisfies the builtin error interface

func (DeleteWorkerGroupRequestValidationError) ErrorName

ErrorName returns error name.

func (DeleteWorkerGroupRequestValidationError) Field

Field function returns field value.

func (DeleteWorkerGroupRequestValidationError) Key

Key function returns key value.

func (DeleteWorkerGroupRequestValidationError) Reason

Reason function returns reason value.

type DeleteWorkerRequest

type DeleteWorkerRequest struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteWorkerRequest) Descriptor deprecated

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

Deprecated: Use DeleteWorkerRequest.ProtoReflect.Descriptor instead.

func (*DeleteWorkerRequest) GetId

func (x *DeleteWorkerRequest) GetId() uint32

func (*DeleteWorkerRequest) ProtoMessage

func (*DeleteWorkerRequest) ProtoMessage()

func (*DeleteWorkerRequest) ProtoReflect

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

func (*DeleteWorkerRequest) Reset

func (x *DeleteWorkerRequest) Reset()

func (*DeleteWorkerRequest) String

func (x *DeleteWorkerRequest) String() string

func (*DeleteWorkerRequest) Validate

func (m *DeleteWorkerRequest) Validate() error

Validate checks the field values on DeleteWorkerRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DeleteWorkerRequest) ValidateAll

func (m *DeleteWorkerRequest) ValidateAll() error

ValidateAll checks the field values on DeleteWorkerRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteWorkerRequestMultiError, or nil if none found.

type DeleteWorkerRequestMultiError

type DeleteWorkerRequestMultiError []error

DeleteWorkerRequestMultiError is an error wrapping multiple validation errors returned by DeleteWorkerRequest.ValidateAll() if the designated constraints aren't met.

func (DeleteWorkerRequestMultiError) AllErrors

func (m DeleteWorkerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DeleteWorkerRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DeleteWorkerRequestValidationError

type DeleteWorkerRequestValidationError struct {
	// contains filtered or unexported fields
}

DeleteWorkerRequestValidationError is the validation error returned by DeleteWorkerRequest.Validate if the designated constraints aren't met.

func (DeleteWorkerRequestValidationError) Cause

Cause function returns cause value.

func (DeleteWorkerRequestValidationError) Error

Error satisfies the builtin error interface

func (DeleteWorkerRequestValidationError) ErrorName

ErrorName returns error name.

func (DeleteWorkerRequestValidationError) Field

Field function returns field value.

func (DeleteWorkerRequestValidationError) Key

Key function returns key value.

func (DeleteWorkerRequestValidationError) Reason

Reason function returns reason value.

type DisableTaskRequest

type DisableTaskRequest struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DisableTaskRequest) Descriptor deprecated

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

Deprecated: Use DisableTaskRequest.ProtoReflect.Descriptor instead.

func (*DisableTaskRequest) GetId

func (x *DisableTaskRequest) GetId() uint32

func (*DisableTaskRequest) ProtoMessage

func (*DisableTaskRequest) ProtoMessage()

func (*DisableTaskRequest) ProtoReflect

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

func (*DisableTaskRequest) Reset

func (x *DisableTaskRequest) Reset()

func (*DisableTaskRequest) String

func (x *DisableTaskRequest) String() string

func (*DisableTaskRequest) Validate

func (m *DisableTaskRequest) Validate() error

Validate checks the field values on DisableTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DisableTaskRequest) ValidateAll

func (m *DisableTaskRequest) ValidateAll() error

ValidateAll checks the field values on DisableTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DisableTaskRequestMultiError, or nil if none found.

type DisableTaskRequestMultiError

type DisableTaskRequestMultiError []error

DisableTaskRequestMultiError is an error wrapping multiple validation errors returned by DisableTaskRequest.ValidateAll() if the designated constraints aren't met.

func (DisableTaskRequestMultiError) AllErrors

func (m DisableTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DisableTaskRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DisableTaskRequestValidationError

type DisableTaskRequestValidationError struct {
	// contains filtered or unexported fields
}

DisableTaskRequestValidationError is the validation error returned by DisableTaskRequest.Validate if the designated constraints aren't met.

func (DisableTaskRequestValidationError) Cause

Cause function returns cause value.

func (DisableTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (DisableTaskRequestValidationError) ErrorName

ErrorName returns error name.

func (DisableTaskRequestValidationError) Field

Field function returns field value.

func (DisableTaskRequestValidationError) Key

Key function returns key value.

func (DisableTaskRequestValidationError) Reason

Reason function returns reason value.

type DisableWorkerRequest

type DisableWorkerRequest struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DisableWorkerRequest) Descriptor deprecated

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

Deprecated: Use DisableWorkerRequest.ProtoReflect.Descriptor instead.

func (*DisableWorkerRequest) GetId

func (x *DisableWorkerRequest) GetId() uint32

func (*DisableWorkerRequest) ProtoMessage

func (*DisableWorkerRequest) ProtoMessage()

func (*DisableWorkerRequest) ProtoReflect

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

func (*DisableWorkerRequest) Reset

func (x *DisableWorkerRequest) Reset()

func (*DisableWorkerRequest) String

func (x *DisableWorkerRequest) String() string

func (*DisableWorkerRequest) Validate

func (m *DisableWorkerRequest) Validate() error

Validate checks the field values on DisableWorkerRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*DisableWorkerRequest) ValidateAll

func (m *DisableWorkerRequest) ValidateAll() error

ValidateAll checks the field values on DisableWorkerRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DisableWorkerRequestMultiError, or nil if none found.

type DisableWorkerRequestMultiError

type DisableWorkerRequestMultiError []error

DisableWorkerRequestMultiError is an error wrapping multiple validation errors returned by DisableWorkerRequest.ValidateAll() if the designated constraints aren't met.

func (DisableWorkerRequestMultiError) AllErrors

func (m DisableWorkerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (DisableWorkerRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type DisableWorkerRequestValidationError

type DisableWorkerRequestValidationError struct {
	// contains filtered or unexported fields
}

DisableWorkerRequestValidationError is the validation error returned by DisableWorkerRequest.Validate if the designated constraints aren't met.

func (DisableWorkerRequestValidationError) Cause

Cause function returns cause value.

func (DisableWorkerRequestValidationError) Error

Error satisfies the builtin error interface

func (DisableWorkerRequestValidationError) ErrorName

ErrorName returns error name.

func (DisableWorkerRequestValidationError) Field

Field function returns field value.

func (DisableWorkerRequestValidationError) Key

Key function returns key value.

func (DisableWorkerRequestValidationError) Reason

Reason function returns reason value.

type EnableTaskRequest

type EnableTaskRequest struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*EnableTaskRequest) Descriptor deprecated

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

Deprecated: Use EnableTaskRequest.ProtoReflect.Descriptor instead.

func (*EnableTaskRequest) GetId

func (x *EnableTaskRequest) GetId() uint32

func (*EnableTaskRequest) ProtoMessage

func (*EnableTaskRequest) ProtoMessage()

func (*EnableTaskRequest) ProtoReflect

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

func (*EnableTaskRequest) Reset

func (x *EnableTaskRequest) Reset()

func (*EnableTaskRequest) String

func (x *EnableTaskRequest) String() string

func (*EnableTaskRequest) Validate

func (m *EnableTaskRequest) Validate() error

Validate checks the field values on EnableTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*EnableTaskRequest) ValidateAll

func (m *EnableTaskRequest) ValidateAll() error

ValidateAll checks the field values on EnableTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EnableTaskRequestMultiError, or nil if none found.

type EnableTaskRequestMultiError

type EnableTaskRequestMultiError []error

EnableTaskRequestMultiError is an error wrapping multiple validation errors returned by EnableTaskRequest.ValidateAll() if the designated constraints aren't met.

func (EnableTaskRequestMultiError) AllErrors

func (m EnableTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EnableTaskRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type EnableTaskRequestValidationError

type EnableTaskRequestValidationError struct {
	// contains filtered or unexported fields
}

EnableTaskRequestValidationError is the validation error returned by EnableTaskRequest.Validate if the designated constraints aren't met.

func (EnableTaskRequestValidationError) Cause

Cause function returns cause value.

func (EnableTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (EnableTaskRequestValidationError) ErrorName

ErrorName returns error name.

func (EnableTaskRequestValidationError) Field

Field function returns field value.

func (EnableTaskRequestValidationError) Key

Key function returns key value.

func (EnableTaskRequestValidationError) Reason

Reason function returns reason value.

type EnableWorkerRequest

type EnableWorkerRequest struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*EnableWorkerRequest) Descriptor deprecated

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

Deprecated: Use EnableWorkerRequest.ProtoReflect.Descriptor instead.

func (*EnableWorkerRequest) GetId

func (x *EnableWorkerRequest) GetId() uint32

func (*EnableWorkerRequest) ProtoMessage

func (*EnableWorkerRequest) ProtoMessage()

func (*EnableWorkerRequest) ProtoReflect

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

func (*EnableWorkerRequest) Reset

func (x *EnableWorkerRequest) Reset()

func (*EnableWorkerRequest) String

func (x *EnableWorkerRequest) String() string

func (*EnableWorkerRequest) Validate

func (m *EnableWorkerRequest) Validate() error

Validate checks the field values on EnableWorkerRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*EnableWorkerRequest) ValidateAll

func (m *EnableWorkerRequest) ValidateAll() error

ValidateAll checks the field values on EnableWorkerRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in EnableWorkerRequestMultiError, or nil if none found.

type EnableWorkerRequestMultiError

type EnableWorkerRequestMultiError []error

EnableWorkerRequestMultiError is an error wrapping multiple validation errors returned by EnableWorkerRequest.ValidateAll() if the designated constraints aren't met.

func (EnableWorkerRequestMultiError) AllErrors

func (m EnableWorkerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (EnableWorkerRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type EnableWorkerRequestValidationError

type EnableWorkerRequestValidationError struct {
	// contains filtered or unexported fields
}

EnableWorkerRequestValidationError is the validation error returned by EnableWorkerRequest.Validate if the designated constraints aren't met.

func (EnableWorkerRequestValidationError) Cause

Cause function returns cause value.

func (EnableWorkerRequestValidationError) Error

Error satisfies the builtin error interface

func (EnableWorkerRequestValidationError) ErrorName

ErrorName returns error name.

func (EnableWorkerRequestValidationError) Field

Field function returns field value.

func (EnableWorkerRequestValidationError) Key

Key function returns key value.

func (EnableWorkerRequestValidationError) Reason

Reason function returns reason value.

type ExecTaskRequest

type ExecTaskRequest struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecTaskRequest) Descriptor deprecated

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

Deprecated: Use ExecTaskRequest.ProtoReflect.Descriptor instead.

func (*ExecTaskRequest) GetId

func (x *ExecTaskRequest) GetId() uint32

func (*ExecTaskRequest) ProtoMessage

func (*ExecTaskRequest) ProtoMessage()

func (*ExecTaskRequest) ProtoReflect

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

func (*ExecTaskRequest) Reset

func (x *ExecTaskRequest) Reset()

func (*ExecTaskRequest) String

func (x *ExecTaskRequest) String() string

func (*ExecTaskRequest) Validate

func (m *ExecTaskRequest) Validate() error

Validate checks the field values on ExecTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*ExecTaskRequest) ValidateAll

func (m *ExecTaskRequest) ValidateAll() error

ValidateAll checks the field values on ExecTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ExecTaskRequestMultiError, or nil if none found.

type ExecTaskRequestMultiError

type ExecTaskRequestMultiError []error

ExecTaskRequestMultiError is an error wrapping multiple validation errors returned by ExecTaskRequest.ValidateAll() if the designated constraints aren't met.

func (ExecTaskRequestMultiError) AllErrors

func (m ExecTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (ExecTaskRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type ExecTaskRequestValidationError

type ExecTaskRequestValidationError struct {
	// contains filtered or unexported fields
}

ExecTaskRequestValidationError is the validation error returned by ExecTaskRequest.Validate if the designated constraints aren't met.

func (ExecTaskRequestValidationError) Cause

Cause function returns cause value.

func (ExecTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (ExecTaskRequestValidationError) ErrorName

func (e ExecTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (ExecTaskRequestValidationError) Field

Field function returns field value.

func (ExecTaskRequestValidationError) Key

Key function returns key value.

func (ExecTaskRequestValidationError) Reason

Reason function returns reason value.

type GetLogRequest

type GetLogRequest struct {
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetLogRequest) Descriptor deprecated

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

Deprecated: Use GetLogRequest.ProtoReflect.Descriptor instead.

func (*GetLogRequest) GetId

func (x *GetLogRequest) GetId() uint32

func (*GetLogRequest) ProtoMessage

func (*GetLogRequest) ProtoMessage()

func (*GetLogRequest) ProtoReflect

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

func (*GetLogRequest) Reset

func (x *GetLogRequest) Reset()

func (*GetLogRequest) String

func (x *GetLogRequest) String() string

func (*GetLogRequest) Validate

func (m *GetLogRequest) Validate() error

Validate checks the field values on GetLogRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*GetLogRequest) ValidateAll

func (m *GetLogRequest) ValidateAll() error

ValidateAll checks the field values on GetLogRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in GetLogRequestMultiError, or nil if none found.

type GetLogRequestMultiError

type GetLogRequestMultiError []error

GetLogRequestMultiError is an error wrapping multiple validation errors returned by GetLogRequest.ValidateAll() if the designated constraints aren't met.

func (GetLogRequestMultiError) AllErrors

func (m GetLogRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (GetLogRequestMultiError) Error

func (m GetLogRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type GetLogRequestValidationError

type GetLogRequestValidationError struct {
	// contains filtered or unexported fields
}

GetLogRequestValidationError is the validation error returned by GetLogRequest.Validate if the designated constraints aren't met.

func (GetLogRequestValidationError) Cause

Cause function returns cause value.

func (GetLogRequestValidationError) Error

Error satisfies the builtin error interface

func (GetLogRequestValidationError) ErrorName

func (e GetLogRequestValidationError) ErrorName() string

ErrorName returns error name.

func (GetLogRequestValidationError) Field

Field function returns field value.

func (GetLogRequestValidationError) Key

Key function returns key value.

func (GetLogRequestValidationError) Reason

Reason function returns reason value.

type Log

type Log struct {
	Id             uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Uuid           string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	WorkerId       uint32 `protobuf:"varint,3,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	WorkerSnapshot string `protobuf:"bytes,4,opt,name=worker_snapshot,json=workerSnapshot,proto3" json:"worker_snapshot,omitempty"`
	TaskId         uint32 `protobuf:"varint,5,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TaskSnapshot   string `protobuf:"bytes,6,opt,name=task_snapshot,json=taskSnapshot,proto3" json:"task_snapshot,omitempty"`
	Start          int64  `protobuf:"varint,7,opt,name=start,proto3" json:"start,omitempty"`
	End            int64  `protobuf:"varint,8,opt,name=end,proto3" json:"end,omitempty"`
	Content        string `protobuf:"bytes,9,opt,name=content,proto3" json:"content,omitempty"`
	Status         string `protobuf:"bytes,10,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetContent

func (x *Log) GetContent() string

func (*Log) GetEnd

func (x *Log) GetEnd() int64

func (*Log) GetId

func (x *Log) GetId() uint32

func (*Log) GetStart

func (x *Log) GetStart() int64

func (*Log) GetStatus

func (x *Log) GetStatus() string

func (*Log) GetTaskId

func (x *Log) GetTaskId() uint32

func (*Log) GetTaskSnapshot

func (x *Log) GetTaskSnapshot() string

func (*Log) GetUuid

func (x *Log) GetUuid() string

func (*Log) GetWorkerId

func (x *Log) GetWorkerId() uint32

func (*Log) GetWorkerSnapshot

func (x *Log) GetWorkerSnapshot() string

func (*Log) ProtoMessage

func (*Log) ProtoMessage()

func (*Log) ProtoReflect

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

func (*Log) Reset

func (x *Log) Reset()

func (*Log) String

func (x *Log) String() string

func (*Log) Validate

func (m *Log) Validate() error

Validate checks the field values on Log with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Log) ValidateAll

func (m *Log) ValidateAll() error

ValidateAll checks the field values on Log with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in LogMultiError, or nil if none found.

type LogMultiError

type LogMultiError []error

LogMultiError is an error wrapping multiple validation errors returned by Log.ValidateAll() if the designated constraints aren't met.

func (LogMultiError) AllErrors

func (m LogMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (LogMultiError) Error

func (m LogMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type LogValidationError

type LogValidationError struct {
	// contains filtered or unexported fields
}

LogValidationError is the validation error returned by Log.Validate if the designated constraints aren't met.

func (LogValidationError) Cause

func (e LogValidationError) Cause() error

Cause function returns cause value.

func (LogValidationError) Error

func (e LogValidationError) Error() string

Error satisfies the builtin error interface

func (LogValidationError) ErrorName

func (e LogValidationError) ErrorName() string

ErrorName returns error name.

func (LogValidationError) Field

func (e LogValidationError) Field() string

Field function returns field value.

func (LogValidationError) Key

func (e LogValidationError) Key() bool

Key function returns key value.

func (LogValidationError) Reason

func (e LogValidationError) Reason() string

Reason function returns reason value.

type PageLogReply

type PageLogReply struct {
	Total uint32 `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	List  []*Log `protobuf:"bytes,2,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*PageLogReply) Descriptor deprecated

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

Deprecated: Use PageLogReply.ProtoReflect.Descriptor instead.

func (*PageLogReply) GetList

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

func (*PageLogReply) GetTotal

func (x *PageLogReply) GetTotal() uint32

func (*PageLogReply) ProtoMessage

func (*PageLogReply) ProtoMessage()

func (*PageLogReply) ProtoReflect

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

func (*PageLogReply) Reset

func (x *PageLogReply) Reset()

func (*PageLogReply) String

func (x *PageLogReply) String() string

func (*PageLogReply) Validate

func (m *PageLogReply) Validate() error

Validate checks the field values on PageLogReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PageLogReply) ValidateAll

func (m *PageLogReply) ValidateAll() error

ValidateAll checks the field values on PageLogReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PageLogReplyMultiError, or nil if none found.

type PageLogReplyMultiError

type PageLogReplyMultiError []error

PageLogReplyMultiError is an error wrapping multiple validation errors returned by PageLogReply.ValidateAll() if the designated constraints aren't met.

func (PageLogReplyMultiError) AllErrors

func (m PageLogReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PageLogReplyMultiError) Error

func (m PageLogReplyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PageLogReplyValidationError

type PageLogReplyValidationError struct {
	// contains filtered or unexported fields
}

PageLogReplyValidationError is the validation error returned by PageLogReply.Validate if the designated constraints aren't met.

func (PageLogReplyValidationError) Cause

Cause function returns cause value.

func (PageLogReplyValidationError) Error

Error satisfies the builtin error interface

func (PageLogReplyValidationError) ErrorName

func (e PageLogReplyValidationError) ErrorName() string

ErrorName returns error name.

func (PageLogReplyValidationError) Field

Field function returns field value.

func (PageLogReplyValidationError) Key

Key function returns key value.

func (PageLogReplyValidationError) Reason

Reason function returns reason value.

type PageLogRequest

type PageLogRequest struct {
	Page     uint32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	PageSize uint32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	TaskId   uint32 `protobuf:"varint,3,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PageLogRequest) Descriptor deprecated

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

Deprecated: Use PageLogRequest.ProtoReflect.Descriptor instead.

func (*PageLogRequest) GetPage

func (x *PageLogRequest) GetPage() uint32

func (*PageLogRequest) GetPageSize

func (x *PageLogRequest) GetPageSize() uint32

func (*PageLogRequest) GetTaskId

func (x *PageLogRequest) GetTaskId() uint32

func (*PageLogRequest) ProtoMessage

func (*PageLogRequest) ProtoMessage()

func (*PageLogRequest) ProtoReflect

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

func (*PageLogRequest) Reset

func (x *PageLogRequest) Reset()

func (*PageLogRequest) String

func (x *PageLogRequest) String() string

func (*PageLogRequest) Validate

func (m *PageLogRequest) Validate() error

Validate checks the field values on PageLogRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PageLogRequest) ValidateAll

func (m *PageLogRequest) ValidateAll() error

ValidateAll checks the field values on PageLogRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PageLogRequestMultiError, or nil if none found.

type PageLogRequestMultiError

type PageLogRequestMultiError []error

PageLogRequestMultiError is an error wrapping multiple validation errors returned by PageLogRequest.ValidateAll() if the designated constraints aren't met.

func (PageLogRequestMultiError) AllErrors

func (m PageLogRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PageLogRequestMultiError) Error

func (m PageLogRequestMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PageLogRequestValidationError

type PageLogRequestValidationError struct {
	// contains filtered or unexported fields
}

PageLogRequestValidationError is the validation error returned by PageLogRequest.Validate if the designated constraints aren't met.

func (PageLogRequestValidationError) Cause

Cause function returns cause value.

func (PageLogRequestValidationError) Error

Error satisfies the builtin error interface

func (PageLogRequestValidationError) ErrorName

func (e PageLogRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PageLogRequestValidationError) Field

Field function returns field value.

func (PageLogRequestValidationError) Key

Key function returns key value.

func (PageLogRequestValidationError) Reason

Reason function returns reason value.

type PageTaskReply

type PageTaskReply struct {
	Total uint32  `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	List  []*Task `protobuf:"bytes,2,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*PageTaskReply) Descriptor deprecated

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

Deprecated: Use PageTaskReply.ProtoReflect.Descriptor instead.

func (*PageTaskReply) GetList

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

func (*PageTaskReply) GetTotal

func (x *PageTaskReply) GetTotal() uint32

func (*PageTaskReply) ProtoMessage

func (*PageTaskReply) ProtoMessage()

func (*PageTaskReply) ProtoReflect

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

func (*PageTaskReply) Reset

func (x *PageTaskReply) Reset()

func (*PageTaskReply) String

func (x *PageTaskReply) String() string

func (*PageTaskReply) Validate

func (m *PageTaskReply) Validate() error

Validate checks the field values on PageTaskReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PageTaskReply) ValidateAll

func (m *PageTaskReply) ValidateAll() error

ValidateAll checks the field values on PageTaskReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PageTaskReplyMultiError, or nil if none found.

type PageTaskReplyMultiError

type PageTaskReplyMultiError []error

PageTaskReplyMultiError is an error wrapping multiple validation errors returned by PageTaskReply.ValidateAll() if the designated constraints aren't met.

func (PageTaskReplyMultiError) AllErrors

func (m PageTaskReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PageTaskReplyMultiError) Error

func (m PageTaskReplyMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type PageTaskReplyValidationError

type PageTaskReplyValidationError struct {
	// contains filtered or unexported fields
}

PageTaskReplyValidationError is the validation error returned by PageTaskReply.Validate if the designated constraints aren't met.

func (PageTaskReplyValidationError) Cause

Cause function returns cause value.

func (PageTaskReplyValidationError) Error

Error satisfies the builtin error interface

func (PageTaskReplyValidationError) ErrorName

func (e PageTaskReplyValidationError) ErrorName() string

ErrorName returns error name.

func (PageTaskReplyValidationError) Field

Field function returns field value.

func (PageTaskReplyValidationError) Key

Key function returns key value.

func (PageTaskReplyValidationError) Reason

Reason function returns reason value.

type PageTaskRequest

type PageTaskRequest struct {
	Page     uint32  `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	PageSize uint32  `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	Tag      *string `protobuf:"bytes,3,opt,name=tag,proto3,oneof" json:"tag,omitempty"`
	Ip       *string `protobuf:"bytes,4,opt,name=ip,proto3,oneof" json:"ip,omitempty"`
	Name     *string `protobuf:"bytes,5,opt,name=name,proto3,oneof" json:"name,omitempty"`
	Status   *bool   `protobuf:"varint,6,opt,name=status,proto3,oneof" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*PageTaskRequest) Descriptor deprecated

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

Deprecated: Use PageTaskRequest.ProtoReflect.Descriptor instead.

func (*PageTaskRequest) GetIp

func (x *PageTaskRequest) GetIp() string

func (*PageTaskRequest) GetName

func (x *PageTaskRequest) GetName() string

func (*PageTaskRequest) GetPage

func (x *PageTaskRequest) GetPage() uint32

func (*PageTaskRequest) GetPageSize

func (x *PageTaskRequest) GetPageSize() uint32

func (*PageTaskRequest) GetStatus

func (x *PageTaskRequest) GetStatus() bool

func (*PageTaskRequest) GetTag

func (x *PageTaskRequest) GetTag() string

func (*PageTaskRequest) ProtoMessage

func (*PageTaskRequest) ProtoMessage()

func (*PageTaskRequest) ProtoReflect

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

func (*PageTaskRequest) Reset

func (x *PageTaskRequest) Reset()

func (*PageTaskRequest) String

func (x *PageTaskRequest) String() string

func (*PageTaskRequest) Validate

func (m *PageTaskRequest) Validate() error

Validate checks the field values on PageTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PageTaskRequest) ValidateAll

func (m *PageTaskRequest) ValidateAll() error

ValidateAll checks the field values on PageTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PageTaskRequestMultiError, or nil if none found.

type PageTaskRequestMultiError

type PageTaskRequestMultiError []error

PageTaskRequestMultiError is an error wrapping multiple validation errors returned by PageTaskRequest.ValidateAll() if the designated constraints aren't met.

func (PageTaskRequestMultiError) AllErrors

func (m PageTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PageTaskRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type PageTaskRequestValidationError

type PageTaskRequestValidationError struct {
	// contains filtered or unexported fields
}

PageTaskRequestValidationError is the validation error returned by PageTaskRequest.Validate if the designated constraints aren't met.

func (PageTaskRequestValidationError) Cause

Cause function returns cause value.

func (PageTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (PageTaskRequestValidationError) ErrorName

func (e PageTaskRequestValidationError) ErrorName() string

ErrorName returns error name.

func (PageTaskRequestValidationError) Field

Field function returns field value.

func (PageTaskRequestValidationError) Key

Key function returns key value.

func (PageTaskRequestValidationError) Reason

Reason function returns reason value.

type PageWorkerReply

type PageWorkerReply struct {
	Total uint32    `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	List  []*Worker `protobuf:"bytes,2,rep,name=list,proto3" json:"list,omitempty"`
	// contains filtered or unexported fields
}

func (*PageWorkerReply) Descriptor deprecated

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

Deprecated: Use PageWorkerReply.ProtoReflect.Descriptor instead.

func (*PageWorkerReply) GetList

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

func (*PageWorkerReply) GetTotal

func (x *PageWorkerReply) GetTotal() uint32

func (*PageWorkerReply) ProtoMessage

func (*PageWorkerReply) ProtoMessage()

func (*PageWorkerReply) ProtoReflect

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

func (*PageWorkerReply) Reset

func (x *PageWorkerReply) Reset()

func (*PageWorkerReply) String

func (x *PageWorkerReply) String() string

func (*PageWorkerReply) Validate

func (m *PageWorkerReply) Validate() error

Validate checks the field values on PageWorkerReply with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PageWorkerReply) ValidateAll

func (m *PageWorkerReply) ValidateAll() error

ValidateAll checks the field values on PageWorkerReply with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PageWorkerReplyMultiError, or nil if none found.

type PageWorkerReplyMultiError

type PageWorkerReplyMultiError []error

PageWorkerReplyMultiError is an error wrapping multiple validation errors returned by PageWorkerReply.ValidateAll() if the designated constraints aren't met.

func (PageWorkerReplyMultiError) AllErrors

func (m PageWorkerReplyMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PageWorkerReplyMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type PageWorkerReplyValidationError

type PageWorkerReplyValidationError struct {
	// contains filtered or unexported fields
}

PageWorkerReplyValidationError is the validation error returned by PageWorkerReply.Validate if the designated constraints aren't met.

func (PageWorkerReplyValidationError) Cause

Cause function returns cause value.

func (PageWorkerReplyValidationError) Error

Error satisfies the builtin error interface

func (PageWorkerReplyValidationError) ErrorName

func (e PageWorkerReplyValidationError) ErrorName() string

ErrorName returns error name.

func (PageWorkerReplyValidationError) Field

Field function returns field value.

func (PageWorkerReplyValidationError) Key

Key function returns key value.

func (PageWorkerReplyValidationError) Reason

Reason function returns reason value.

type PageWorkerRequest

type PageWorkerRequest struct {
	Page     uint32  `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	PageSize uint32  `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	GroupId  *uint32 `protobuf:"varint,3,opt,name=group_id,json=groupId,proto3,oneof" json:"group_id,omitempty"`
	Name     *string `protobuf:"bytes,5,opt,name=name,proto3,oneof" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*PageWorkerRequest) Descriptor deprecated

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

Deprecated: Use PageWorkerRequest.ProtoReflect.Descriptor instead.

func (*PageWorkerRequest) GetGroupId

func (x *PageWorkerRequest) GetGroupId() uint32

func (*PageWorkerRequest) GetName

func (x *PageWorkerRequest) GetName() string

func (*PageWorkerRequest) GetPage

func (x *PageWorkerRequest) GetPage() uint32

func (*PageWorkerRequest) GetPageSize

func (x *PageWorkerRequest) GetPageSize() uint32

func (*PageWorkerRequest) ProtoMessage

func (*PageWorkerRequest) ProtoMessage()

func (*PageWorkerRequest) ProtoReflect

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

func (*PageWorkerRequest) Reset

func (x *PageWorkerRequest) Reset()

func (*PageWorkerRequest) String

func (x *PageWorkerRequest) String() string

func (*PageWorkerRequest) Validate

func (m *PageWorkerRequest) Validate() error

Validate checks the field values on PageWorkerRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*PageWorkerRequest) ValidateAll

func (m *PageWorkerRequest) ValidateAll() error

ValidateAll checks the field values on PageWorkerRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PageWorkerRequestMultiError, or nil if none found.

type PageWorkerRequestMultiError

type PageWorkerRequestMultiError []error

PageWorkerRequestMultiError is an error wrapping multiple validation errors returned by PageWorkerRequest.ValidateAll() if the designated constraints aren't met.

func (PageWorkerRequestMultiError) AllErrors

func (m PageWorkerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (PageWorkerRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type PageWorkerRequestValidationError

type PageWorkerRequestValidationError struct {
	// contains filtered or unexported fields
}

PageWorkerRequestValidationError is the validation error returned by PageWorkerRequest.Validate if the designated constraints aren't met.

func (PageWorkerRequestValidationError) Cause

Cause function returns cause value.

func (PageWorkerRequestValidationError) Error

Error satisfies the builtin error interface

func (PageWorkerRequestValidationError) ErrorName

ErrorName returns error name.

func (PageWorkerRequestValidationError) Field

Field function returns field value.

func (PageWorkerRequestValidationError) Key

Key function returns key value.

func (PageWorkerRequestValidationError) Reason

Reason function returns reason value.

type ServiceClient

type ServiceClient interface {
	AllWorkerGroup(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AllWorkerGroupReply, error)
	AddWorkerGroup(ctx context.Context, in *AddWorkerGroupRequest, opts ...grpc.CallOption) (*AddWorkerGroupReply, error)
	UpdateWorkerGroup(ctx context.Context, in *UpdateWorkerGroupRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteWorkerGroup(ctx context.Context, in *DeleteWorkerGroupRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PageWorker(ctx context.Context, in *PageWorkerRequest, opts ...grpc.CallOption) (*PageWorkerReply, error)
	AddWorker(ctx context.Context, in *AddWorkerRequest, opts ...grpc.CallOption) (*AddWorkerReply, error)
	UpdateWorker(ctx context.Context, in *UpdateWorkerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	EnableWorker(ctx context.Context, in *EnableWorkerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DisableWorker(ctx context.Context, in *DisableWorkerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteWorker(ctx context.Context, in *DeleteWorkerRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	AllTaskGroup(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*AllTaskGroupReply, error)
	AddTaskGroup(ctx context.Context, in *AddTaskGroupRequest, opts ...grpc.CallOption) (*AddTaskGroupReply, error)
	UpdateTaskGroup(ctx context.Context, in *UpdateTaskGroupRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteTaskGroup(ctx context.Context, in *DeleteTaskGroupRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PageTask(ctx context.Context, in *PageTaskRequest, opts ...grpc.CallOption) (*PageTaskReply, error)
	AddTask(ctx context.Context, in *AddTaskRequest, opts ...grpc.CallOption) (*AddTaskReply, error)
	UpdateTask(ctx context.Context, in *UpdateTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	EnableTask(ctx context.Context, in *EnableTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DisableTask(ctx context.Context, in *DisableTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	ExecTask(ctx context.Context, in *ExecTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	CancelExecTask(ctx context.Context, in *CancelExecTaskRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	PageLog(ctx context.Context, in *PageLogRequest, opts ...grpc.CallOption) (*PageLogReply, error)
	GetLog(ctx context.Context, in *GetLogRequest, opts ...grpc.CallOption) (*Log, error)
}

ServiceClient is the client API for Service 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 NewServiceClient

func NewServiceClient(cc grpc.ClientConnInterface) ServiceClient

type ServiceHTTPClient

type ServiceHTTPClient interface {
	AddTask(ctx context.Context, req *AddTaskRequest, opts ...http.CallOption) (rsp *AddTaskReply, err error)
	AddTaskGroup(ctx context.Context, req *AddTaskGroupRequest, opts ...http.CallOption) (rsp *AddTaskGroupReply, err error)
	AddWorker(ctx context.Context, req *AddWorkerRequest, opts ...http.CallOption) (rsp *AddWorkerReply, err error)
	AddWorkerGroup(ctx context.Context, req *AddWorkerGroupRequest, opts ...http.CallOption) (rsp *AddWorkerGroupReply, err error)
	AllTaskGroup(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *AllTaskGroupReply, err error)
	AllWorkerGroup(ctx context.Context, req *emptypb.Empty, opts ...http.CallOption) (rsp *AllWorkerGroupReply, err error)
	CancelExecTask(ctx context.Context, req *CancelExecTaskRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	DeleteTask(ctx context.Context, req *DeleteTaskRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	DeleteTaskGroup(ctx context.Context, req *DeleteTaskGroupRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	DeleteWorker(ctx context.Context, req *DeleteWorkerRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	DeleteWorkerGroup(ctx context.Context, req *DeleteWorkerGroupRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	DisableTask(ctx context.Context, req *DisableTaskRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	DisableWorker(ctx context.Context, req *DisableWorkerRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	EnableTask(ctx context.Context, req *EnableTaskRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	EnableWorker(ctx context.Context, req *EnableWorkerRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	ExecTask(ctx context.Context, req *ExecTaskRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	GetLog(ctx context.Context, req *GetLogRequest, opts ...http.CallOption) (rsp *Log, err error)
	PageLog(ctx context.Context, req *PageLogRequest, opts ...http.CallOption) (rsp *PageLogReply, err error)
	PageTask(ctx context.Context, req *PageTaskRequest, opts ...http.CallOption) (rsp *PageTaskReply, err error)
	PageWorker(ctx context.Context, req *PageWorkerRequest, opts ...http.CallOption) (rsp *PageWorkerReply, err error)
	UpdateTask(ctx context.Context, req *UpdateTaskRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	UpdateTaskGroup(ctx context.Context, req *UpdateTaskGroupRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	UpdateWorker(ctx context.Context, req *UpdateWorkerRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
	UpdateWorkerGroup(ctx context.Context, req *UpdateWorkerGroupRequest, opts ...http.CallOption) (rsp *emptypb.Empty, err error)
}

func NewServiceHTTPClient

func NewServiceHTTPClient(client *http.Client) ServiceHTTPClient

type ServiceHTTPClientImpl

type ServiceHTTPClientImpl struct {
	// contains filtered or unexported fields
}

func (*ServiceHTTPClientImpl) AddTask

func (*ServiceHTTPClientImpl) AddTaskGroup

func (*ServiceHTTPClientImpl) AddWorker

func (*ServiceHTTPClientImpl) AddWorkerGroup

func (*ServiceHTTPClientImpl) AllTaskGroup

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

func (*ServiceHTTPClientImpl) AllWorkerGroup

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

func (*ServiceHTTPClientImpl) CancelExecTask

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

func (*ServiceHTTPClientImpl) DeleteTask

func (*ServiceHTTPClientImpl) DeleteTaskGroup

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

func (*ServiceHTTPClientImpl) DeleteWorker

func (*ServiceHTTPClientImpl) DeleteWorkerGroup

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

func (*ServiceHTTPClientImpl) DisableTask

func (*ServiceHTTPClientImpl) DisableWorker

func (*ServiceHTTPClientImpl) EnableTask

func (*ServiceHTTPClientImpl) EnableWorker

func (*ServiceHTTPClientImpl) ExecTask

func (*ServiceHTTPClientImpl) GetLog

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

func (*ServiceHTTPClientImpl) PageLog

func (*ServiceHTTPClientImpl) PageTask

func (*ServiceHTTPClientImpl) PageWorker

func (*ServiceHTTPClientImpl) UpdateTask

func (*ServiceHTTPClientImpl) UpdateTaskGroup

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

func (*ServiceHTTPClientImpl) UpdateWorker

func (*ServiceHTTPClientImpl) UpdateWorkerGroup

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

type ServiceHTTPServer

type ServiceHTTPServer interface {
	AddTask(context.Context, *AddTaskRequest) (*AddTaskReply, error)
	AddTaskGroup(context.Context, *AddTaskGroupRequest) (*AddTaskGroupReply, error)
	AddWorker(context.Context, *AddWorkerRequest) (*AddWorkerReply, error)
	AddWorkerGroup(context.Context, *AddWorkerGroupRequest) (*AddWorkerGroupReply, error)
	AllTaskGroup(context.Context, *emptypb.Empty) (*AllTaskGroupReply, error)
	AllWorkerGroup(context.Context, *emptypb.Empty) (*AllWorkerGroupReply, error)
	CancelExecTask(context.Context, *CancelExecTaskRequest) (*emptypb.Empty, error)
	DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
	DeleteTaskGroup(context.Context, *DeleteTaskGroupRequest) (*emptypb.Empty, error)
	DeleteWorker(context.Context, *DeleteWorkerRequest) (*emptypb.Empty, error)
	DeleteWorkerGroup(context.Context, *DeleteWorkerGroupRequest) (*emptypb.Empty, error)
	DisableTask(context.Context, *DisableTaskRequest) (*emptypb.Empty, error)
	DisableWorker(context.Context, *DisableWorkerRequest) (*emptypb.Empty, error)
	EnableTask(context.Context, *EnableTaskRequest) (*emptypb.Empty, error)
	EnableWorker(context.Context, *EnableWorkerRequest) (*emptypb.Empty, error)
	ExecTask(context.Context, *ExecTaskRequest) (*emptypb.Empty, error)
	GetLog(context.Context, *GetLogRequest) (*Log, error)
	PageLog(context.Context, *PageLogRequest) (*PageLogReply, error)
	PageTask(context.Context, *PageTaskRequest) (*PageTaskReply, error)
	PageWorker(context.Context, *PageWorkerRequest) (*PageWorkerReply, error)
	UpdateTask(context.Context, *UpdateTaskRequest) (*emptypb.Empty, error)
	UpdateTaskGroup(context.Context, *UpdateTaskGroupRequest) (*emptypb.Empty, error)
	UpdateWorker(context.Context, *UpdateWorkerRequest) (*emptypb.Empty, error)
	UpdateWorkerGroup(context.Context, *UpdateWorkerGroupRequest) (*emptypb.Empty, error)
}

type ServiceServer

type ServiceServer interface {
	AllWorkerGroup(context.Context, *emptypb.Empty) (*AllWorkerGroupReply, error)
	AddWorkerGroup(context.Context, *AddWorkerGroupRequest) (*AddWorkerGroupReply, error)
	UpdateWorkerGroup(context.Context, *UpdateWorkerGroupRequest) (*emptypb.Empty, error)
	DeleteWorkerGroup(context.Context, *DeleteWorkerGroupRequest) (*emptypb.Empty, error)
	PageWorker(context.Context, *PageWorkerRequest) (*PageWorkerReply, error)
	AddWorker(context.Context, *AddWorkerRequest) (*AddWorkerReply, error)
	UpdateWorker(context.Context, *UpdateWorkerRequest) (*emptypb.Empty, error)
	EnableWorker(context.Context, *EnableWorkerRequest) (*emptypb.Empty, error)
	DisableWorker(context.Context, *DisableWorkerRequest) (*emptypb.Empty, error)
	DeleteWorker(context.Context, *DeleteWorkerRequest) (*emptypb.Empty, error)
	AllTaskGroup(context.Context, *emptypb.Empty) (*AllTaskGroupReply, error)
	AddTaskGroup(context.Context, *AddTaskGroupRequest) (*AddTaskGroupReply, error)
	UpdateTaskGroup(context.Context, *UpdateTaskGroupRequest) (*emptypb.Empty, error)
	DeleteTaskGroup(context.Context, *DeleteTaskGroupRequest) (*emptypb.Empty, error)
	PageTask(context.Context, *PageTaskRequest) (*PageTaskReply, error)
	AddTask(context.Context, *AddTaskRequest) (*AddTaskReply, error)
	UpdateTask(context.Context, *UpdateTaskRequest) (*emptypb.Empty, error)
	EnableTask(context.Context, *EnableTaskRequest) (*emptypb.Empty, error)
	DisableTask(context.Context, *DisableTaskRequest) (*emptypb.Empty, error)
	DeleteTask(context.Context, *DeleteTaskRequest) (*emptypb.Empty, error)
	ExecTask(context.Context, *ExecTaskRequest) (*emptypb.Empty, error)
	CancelExecTask(context.Context, *CancelExecTaskRequest) (*emptypb.Empty, error)
	PageLog(context.Context, *PageLogRequest) (*PageLogReply, error)
	GetLog(context.Context, *GetLogRequest) (*Log, error)
	// contains filtered or unexported methods
}

ServiceServer is the server API for Service service. All implementations must embed UnimplementedServiceServer for forward compatibility

type Task

type Task struct {
	Id            uint32     `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	GroupId       uint32     `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Name          string     `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Tag           string     `protobuf:"bytes,4,opt,name=tag,proto3" json:"tag,omitempty"`
	Spec          string     `protobuf:"bytes,5,opt,name=spec,proto3" json:"spec,omitempty"`
	SelectType    string     `protobuf:"bytes,6,opt,name=select_type,json=selectType,proto3" json:"select_type,omitempty"`
	WorkerGroupId *uint32    `protobuf:"varint,7,opt,name=worker_group_id,json=workerGroupId,proto3,oneof" json:"worker_group_id,omitempty"`
	WorkerId      *uint32    `protobuf:"varint,8,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
	ExecType      string     `protobuf:"bytes,9,opt,name=exec_type,json=execType,proto3" json:"exec_type,omitempty"`
	ExecValue     string     `protobuf:"bytes,10,opt,name=exec_value,json=execValue,proto3" json:"exec_value,omitempty"`
	ExpectCode    uint32     `protobuf:"varint,11,opt,name=expect_code,json=expectCode,proto3" json:"expect_code,omitempty"`
	RetryCount    uint32     `protobuf:"varint,12,opt,name=retry_count,json=retryCount,proto3" json:"retry_count,omitempty"`
	RetryWaitTime uint32     `protobuf:"varint,13,opt,name=retry_wait_time,json=retryWaitTime,proto3" json:"retry_wait_time,omitempty"`
	MaxExecTime   uint32     `protobuf:"varint,14,opt,name=max_exec_time,json=maxExecTime,proto3" json:"max_exec_time,omitempty"`
	Status        bool       `protobuf:"varint,15,opt,name=status,proto3" json:"status,omitempty"`
	Description   string     `protobuf:"bytes,16,opt,name=description,proto3" json:"description,omitempty"`
	CreatedAt     uint32     `protobuf:"varint,17,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt     uint32     `protobuf:"varint,18,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Group         *TaskGroup `protobuf:"bytes,19,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor deprecated

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCreatedAt

func (x *Task) GetCreatedAt() uint32

func (*Task) GetDescription

func (x *Task) GetDescription() string

func (*Task) GetExecType

func (x *Task) GetExecType() string

func (*Task) GetExecValue

func (x *Task) GetExecValue() string

func (*Task) GetExpectCode

func (x *Task) GetExpectCode() uint32

func (*Task) GetGroup

func (x *Task) GetGroup() *TaskGroup

func (*Task) GetGroupId

func (x *Task) GetGroupId() uint32

func (*Task) GetId

func (x *Task) GetId() uint32

func (*Task) GetMaxExecTime

func (x *Task) GetMaxExecTime() uint32

func (*Task) GetName

func (x *Task) GetName() string

func (*Task) GetRetryCount

func (x *Task) GetRetryCount() uint32

func (*Task) GetRetryWaitTime

func (x *Task) GetRetryWaitTime() uint32

func (*Task) GetSelectType

func (x *Task) GetSelectType() string

func (*Task) GetSpec

func (x *Task) GetSpec() string

func (*Task) GetStatus

func (x *Task) GetStatus() bool

func (*Task) GetTag

func (x *Task) GetTag() string

func (*Task) GetUpdatedAt

func (x *Task) GetUpdatedAt() uint32

func (*Task) GetWorkerGroupId

func (x *Task) GetWorkerGroupId() uint32

func (*Task) GetWorkerId

func (x *Task) GetWorkerId() uint32

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) ProtoReflect

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

func (*Task) Reset

func (x *Task) Reset()

func (*Task) String

func (x *Task) String() string

func (*Task) Validate

func (m *Task) Validate() error

Validate checks the field values on Task with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Task) ValidateAll

func (m *Task) ValidateAll() error

ValidateAll checks the field values on Task with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskMultiError, or nil if none found.

type TaskGroup

type TaskGroup struct {
	Id          uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	CreatedAt   uint32 `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   uint32 `protobuf:"varint,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskGroup) Descriptor deprecated

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

Deprecated: Use TaskGroup.ProtoReflect.Descriptor instead.

func (*TaskGroup) GetCreatedAt

func (x *TaskGroup) GetCreatedAt() uint32

func (*TaskGroup) GetDescription

func (x *TaskGroup) GetDescription() string

func (*TaskGroup) GetId

func (x *TaskGroup) GetId() uint32

func (*TaskGroup) GetName

func (x *TaskGroup) GetName() string

func (*TaskGroup) GetUpdatedAt

func (x *TaskGroup) GetUpdatedAt() uint32

func (*TaskGroup) ProtoMessage

func (*TaskGroup) ProtoMessage()

func (*TaskGroup) ProtoReflect

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

func (*TaskGroup) Reset

func (x *TaskGroup) Reset()

func (*TaskGroup) String

func (x *TaskGroup) String() string

func (*TaskGroup) Validate

func (m *TaskGroup) Validate() error

Validate checks the field values on TaskGroup with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*TaskGroup) ValidateAll

func (m *TaskGroup) ValidateAll() error

ValidateAll checks the field values on TaskGroup with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in TaskGroupMultiError, or nil if none found.

type TaskGroupMultiError

type TaskGroupMultiError []error

TaskGroupMultiError is an error wrapping multiple validation errors returned by TaskGroup.ValidateAll() if the designated constraints aren't met.

func (TaskGroupMultiError) AllErrors

func (m TaskGroupMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskGroupMultiError) Error

func (m TaskGroupMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskGroupValidationError

type TaskGroupValidationError struct {
	// contains filtered or unexported fields
}

TaskGroupValidationError is the validation error returned by TaskGroup.Validate if the designated constraints aren't met.

func (TaskGroupValidationError) Cause

func (e TaskGroupValidationError) Cause() error

Cause function returns cause value.

func (TaskGroupValidationError) Error

func (e TaskGroupValidationError) Error() string

Error satisfies the builtin error interface

func (TaskGroupValidationError) ErrorName

func (e TaskGroupValidationError) ErrorName() string

ErrorName returns error name.

func (TaskGroupValidationError) Field

func (e TaskGroupValidationError) Field() string

Field function returns field value.

func (TaskGroupValidationError) Key

Key function returns key value.

func (TaskGroupValidationError) Reason

func (e TaskGroupValidationError) Reason() string

Reason function returns reason value.

type TaskMultiError

type TaskMultiError []error

TaskMultiError is an error wrapping multiple validation errors returned by Task.ValidateAll() if the designated constraints aren't met.

func (TaskMultiError) AllErrors

func (m TaskMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (TaskMultiError) Error

func (m TaskMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type TaskValidationError

type TaskValidationError struct {
	// contains filtered or unexported fields
}

TaskValidationError is the validation error returned by Task.Validate if the designated constraints aren't met.

func (TaskValidationError) Cause

func (e TaskValidationError) Cause() error

Cause function returns cause value.

func (TaskValidationError) Error

func (e TaskValidationError) Error() string

Error satisfies the builtin error interface

func (TaskValidationError) ErrorName

func (e TaskValidationError) ErrorName() string

ErrorName returns error name.

func (TaskValidationError) Field

func (e TaskValidationError) Field() string

Field function returns field value.

func (TaskValidationError) Key

func (e TaskValidationError) Key() bool

Key function returns key value.

func (TaskValidationError) Reason

func (e TaskValidationError) Reason() string

Reason function returns reason value.

type UnimplementedServiceServer

type UnimplementedServiceServer struct {
}

UnimplementedServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedServiceServer) AddTask

func (UnimplementedServiceServer) AddTaskGroup

func (UnimplementedServiceServer) AddWorker

func (UnimplementedServiceServer) AddWorkerGroup

func (UnimplementedServiceServer) AllTaskGroup

func (UnimplementedServiceServer) AllWorkerGroup

func (UnimplementedServiceServer) CancelExecTask

func (UnimplementedServiceServer) DeleteTask

func (UnimplementedServiceServer) DeleteTaskGroup

func (UnimplementedServiceServer) DeleteWorker

func (UnimplementedServiceServer) DeleteWorkerGroup

func (UnimplementedServiceServer) DisableTask

func (UnimplementedServiceServer) DisableWorker

func (UnimplementedServiceServer) EnableTask

func (UnimplementedServiceServer) EnableWorker

func (UnimplementedServiceServer) ExecTask

func (UnimplementedServiceServer) GetLog

func (UnimplementedServiceServer) PageLog

func (UnimplementedServiceServer) PageTask

func (UnimplementedServiceServer) PageWorker

func (UnimplementedServiceServer) UpdateTask

func (UnimplementedServiceServer) UpdateTaskGroup

func (UnimplementedServiceServer) UpdateWorker

func (UnimplementedServiceServer) UpdateWorkerGroup

type UnsafeServiceServer

type UnsafeServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ServiceServer will result in compilation errors.

type UpdateTaskGroupRequest

type UpdateTaskGroupRequest struct {
	Id          uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTaskGroupRequest) Descriptor deprecated

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

Deprecated: Use UpdateTaskGroupRequest.ProtoReflect.Descriptor instead.

func (*UpdateTaskGroupRequest) GetDescription

func (x *UpdateTaskGroupRequest) GetDescription() string

func (*UpdateTaskGroupRequest) GetId

func (x *UpdateTaskGroupRequest) GetId() uint32

func (*UpdateTaskGroupRequest) GetName

func (x *UpdateTaskGroupRequest) GetName() string

func (*UpdateTaskGroupRequest) ProtoMessage

func (*UpdateTaskGroupRequest) ProtoMessage()

func (*UpdateTaskGroupRequest) ProtoReflect

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

func (*UpdateTaskGroupRequest) Reset

func (x *UpdateTaskGroupRequest) Reset()

func (*UpdateTaskGroupRequest) String

func (x *UpdateTaskGroupRequest) String() string

func (*UpdateTaskGroupRequest) Validate

func (m *UpdateTaskGroupRequest) Validate() error

Validate checks the field values on UpdateTaskGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*UpdateTaskGroupRequest) ValidateAll

func (m *UpdateTaskGroupRequest) ValidateAll() error

ValidateAll checks the field values on UpdateTaskGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UpdateTaskGroupRequestMultiError, or nil if none found.

type UpdateTaskGroupRequestMultiError

type UpdateTaskGroupRequestMultiError []error

UpdateTaskGroupRequestMultiError is an error wrapping multiple validation errors returned by UpdateTaskGroupRequest.ValidateAll() if the designated constraints aren't met.

func (UpdateTaskGroupRequestMultiError) AllErrors

func (m UpdateTaskGroupRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UpdateTaskGroupRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type UpdateTaskGroupRequestValidationError

type UpdateTaskGroupRequestValidationError struct {
	// contains filtered or unexported fields
}

UpdateTaskGroupRequestValidationError is the validation error returned by UpdateTaskGroupRequest.Validate if the designated constraints aren't met.

func (UpdateTaskGroupRequestValidationError) Cause

Cause function returns cause value.

func (UpdateTaskGroupRequestValidationError) Error

Error satisfies the builtin error interface

func (UpdateTaskGroupRequestValidationError) ErrorName

ErrorName returns error name.

func (UpdateTaskGroupRequestValidationError) Field

Field function returns field value.

func (UpdateTaskGroupRequestValidationError) Key

Key function returns key value.

func (UpdateTaskGroupRequestValidationError) Reason

Reason function returns reason value.

type UpdateTaskRequest

type UpdateTaskRequest struct {
	Id            uint32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	GroupId       uint32  `protobuf:"varint,2,opt,name=group_id,json=groupId,proto3" json:"group_id,omitempty"`
	Name          string  `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Tag           string  `protobuf:"bytes,4,opt,name=tag,proto3" json:"tag,omitempty"`
	Spec          string  `protobuf:"bytes,5,opt,name=spec,proto3" json:"spec,omitempty"`
	SelectType    string  `protobuf:"bytes,6,opt,name=select_type,json=selectType,proto3" json:"select_type,omitempty"`
	WorkerGroupId *uint32 `protobuf:"varint,7,opt,name=worker_group_id,json=workerGroupId,proto3,oneof" json:"worker_group_id,omitempty"`
	WorkerId      *uint32 `protobuf:"varint,8,opt,name=worker_id,json=workerId,proto3,oneof" json:"worker_id,omitempty"`
	ExecType      string  `protobuf:"bytes,9,opt,name=exec_type,json=execType,proto3" json:"exec_type,omitempty"`
	ExecValue     string  `protobuf:"bytes,10,opt,name=exec_value,json=execValue,proto3" json:"exec_value,omitempty"`
	ExpectCode    uint32  `protobuf:"varint,11,opt,name=expect_code,json=expectCode,proto3" json:"expect_code,omitempty"`
	RetryCount    uint32  `protobuf:"varint,12,opt,name=retry_count,json=retryCount,proto3" json:"retry_count,omitempty"`
	RetryWaitTime uint32  `protobuf:"varint,13,opt,name=retry_wait_time,json=retryWaitTime,proto3" json:"retry_wait_time,omitempty"`
	MaxExecTime   uint32  `protobuf:"varint,14,opt,name=max_exec_time,json=maxExecTime,proto3" json:"max_exec_time,omitempty"`
	Description   string  `protobuf:"bytes,15,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTaskRequest) Descriptor deprecated

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

Deprecated: Use UpdateTaskRequest.ProtoReflect.Descriptor instead.

func (*UpdateTaskRequest) GetDescription

func (x *UpdateTaskRequest) GetDescription() string

func (*UpdateTaskRequest) GetExecType

func (x *UpdateTaskRequest) GetExecType() string

func (*UpdateTaskRequest) GetExecValue

func (x *UpdateTaskRequest) GetExecValue() string

func (*UpdateTaskRequest) GetExpectCode

func (x *UpdateTaskRequest) GetExpectCode() uint32

func (*UpdateTaskRequest) GetGroupId

func (x *UpdateTaskRequest) GetGroupId() uint32

func (*UpdateTaskRequest) GetId

func (x *UpdateTaskRequest) GetId() uint32

func (*UpdateTaskRequest) GetMaxExecTime

func (x *UpdateTaskRequest) GetMaxExecTime() uint32

func (*UpdateTaskRequest) GetName

func (x *UpdateTaskRequest) GetName() string

func (*UpdateTaskRequest) GetRetryCount

func (x *UpdateTaskRequest) GetRetryCount() uint32

func (*UpdateTaskRequest) GetRetryWaitTime

func (x *UpdateTaskRequest) GetRetryWaitTime() uint32

func (*UpdateTaskRequest) GetSelectType

func (x *UpdateTaskRequest) GetSelectType() string

func (*UpdateTaskRequest) GetSpec

func (x *UpdateTaskRequest) GetSpec() string

func (*UpdateTaskRequest) GetTag

func (x *UpdateTaskRequest) GetTag() string

func (*UpdateTaskRequest) GetWorkerGroupId

func (x *UpdateTaskRequest) GetWorkerGroupId() uint32

func (*UpdateTaskRequest) GetWorkerId

func (x *UpdateTaskRequest) GetWorkerId() uint32

func (*UpdateTaskRequest) ProtoMessage

func (*UpdateTaskRequest) ProtoMessage()

func (*UpdateTaskRequest) ProtoReflect

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

func (*UpdateTaskRequest) Reset

func (x *UpdateTaskRequest) Reset()

func (*UpdateTaskRequest) String

func (x *UpdateTaskRequest) String() string

func (*UpdateTaskRequest) Validate

func (m *UpdateTaskRequest) Validate() error

Validate checks the field values on UpdateTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*UpdateTaskRequest) ValidateAll

func (m *UpdateTaskRequest) ValidateAll() error

ValidateAll checks the field values on UpdateTaskRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UpdateTaskRequestMultiError, or nil if none found.

type UpdateTaskRequestMultiError

type UpdateTaskRequestMultiError []error

UpdateTaskRequestMultiError is an error wrapping multiple validation errors returned by UpdateTaskRequest.ValidateAll() if the designated constraints aren't met.

func (UpdateTaskRequestMultiError) AllErrors

func (m UpdateTaskRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UpdateTaskRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type UpdateTaskRequestValidationError

type UpdateTaskRequestValidationError struct {
	// contains filtered or unexported fields
}

UpdateTaskRequestValidationError is the validation error returned by UpdateTaskRequest.Validate if the designated constraints aren't met.

func (UpdateTaskRequestValidationError) Cause

Cause function returns cause value.

func (UpdateTaskRequestValidationError) Error

Error satisfies the builtin error interface

func (UpdateTaskRequestValidationError) ErrorName

ErrorName returns error name.

func (UpdateTaskRequestValidationError) Field

Field function returns field value.

func (UpdateTaskRequestValidationError) Key

Key function returns key value.

func (UpdateTaskRequestValidationError) Reason

Reason function returns reason value.

type UpdateWorkerGroupRequest

type UpdateWorkerGroupRequest struct {
	Id          uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWorkerGroupRequest) Descriptor deprecated

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

Deprecated: Use UpdateWorkerGroupRequest.ProtoReflect.Descriptor instead.

func (*UpdateWorkerGroupRequest) GetDescription

func (x *UpdateWorkerGroupRequest) GetDescription() string

func (*UpdateWorkerGroupRequest) GetId

func (x *UpdateWorkerGroupRequest) GetId() uint32

func (*UpdateWorkerGroupRequest) GetName

func (x *UpdateWorkerGroupRequest) GetName() string

func (*UpdateWorkerGroupRequest) ProtoMessage

func (*UpdateWorkerGroupRequest) ProtoMessage()

func (*UpdateWorkerGroupRequest) ProtoReflect

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

func (*UpdateWorkerGroupRequest) Reset

func (x *UpdateWorkerGroupRequest) Reset()

func (*UpdateWorkerGroupRequest) String

func (x *UpdateWorkerGroupRequest) String() string

func (*UpdateWorkerGroupRequest) Validate

func (m *UpdateWorkerGroupRequest) Validate() error

Validate checks the field values on UpdateWorkerGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*UpdateWorkerGroupRequest) ValidateAll

func (m *UpdateWorkerGroupRequest) ValidateAll() error

ValidateAll checks the field values on UpdateWorkerGroupRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UpdateWorkerGroupRequestMultiError, or nil if none found.

type UpdateWorkerGroupRequestMultiError

type UpdateWorkerGroupRequestMultiError []error

UpdateWorkerGroupRequestMultiError is an error wrapping multiple validation errors returned by UpdateWorkerGroupRequest.ValidateAll() if the designated constraints aren't met.

func (UpdateWorkerGroupRequestMultiError) AllErrors

func (m UpdateWorkerGroupRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UpdateWorkerGroupRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type UpdateWorkerGroupRequestValidationError

type UpdateWorkerGroupRequestValidationError struct {
	// contains filtered or unexported fields
}

UpdateWorkerGroupRequestValidationError is the validation error returned by UpdateWorkerGroupRequest.Validate if the designated constraints aren't met.

func (UpdateWorkerGroupRequestValidationError) Cause

Cause function returns cause value.

func (UpdateWorkerGroupRequestValidationError) Error

Error satisfies the builtin error interface

func (UpdateWorkerGroupRequestValidationError) ErrorName

ErrorName returns error name.

func (UpdateWorkerGroupRequestValidationError) Field

Field function returns field value.

func (UpdateWorkerGroupRequestValidationError) Key

Key function returns key value.

func (UpdateWorkerGroupRequestValidationError) Reason

Reason function returns reason value.

type UpdateWorkerRequest

type UpdateWorkerRequest struct {
	Id          uint32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string  `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Ip          string  `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	GroupId     *uint32 `protobuf:"varint,4,opt,name=group_id,json=groupId,proto3,oneof" json:"group_id,omitempty"`
	Description string  `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateWorkerRequest) Descriptor deprecated

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

Deprecated: Use UpdateWorkerRequest.ProtoReflect.Descriptor instead.

func (*UpdateWorkerRequest) GetDescription

func (x *UpdateWorkerRequest) GetDescription() string

func (*UpdateWorkerRequest) GetGroupId

func (x *UpdateWorkerRequest) GetGroupId() uint32

func (*UpdateWorkerRequest) GetId

func (x *UpdateWorkerRequest) GetId() uint32

func (*UpdateWorkerRequest) GetIp

func (x *UpdateWorkerRequest) GetIp() string

func (*UpdateWorkerRequest) GetName

func (x *UpdateWorkerRequest) GetName() string

func (*UpdateWorkerRequest) ProtoMessage

func (*UpdateWorkerRequest) ProtoMessage()

func (*UpdateWorkerRequest) ProtoReflect

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

func (*UpdateWorkerRequest) Reset

func (x *UpdateWorkerRequest) Reset()

func (*UpdateWorkerRequest) String

func (x *UpdateWorkerRequest) String() string

func (*UpdateWorkerRequest) Validate

func (m *UpdateWorkerRequest) Validate() error

Validate checks the field values on UpdateWorkerRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*UpdateWorkerRequest) ValidateAll

func (m *UpdateWorkerRequest) ValidateAll() error

ValidateAll checks the field values on UpdateWorkerRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in UpdateWorkerRequestMultiError, or nil if none found.

type UpdateWorkerRequestMultiError

type UpdateWorkerRequestMultiError []error

UpdateWorkerRequestMultiError is an error wrapping multiple validation errors returned by UpdateWorkerRequest.ValidateAll() if the designated constraints aren't met.

func (UpdateWorkerRequestMultiError) AllErrors

func (m UpdateWorkerRequestMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (UpdateWorkerRequestMultiError) Error

Error returns a concatenation of all the error messages it wraps.

type UpdateWorkerRequestValidationError

type UpdateWorkerRequestValidationError struct {
	// contains filtered or unexported fields
}

UpdateWorkerRequestValidationError is the validation error returned by UpdateWorkerRequest.Validate if the designated constraints aren't met.

func (UpdateWorkerRequestValidationError) Cause

Cause function returns cause value.

func (UpdateWorkerRequestValidationError) Error

Error satisfies the builtin error interface

func (UpdateWorkerRequestValidationError) ErrorName

ErrorName returns error name.

func (UpdateWorkerRequestValidationError) Field

Field function returns field value.

func (UpdateWorkerRequestValidationError) Key

Key function returns key value.

func (UpdateWorkerRequestValidationError) Reason

Reason function returns reason value.

type Worker

type Worker struct {
	Id          uint32       `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string       `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Ip          string       `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
	GroupId     *uint32      `protobuf:"varint,4,opt,name=group_id,json=groupId,proto3,oneof" json:"group_id,omitempty"`
	Status      bool         `protobuf:"varint,5,opt,name=status,proto3" json:"status,omitempty"`
	Description string       `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	CreatedAt   uint32       `protobuf:"varint,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   uint32       `protobuf:"varint,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Group       *WorkerGroup `protobuf:"bytes,9,opt,name=group,proto3,oneof" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*Worker) Descriptor deprecated

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

Deprecated: Use Worker.ProtoReflect.Descriptor instead.

func (*Worker) GetCreatedAt

func (x *Worker) GetCreatedAt() uint32

func (*Worker) GetDescription

func (x *Worker) GetDescription() string

func (*Worker) GetGroup

func (x *Worker) GetGroup() *WorkerGroup

func (*Worker) GetGroupId

func (x *Worker) GetGroupId() uint32

func (*Worker) GetId

func (x *Worker) GetId() uint32

func (*Worker) GetIp

func (x *Worker) GetIp() string

func (*Worker) GetName

func (x *Worker) GetName() string

func (*Worker) GetStatus

func (x *Worker) GetStatus() bool

func (*Worker) GetUpdatedAt

func (x *Worker) GetUpdatedAt() uint32

func (*Worker) ProtoMessage

func (*Worker) ProtoMessage()

func (*Worker) ProtoReflect

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

func (*Worker) Reset

func (x *Worker) Reset()

func (*Worker) String

func (x *Worker) String() string

func (*Worker) Validate

func (m *Worker) Validate() error

Validate checks the field values on Worker with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*Worker) ValidateAll

func (m *Worker) ValidateAll() error

ValidateAll checks the field values on Worker with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WorkerMultiError, or nil if none found.

type WorkerGroup

type WorkerGroup struct {
	Id          uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name        string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	CreatedAt   uint32 `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   uint32 `protobuf:"varint,5,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerGroup) Descriptor deprecated

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

Deprecated: Use WorkerGroup.ProtoReflect.Descriptor instead.

func (*WorkerGroup) GetCreatedAt

func (x *WorkerGroup) GetCreatedAt() uint32

func (*WorkerGroup) GetDescription

func (x *WorkerGroup) GetDescription() string

func (*WorkerGroup) GetId

func (x *WorkerGroup) GetId() uint32

func (*WorkerGroup) GetName

func (x *WorkerGroup) GetName() string

func (*WorkerGroup) GetUpdatedAt

func (x *WorkerGroup) GetUpdatedAt() uint32

func (*WorkerGroup) ProtoMessage

func (*WorkerGroup) ProtoMessage()

func (*WorkerGroup) ProtoReflect

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

func (*WorkerGroup) Reset

func (x *WorkerGroup) Reset()

func (*WorkerGroup) String

func (x *WorkerGroup) String() string

func (*WorkerGroup) Validate

func (m *WorkerGroup) Validate() error

Validate checks the field values on WorkerGroup with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.

func (*WorkerGroup) ValidateAll

func (m *WorkerGroup) ValidateAll() error

ValidateAll checks the field values on WorkerGroup with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in WorkerGroupMultiError, or nil if none found.

type WorkerGroupMultiError

type WorkerGroupMultiError []error

WorkerGroupMultiError is an error wrapping multiple validation errors returned by WorkerGroup.ValidateAll() if the designated constraints aren't met.

func (WorkerGroupMultiError) AllErrors

func (m WorkerGroupMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WorkerGroupMultiError) Error

func (m WorkerGroupMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WorkerGroupValidationError

type WorkerGroupValidationError struct {
	// contains filtered or unexported fields
}

WorkerGroupValidationError is the validation error returned by WorkerGroup.Validate if the designated constraints aren't met.

func (WorkerGroupValidationError) Cause

Cause function returns cause value.

func (WorkerGroupValidationError) Error

Error satisfies the builtin error interface

func (WorkerGroupValidationError) ErrorName

func (e WorkerGroupValidationError) ErrorName() string

ErrorName returns error name.

func (WorkerGroupValidationError) Field

Field function returns field value.

func (WorkerGroupValidationError) Key

Key function returns key value.

func (WorkerGroupValidationError) Reason

Reason function returns reason value.

type WorkerMultiError

type WorkerMultiError []error

WorkerMultiError is an error wrapping multiple validation errors returned by Worker.ValidateAll() if the designated constraints aren't met.

func (WorkerMultiError) AllErrors

func (m WorkerMultiError) AllErrors() []error

AllErrors returns a list of validation violation errors.

func (WorkerMultiError) Error

func (m WorkerMultiError) Error() string

Error returns a concatenation of all the error messages it wraps.

type WorkerValidationError

type WorkerValidationError struct {
	// contains filtered or unexported fields
}

WorkerValidationError is the validation error returned by Worker.Validate if the designated constraints aren't met.

func (WorkerValidationError) Cause

func (e WorkerValidationError) Cause() error

Cause function returns cause value.

func (WorkerValidationError) Error

func (e WorkerValidationError) Error() string

Error satisfies the builtin error interface

func (WorkerValidationError) ErrorName

func (e WorkerValidationError) ErrorName() string

ErrorName returns error name.

func (WorkerValidationError) Field

func (e WorkerValidationError) Field() string

Field function returns field value.

func (WorkerValidationError) Key

func (e WorkerValidationError) Key() bool

Key function returns key value.

func (WorkerValidationError) Reason

func (e WorkerValidationError) Reason() string

Reason function returns reason value.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL