go_micro_srv_task

package
v2.3.3 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_proto_task_task_proto protoreflect.FileDescriptor

Functions

func NewTaskServiceEndpoints 

func NewTaskServiceEndpoints() []*api.Endpoint

func RegisterTaskServiceHandler 

func RegisterTaskServiceHandler(s server.Server, hdlr TaskServiceHandler, opts ...server.HandlerOption) error

Types

type CallOptions 

type CallOptions struct {
	Module     string       `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"`
	Function   string       `protobuf:"bytes,2,opt,name=function,proto3" json:"function,omitempty"`
	Parameters []*Parameter `protobuf:"bytes,3,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

func (*CallOptions) Descriptor deprecated 

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

Deprecated: Use CallOptions.ProtoReflect.Descriptor instead.

func (*CallOptions) GetFunction 

func (x *CallOptions) GetFunction() string

func (*CallOptions) GetModule 

func (x *CallOptions) GetModule() string

func (*CallOptions) GetParameters 

func (x *CallOptions) GetParameters() []*Parameter

func (*CallOptions) ProtoMessage 

func (*CallOptions) ProtoMessage()

func (*CallOptions) ProtoReflect 

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

func (*CallOptions) Reset 

func (x *CallOptions) Reset()

func (*CallOptions) String 

func (x *CallOptions) String() string

type CallResponse 

type CallResponse struct {
	Result string `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// google.protobuf.Any result = 1;
	ErrorMessage string `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*CallResponse) Descriptor deprecated 

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

Deprecated: Use CallResponse.ProtoReflect.Descriptor instead.

func (*CallResponse) GetErrorMessage 

func (x *CallResponse) GetErrorMessage() string

func (*CallResponse) GetResult 

func (x *CallResponse) GetResult() string

func (*CallResponse) ProtoMessage 

func (*CallResponse) ProtoMessage()

func (*CallResponse) ProtoReflect 

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

func (*CallResponse) Reset 

func (x *CallResponse) Reset()

func (*CallResponse) String 

func (x *CallResponse) String() string

type CancelReq 

type CancelReq struct {
	TaskID uint32 `protobuf:"varint,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	// 是否强制取消任务，true为强制取消
	ForcedExit bool `protobuf:"varint,2,opt,name=forcedExit,proto3" json:"forcedExit,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelReq) Descriptor deprecated 

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

Deprecated: Use CancelReq.ProtoReflect.Descriptor instead.

func (*CancelReq) GetForcedExit 

func (x *CancelReq) GetForcedExit() bool

func (*CancelReq) GetTaskID 

func (x *CancelReq) GetTaskID() uint32

func (*CancelReq) ProtoMessage 

func (*CancelReq) ProtoMessage()

func (*CancelReq) ProtoReflect 

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

func (*CancelReq) Reset 

func (x *CancelReq) Reset()

func (*CancelReq) String 

func (x *CancelReq) String() string

type DebugConfigReq 

type DebugConfigReq struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Port    int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*DebugConfigReq) Descriptor deprecated 

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

Deprecated: Use DebugConfigReq.ProtoReflect.Descriptor instead.

func (*DebugConfigReq) GetAddress 

func (x *DebugConfigReq) GetAddress() string

func (*DebugConfigReq) GetPort 

func (x *DebugConfigReq) GetPort() int32

func (*DebugConfigReq) ProtoMessage 

func (*DebugConfigReq) ProtoMessage()

func (*DebugConfigReq) ProtoReflect 

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

func (*DebugConfigReq) Reset 

func (x *DebugConfigReq) Reset()

func (*DebugConfigReq) String 

func (x *DebugConfigReq) String() string

type DebugConfigResponse 

type DebugConfigResponse struct {
	Debug   bool   `protobuf:"varint,1,opt,name=debug,proto3" json:"debug,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Port    int32  `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*DebugConfigResponse) Descriptor deprecated 

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

Deprecated: Use DebugConfigResponse.ProtoReflect.Descriptor instead.

func (*DebugConfigResponse) GetAddress 

func (x *DebugConfigResponse) GetAddress() string

func (*DebugConfigResponse) GetDebug 

func (x *DebugConfigResponse) GetDebug() bool

func (*DebugConfigResponse) GetPort 

func (x *DebugConfigResponse) GetPort() int32

func (*DebugConfigResponse) ProtoMessage 

func (*DebugConfigResponse) ProtoMessage()

func (*DebugConfigResponse) ProtoReflect 

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

func (*DebugConfigResponse) Reset 

func (x *DebugConfigResponse) Reset()

func (*DebugConfigResponse) String 

func (x *DebugConfigResponse) String() string

type DebugReq 

type DebugReq struct {
	Debug bool `protobuf:"varint,1,opt,name=debug,proto3" json:"debug,omitempty"`
	// contains filtered or unexported fields
}

func (*DebugReq) Descriptor deprecated 

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

Deprecated: Use DebugReq.ProtoReflect.Descriptor instead.

func (*DebugReq) GetDebug 

func (x *DebugReq) GetDebug() bool

func (*DebugReq) ProtoMessage 

func (*DebugReq) ProtoMessage()

func (*DebugReq) ProtoReflect 

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

func (*DebugReq) Reset 

func (x *DebugReq) Reset()

func (*DebugReq) String 

func (x *DebugReq) String() string

type ExecuteOptions 

type ExecuteOptions struct {
	TaskID      uint32       `protobuf:"varint,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Priority    uint32       `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	ScriptIndex uint32       `protobuf:"varint,3,opt,name=scriptIndex,proto3" json:"scriptIndex,omitempty"`
	Parameters  []*Parameter `protobuf:"bytes,4,rep,name=parameters,proto3" json:"parameters,omitempty"`
	Description string       `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteOptions) Descriptor deprecated 

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

Deprecated: Use ExecuteOptions.ProtoReflect.Descriptor instead.

func (*ExecuteOptions) GetDescription 

func (x *ExecuteOptions) GetDescription() string

func (*ExecuteOptions) GetParameters 

func (x *ExecuteOptions) GetParameters() []*Parameter

func (*ExecuteOptions) GetPriority 

func (x *ExecuteOptions) GetPriority() uint32

func (*ExecuteOptions) GetScriptIndex 

func (x *ExecuteOptions) GetScriptIndex() uint32

func (*ExecuteOptions) GetTaskID 

func (x *ExecuteOptions) GetTaskID() uint32

func (*ExecuteOptions) ProtoMessage 

func (*ExecuteOptions) ProtoMessage()

func (*ExecuteOptions) ProtoReflect 

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

func (*ExecuteOptions) Reset 

func (x *ExecuteOptions) Reset()

func (*ExecuteOptions) String 

func (x *ExecuteOptions) String() string

type ExecuteResponse 

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

func (*ExecuteResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) ProtoMessage 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect 

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

func (*ExecuteResponse) Reset 

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String 

func (x *ExecuteResponse) String() string

type GPKey 

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

func (*GPKey) Descriptor deprecated 

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

Deprecated: Use GPKey.ProtoReflect.Descriptor instead.

func (*GPKey) GetKey 

func (x *GPKey) GetKey() string

func (*GPKey) ProtoMessage 

func (*GPKey) ProtoMessage()

func (*GPKey) ProtoReflect 

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

func (*GPKey) Reset 

func (x *GPKey) Reset()

func (*GPKey) String 

func (x *GPKey) String() string

type GPQuery 

type GPQuery struct {
	Page    uint32 `protobuf:"varint,1,opt,name=page,proto3" json:"page,omitempty"`
	PerPage uint32 `protobuf:"varint,2,opt,name=perPage,proto3" json:"perPage,omitempty"`
	// contains filtered or unexported fields
}

func (*GPQuery) Descriptor deprecated 

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

Deprecated: Use GPQuery.ProtoReflect.Descriptor instead.

func (*GPQuery) GetPage 

func (x *GPQuery) GetPage() uint32

func (*GPQuery) GetPerPage 

func (x *GPQuery) GetPerPage() uint32

func (*GPQuery) ProtoMessage 

func (*GPQuery) ProtoMessage()

func (*GPQuery) ProtoReflect 

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

func (*GPQuery) Reset 

func (x *GPQuery) Reset()

func (*GPQuery) String 

func (x *GPQuery) String() string

type GpParameter 

type GpParameter struct {
	Type        string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Key         string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value       string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*GpParameter) Descriptor deprecated 

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

Deprecated: Use GpParameter.ProtoReflect.Descriptor instead.

func (*GpParameter) GetDescription 

func (x *GpParameter) GetDescription() string

func (*GpParameter) GetKey 

func (x *GpParameter) GetKey() string

func (*GpParameter) GetType 

func (x *GpParameter) GetType() string

func (*GpParameter) GetValue 

func (x *GpParameter) GetValue() string

func (*GpParameter) ProtoMessage 

func (*GpParameter) ProtoMessage()

func (*GpParameter) ProtoReflect 

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

func (*GpParameter) Reset 

func (x *GpParameter) Reset()

func (*GpParameter) String 

func (x *GpParameter) String() string

type GpParameters 

type GpParameters struct {
	TotalCount uint32         `protobuf:"varint,1,opt,name=totalCount,proto3" json:"totalCount,omitempty"`
	Params     []*GpParameter `protobuf:"bytes,2,rep,name=params,proto3" json:"params,omitempty"`
	// contains filtered or unexported fields
}

func (*GpParameters) Descriptor deprecated 

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

Deprecated: Use GpParameters.ProtoReflect.Descriptor instead.

func (*GpParameters) GetParams 

func (x *GpParameters) GetParams() []*GpParameter

func (*GpParameters) GetTotalCount 

func (x *GpParameters) GetTotalCount() uint32

func (*GpParameters) ProtoMessage 

func (*GpParameters) ProtoMessage()

func (*GpParameters) ProtoReflect 

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

func (*GpParameters) Reset 

func (x *GpParameters) Reset()

func (*GpParameters) String 

func (x *GpParameters) String() string

type LogLevelRequest 

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

func (*LogLevelRequest) Descriptor deprecated 

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

Deprecated: Use LogLevelRequest.ProtoReflect.Descriptor instead.

func (*LogLevelRequest) ProtoMessage 

func (*LogLevelRequest) ProtoMessage()

func (*LogLevelRequest) ProtoReflect 

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

func (*LogLevelRequest) Reset 

func (x *LogLevelRequest) Reset()

func (*LogLevelRequest) String 

func (x *LogLevelRequest) String() string

type LogResponse 

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

func (*LogResponse) Descriptor deprecated 

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

Deprecated: Use LogResponse.ProtoReflect.Descriptor instead.

func (*LogResponse) GetName 

func (x *LogResponse) GetName() string

func (*LogResponse) ProtoMessage 

func (*LogResponse) ProtoMessage()

func (*LogResponse) ProtoReflect 

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

func (*LogResponse) Reset 

func (x *LogResponse) Reset()

func (*LogResponse) String 

func (x *LogResponse) String() string

type Loglevel 

type Loglevel struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Level uint32 `protobuf:"varint,2,opt,name=level,proto3" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*Loglevel) Descriptor deprecated 

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

Deprecated: Use Loglevel.ProtoReflect.Descriptor instead.

func (*Loglevel) GetLevel 

func (x *Loglevel) GetLevel() uint32

func (*Loglevel) GetName 

func (x *Loglevel) GetName() string

func (*Loglevel) ProtoMessage 

func (*Loglevel) ProtoMessage()

func (*Loglevel) ProtoReflect 

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

func (*Loglevel) Reset 

func (x *Loglevel) Reset()

func (*Loglevel) String 

func (x *Loglevel) String() string

type LpParameter 

type LpParameter struct {
	TaskID    uint32     `protobuf:"varint,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Parameter *Parameter `protobuf:"bytes,2,opt,name=parameter,proto3" json:"parameter,omitempty"`
	// contains filtered or unexported fields
}

局部参数需携带任务编号

func (*LpParameter) Descriptor deprecated 

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

Deprecated: Use LpParameter.ProtoReflect.Descriptor instead.

func (*LpParameter) GetParameter 

func (x *LpParameter) GetParameter() *Parameter

func (*LpParameter) GetTaskID 

func (x *LpParameter) GetTaskID() uint32

func (*LpParameter) ProtoMessage 

func (*LpParameter) ProtoMessage()

func (*LpParameter) ProtoReflect 

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

func (*LpParameter) Reset 

func (x *LpParameter) Reset()

func (*LpParameter) String 

func (x *LpParameter) String() string

type LpParameterKey 

type LpParameterKey struct {
	TaskID uint32 `protobuf:"varint,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Key    string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*LpParameterKey) Descriptor deprecated 

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

Deprecated: Use LpParameterKey.ProtoReflect.Descriptor instead.

func (*LpParameterKey) GetKey 

func (x *LpParameterKey) GetKey() string

func (*LpParameterKey) GetTaskID 

func (x *LpParameterKey) GetTaskID() uint32

func (*LpParameterKey) ProtoMessage 

func (*LpParameterKey) ProtoMessage()

func (*LpParameterKey) ProtoReflect 

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

func (*LpParameterKey) Reset 

func (x *LpParameterKey) Reset()

func (*LpParameterKey) String 

func (x *LpParameterKey) String() string

type LpParameterKeys 

type LpParameterKeys struct {
	TaskID uint32   `protobuf:"varint,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Keys   []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*LpParameterKeys) Descriptor deprecated 

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

Deprecated: Use LpParameterKeys.ProtoReflect.Descriptor instead.

func (*LpParameterKeys) GetKeys 

func (x *LpParameterKeys) GetKeys() []string

func (*LpParameterKeys) GetTaskID 

func (x *LpParameterKeys) GetTaskID() uint32

func (*LpParameterKeys) ProtoMessage 

func (*LpParameterKeys) ProtoMessage()

func (*LpParameterKeys) ProtoReflect 

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

func (*LpParameterKeys) Reset 

func (x *LpParameterKeys) Reset()

func (*LpParameterKeys) String 

func (x *LpParameterKeys) String() string

type LpParameters 

type LpParameters struct {
	TaskID     uint32 `protobuf:"varint,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Parameters string `protobuf:"bytes,2,opt,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

func (*LpParameters) Descriptor deprecated 

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

Deprecated: Use LpParameters.ProtoReflect.Descriptor instead.

func (*LpParameters) GetParameters 

func (x *LpParameters) GetParameters() string

func (*LpParameters) GetTaskID 

func (x *LpParameters) GetTaskID() uint32

func (*LpParameters) ProtoMessage 

func (*LpParameters) ProtoMessage()

func (*LpParameters) ProtoReflect 

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

func (*LpParameters) Reset 

func (x *LpParameters) Reset()

func (*LpParameters) String 

func (x *LpParameters) String() string

type NewTaskReq 

type NewTaskReq struct {
	ScriptIndex *wrappers.UInt32Value `protobuf:"bytes,1,opt,name=scriptIndex,proto3" json:"scriptIndex,omitempty"`
	ScriptName  *wrappers.StringValue `protobuf:"bytes,2,opt,name=scriptName,proto3" json:"scriptName,omitempty"`
	Parameters  []*Parameter          `protobuf:"bytes,3,rep,name=parameters,proto3" json:"parameters,omitempty"`
	TaskID      *wrappers.UInt32Value `protobuf:"bytes,4,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Priority    *wrappers.UInt32Value `protobuf:"bytes,5,opt,name=priority,proto3" json:"priority,omitempty"`
	Description *wrappers.StringValue `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

func (*NewTaskReq) Descriptor deprecated 

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

Deprecated: Use NewTaskReq.ProtoReflect.Descriptor instead.

func (*NewTaskReq) GetDescription 

func (x *NewTaskReq) GetDescription() *wrappers.StringValue

func (*NewTaskReq) GetParameters 

func (x *NewTaskReq) GetParameters() []*Parameter

func (*NewTaskReq) GetPriority 

func (x *NewTaskReq) GetPriority() *wrappers.UInt32Value

func (*NewTaskReq) GetScriptIndex 

func (x *NewTaskReq) GetScriptIndex() *wrappers.UInt32Value

func (*NewTaskReq) GetScriptName 

func (x *NewTaskReq) GetScriptName() *wrappers.StringValue

func (*NewTaskReq) GetTaskID 

func (x *NewTaskReq) GetTaskID() *wrappers.UInt32Value

func (*NewTaskReq) ProtoMessage 

func (*NewTaskReq) ProtoMessage()

func (*NewTaskReq) ProtoReflect 

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

func (*NewTaskReq) Reset 

func (x *NewTaskReq) Reset()

func (*NewTaskReq) String 

func (x *NewTaskReq) String() string

type NewTasksReq 

type NewTasksReq struct {
	Tasks []*NewTaskReq `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*NewTasksReq) Descriptor deprecated 

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

Deprecated: Use NewTasksReq.ProtoReflect.Descriptor instead.

func (*NewTasksReq) GetTasks 

func (x *NewTasksReq) GetTasks() []*NewTaskReq

func (*NewTasksReq) ProtoMessage 

func (*NewTasksReq) ProtoMessage()

func (*NewTasksReq) ProtoReflect 

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

func (*NewTasksReq) Reset 

func (x *NewTasksReq) Reset()

func (*NewTasksReq) String 

func (x *NewTasksReq) String() string

type Nop 

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

无参数

func (*Nop) Descriptor deprecated 

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

Deprecated: Use Nop.ProtoReflect.Descriptor instead.

func (*Nop) ProtoMessage 

func (*Nop) ProtoMessage()

func (*Nop) ProtoReflect 

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

func (*Nop) Reset 

func (x *Nop) Reset()

func (*Nop) String 

func (x *Nop) String() string

type Parameter 

type Parameter struct {

	//参数类型，支持string, int, float64，bool四种种类型，默认为string类型
	Type  string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Key   string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*Parameter) Descriptor deprecated 

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

Deprecated: Use Parameter.ProtoReflect.Descriptor instead.

func (*Parameter) GetKey 

func (x *Parameter) GetKey() string

func (*Parameter) GetType 

func (x *Parameter) GetType() string

func (*Parameter) GetValue 

func (x *Parameter) GetValue() string

func (*Parameter) ProtoMessage 

func (*Parameter) ProtoMessage()

func (*Parameter) ProtoReflect 

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

func (*Parameter) Reset 

func (x *Parameter) Reset()

func (*Parameter) String 

func (x *Parameter) String() string

type ParameterKey 

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

func (*ParameterKey) Descriptor deprecated 

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

Deprecated: Use ParameterKey.ProtoReflect.Descriptor instead.

func (*ParameterKey) GetName 

func (x *ParameterKey) GetName() string

func (*ParameterKey) ProtoMessage 

func (*ParameterKey) ProtoMessage()

func (*ParameterKey) ProtoReflect 

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

func (*ParameterKey) Reset 

func (x *ParameterKey) Reset()

func (*ParameterKey) String 

func (x *ParameterKey) String() string

type ParameterKeys 

type ParameterKeys struct {
	TaskID uint32   `protobuf:"varint,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Keys   []string `protobuf:"bytes,2,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*ParameterKeys) Descriptor deprecated 

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

Deprecated: Use ParameterKeys.ProtoReflect.Descriptor instead.

func (*ParameterKeys) GetKeys 

func (x *ParameterKeys) GetKeys() []string

func (*ParameterKeys) GetTaskID 

func (x *ParameterKeys) GetTaskID() uint32

func (*ParameterKeys) ProtoMessage 

func (*ParameterKeys) ProtoMessage()

func (*ParameterKeys) ProtoReflect 

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

func (*ParameterKeys) Reset 

func (x *ParameterKeys) Reset()

func (*ParameterKeys) String 

func (x *ParameterKeys) String() string

type Parameters 

type Parameters struct {
	TaskID     uint32       `protobuf:"varint,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Parameters []*Parameter `protobuf:"bytes,2,rep,name=parameters,proto3" json:"parameters,omitempty"`
	// contains filtered or unexported fields
}

func (*Parameters) Descriptor deprecated 

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

Deprecated: Use Parameters.ProtoReflect.Descriptor instead.

func (*Parameters) GetParameters 

func (x *Parameters) GetParameters() []*Parameter

func (*Parameters) GetTaskID 

func (x *Parameters) GetTaskID() uint32

func (*Parameters) ProtoMessage 

func (*Parameters) ProtoMessage()

func (*Parameters) ProtoReflect 

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

func (*Parameters) Reset 

func (x *Parameters) Reset()

func (*Parameters) String 

func (x *Parameters) String() string

type Query 

type Query struct {
	Limit   uint32      `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset  uint32      `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Page    uint32      `protobuf:"varint,3,opt,name=page,proto3" json:"page,omitempty"`
	PerPage uint32      `protobuf:"varint,4,opt,name=perPage,proto3" json:"perPage,omitempty"`
	Filter  *TaskFilter `protobuf:"bytes,5,opt,name=filter,proto3" json:"filter,omitempty"`
	// contains filtered or unexported fields
}

func (*Query) Descriptor deprecated 

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

Deprecated: Use Query.ProtoReflect.Descriptor instead.

func (*Query) GetFilter 

func (x *Query) GetFilter() *TaskFilter

func (*Query) GetLimit 

func (x *Query) GetLimit() uint32

func (*Query) GetOffset 

func (x *Query) GetOffset() uint32

func (*Query) GetPage 

func (x *Query) GetPage() uint32

func (*Query) GetPerPage 

func (x *Query) GetPerPage() uint32

func (*Query) ProtoMessage 

func (*Query) ProtoMessage()

func (*Query) ProtoReflect 

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

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) String 

func (x *Query) String() string

type Response 

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

func (*Response) Descriptor deprecated 

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

Deprecated: Use Response.ProtoReflect.Descriptor instead.

func (*Response) ProtoMessage 

func (*Response) ProtoMessage()

func (*Response) ProtoReflect 

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

func (*Response) Reset 

func (x *Response) Reset()

func (*Response) String 

func (x *Response) String() string

type SystemGoReq 

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

func (*SystemGoReq) Descriptor deprecated 

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

Deprecated: Use SystemGoReq.ProtoReflect.Descriptor instead.

func (*SystemGoReq) GetScriptIndex 

func (x *SystemGoReq) GetScriptIndex() uint32

func (*SystemGoReq) ProtoMessage 

func (*SystemGoReq) ProtoMessage()

func (*SystemGoReq) ProtoReflect 

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

func (*SystemGoReq) Reset 

func (x *SystemGoReq) Reset()

func (*SystemGoReq) String 

func (x *SystemGoReq) String() string

type SystemGoResponse 

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

func (*SystemGoResponse) Descriptor deprecated 

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

Deprecated: Use SystemGoResponse.ProtoReflect.Descriptor instead.

func (*SystemGoResponse) GetScriptIndex 

func (x *SystemGoResponse) GetScriptIndex() uint32

func (*SystemGoResponse) ProtoMessage 

func (*SystemGoResponse) ProtoMessage()

func (*SystemGoResponse) ProtoReflect 

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

func (*SystemGoResponse) Reset 

func (x *SystemGoResponse) Reset()

func (*SystemGoResponse) String 

func (x *SystemGoResponse) String() string

type TaskFilter 

type TaskFilter struct {
	And            []*TaskFilter         `protobuf:"bytes,1,rep,name=and,proto3" json:"and,omitempty"`
	Or             []*TaskFilter         `protobuf:"bytes,2,rep,name=or,proto3" json:"or,omitempty"`
	Id             *wrappers.Int32Value  `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	IdIn           []int32               `protobuf:"varint,4,rep,packed,name=idIn,proto3" json:"idIn,omitempty"`
	Priority       *wrappers.Int32Value  `protobuf:"bytes,8,opt,name=priority,proto3" json:"priority,omitempty"`
	PriorityLT     *wrappers.Int32Value  `protobuf:"bytes,36,opt,name=priorityLT,proto3" json:"priorityLT,omitempty"`
	PriorityGT     *wrappers.Int32Value  `protobuf:"bytes,37,opt,name=priorityGT,proto3" json:"priorityGT,omitempty"`
	BeginLT        *wrappers.StringValue `protobuf:"bytes,10,opt,name=beginLT,proto3" json:"beginLT,omitempty"`
	BeginGT        *wrappers.StringValue `protobuf:"bytes,11,opt,name=beginGT,proto3" json:"beginGT,omitempty"`
	EndLT          *wrappers.StringValue `protobuf:"bytes,12,opt,name=endLT,proto3" json:"endLT,omitempty"`
	EndGT          *wrappers.StringValue `protobuf:"bytes,13,opt,name=endGT,proto3" json:"endGT,omitempty"`
	OrderIndex     *wrappers.Int32Value  `protobuf:"bytes,7,opt,name=orderIndex,proto3" json:"orderIndex,omitempty"`
	ScriptIndex    *wrappers.Int32Value  `protobuf:"bytes,9,opt,name=scriptIndex,proto3" json:"scriptIndex,omitempty"`
	Phase          *wrappers.Int32Value  `protobuf:"bytes,21,opt,name=phase,proto3" json:"phase,omitempty"`
	PhaseIn        []int32               `protobuf:"varint,29,rep,packed,name=phaseIn,proto3" json:"phaseIn,omitempty"`
	PhaseNotIn     []int32               `protobuf:"varint,31,rep,packed,name=phaseNotIn,proto3" json:"phaseNotIn,omitempty"`
	PhaseGT        *wrappers.Int32Value  `protobuf:"bytes,32,opt,name=phaseGT,proto3" json:"phaseGT,omitempty"`
	PhaseLT        *wrappers.Int32Value  `protobuf:"bytes,33,opt,name=phaseLT,proto3" json:"phaseLT,omitempty"`
	PhaseGE        *wrappers.Int32Value  `protobuf:"bytes,34,opt,name=phaseGE,proto3" json:"phaseGE,omitempty"`
	PhaseLE        *wrappers.Int32Value  `protobuf:"bytes,35,opt,name=phaseLE,proto3" json:"phaseLE,omitempty"`
	OriginStation  *wrappers.Int32Value  `protobuf:"bytes,14,opt,name=originStation,proto3" json:"originStation,omitempty"`
	TargetStation  *wrappers.Int32Value  `protobuf:"bytes,15,opt,name=targetStation,proto3" json:"targetStation,omitempty"`
	AgvID          *wrappers.Int32Value  `protobuf:"bytes,16,opt,name=agvID,proto3" json:"agvID,omitempty"`
	AgvInitPoint   *wrappers.Int32Value  `protobuf:"bytes,17,opt,name=agvInitPoint,proto3" json:"agvInitPoint,omitempty"`
	MaterialID     *wrappers.Int64Value  `protobuf:"bytes,18,opt,name=materialID,proto3" json:"materialID,omitempty"`
	Parameter      *TaskParameterFilter  `protobuf:"bytes,20,opt,name=parameter,proto3" json:"parameter,omitempty"`
	ErrorCode      *wrappers.Int32Value  `protobuf:"bytes,19,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	Error          *wrappers.StringValue `protobuf:"bytes,22,opt,name=error,proto3" json:"error,omitempty"`
	EntranceID     *wrappers.Int32Value  `protobuf:"bytes,23,opt,name=entranceID,proto3" json:"entranceID,omitempty"`
	OrderType      *wrappers.Int32Value  `protobuf:"bytes,24,opt,name=orderType,proto3" json:"orderType,omitempty"`
	OrderTypeIn    []int32               `protobuf:"varint,28,rep,packed,name=orderTypeIn,proto3" json:"orderTypeIn,omitempty"`
	OrderTypeNotIn []int32               `protobuf:"varint,30,rep,packed,name=orderTypeNotIn,proto3" json:"orderTypeNotIn,omitempty"`
	RackID         *wrappers.Int32Value  `protobuf:"bytes,25,opt,name=rackID,proto3" json:"rackID,omitempty"`
	OrderByTime    *wrappers.BoolValue   `protobuf:"bytes,40,opt,name=orderByTime,proto3" json:"orderByTime,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskFilter) Descriptor deprecated 

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

Deprecated: Use TaskFilter.ProtoReflect.Descriptor instead.

func (*TaskFilter) GetAgvID 

func (x *TaskFilter) GetAgvID() *wrappers.Int32Value

func (*TaskFilter) GetAgvInitPoint 

func (x *TaskFilter) GetAgvInitPoint() *wrappers.Int32Value

func (*TaskFilter) GetAnd 

func (x *TaskFilter) GetAnd() []*TaskFilter

func (*TaskFilter) GetBeginGT 

func (x *TaskFilter) GetBeginGT() *wrappers.StringValue

func (*TaskFilter) GetBeginLT 

func (x *TaskFilter) GetBeginLT() *wrappers.StringValue

func (*TaskFilter) GetEndGT 

func (x *TaskFilter) GetEndGT() *wrappers.StringValue

func (*TaskFilter) GetEndLT 

func (x *TaskFilter) GetEndLT() *wrappers.StringValue

func (*TaskFilter) GetEntranceID 

func (x *TaskFilter) GetEntranceID() *wrappers.Int32Value

func (*TaskFilter) GetError 

func (x *TaskFilter) GetError() *wrappers.StringValue

func (*TaskFilter) GetErrorCode 

func (x *TaskFilter) GetErrorCode() *wrappers.Int32Value

func (*TaskFilter) GetId 

func (x *TaskFilter) GetId() *wrappers.Int32Value

func (*TaskFilter) GetIdIn 

func (x *TaskFilter) GetIdIn() []int32

func (*TaskFilter) GetMaterialID 

func (x *TaskFilter) GetMaterialID() *wrappers.Int64Value

func (*TaskFilter) GetOr 

func (x *TaskFilter) GetOr() []*TaskFilter

func (*TaskFilter) GetOrderByTime 

func (x *TaskFilter) GetOrderByTime() *wrappers.BoolValue

func (*TaskFilter) GetOrderIndex 

func (x *TaskFilter) GetOrderIndex() *wrappers.Int32Value

func (*TaskFilter) GetOrderType 

func (x *TaskFilter) GetOrderType() *wrappers.Int32Value

func (*TaskFilter) GetOrderTypeIn 

func (x *TaskFilter) GetOrderTypeIn() []int32

func (*TaskFilter) GetOrderTypeNotIn 

func (x *TaskFilter) GetOrderTypeNotIn() []int32

func (*TaskFilter) GetOriginStation 

func (x *TaskFilter) GetOriginStation() *wrappers.Int32Value

func (*TaskFilter) GetParameter 

func (x *TaskFilter) GetParameter() *TaskParameterFilter

func (*TaskFilter) GetPhase 

func (x *TaskFilter) GetPhase() *wrappers.Int32Value

func (*TaskFilter) GetPhaseGE 

func (x *TaskFilter) GetPhaseGE() *wrappers.Int32Value

func (*TaskFilter) GetPhaseGT 

func (x *TaskFilter) GetPhaseGT() *wrappers.Int32Value

func (*TaskFilter) GetPhaseIn 

func (x *TaskFilter) GetPhaseIn() []int32

func (*TaskFilter) GetPhaseLE 

func (x *TaskFilter) GetPhaseLE() *wrappers.Int32Value

func (*TaskFilter) GetPhaseLT 

func (x *TaskFilter) GetPhaseLT() *wrappers.Int32Value

func (*TaskFilter) GetPhaseNotIn 

func (x *TaskFilter) GetPhaseNotIn() []int32

func (*TaskFilter) GetPriority 

func (x *TaskFilter) GetPriority() *wrappers.Int32Value

func (*TaskFilter) GetPriorityGT 

func (x *TaskFilter) GetPriorityGT() *wrappers.Int32Value

func (*TaskFilter) GetPriorityLT 

func (x *TaskFilter) GetPriorityLT() *wrappers.Int32Value

func (*TaskFilter) GetRackID 

func (x *TaskFilter) GetRackID() *wrappers.Int32Value

func (*TaskFilter) GetScriptIndex 

func (x *TaskFilter) GetScriptIndex() *wrappers.Int32Value

func (*TaskFilter) GetTargetStation 

func (x *TaskFilter) GetTargetStation() *wrappers.Int32Value

func (*TaskFilter) ProtoMessage 

func (*TaskFilter) ProtoMessage()

func (*TaskFilter) ProtoReflect 

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

func (*TaskFilter) Reset 

func (x *TaskFilter) Reset()

func (*TaskFilter) String 

func (x *TaskFilter) String() string

type TaskID 

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

func (*TaskID) Descriptor deprecated 

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

Deprecated: Use TaskID.ProtoReflect.Descriptor instead.

func (*TaskID) GetId 

func (x *TaskID) GetId() uint32

func (*TaskID) ProtoMessage 

func (*TaskID) ProtoMessage()

func (*TaskID) ProtoReflect 

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

func (*TaskID) Reset 

func (x *TaskID) Reset()

func (*TaskID) String 

func (x *TaskID) String() string

type TaskIDs 

type TaskIDs struct {
	Ids []uint32 `protobuf:"varint,1,rep,packed,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskIDs) Descriptor deprecated 

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

Deprecated: Use TaskIDs.ProtoReflect.Descriptor instead.

func (*TaskIDs) GetIds 

func (x *TaskIDs) GetIds() []uint32

func (*TaskIDs) ProtoMessage 

func (*TaskIDs) ProtoMessage()

func (*TaskIDs) ProtoReflect 

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

func (*TaskIDs) Reset 

func (x *TaskIDs) Reset()

func (*TaskIDs) String 

func (x *TaskIDs) String() string

type TaskInfo 

type TaskInfo struct {
	TaskID        uint32       `protobuf:"varint,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Priority      uint32       `protobuf:"varint,2,opt,name=priority,proto3" json:"priority,omitempty"`
	BeginTime     string       `protobuf:"bytes,3,opt,name=beginTime,proto3" json:"beginTime,omitempty"`
	EndTime       string       `protobuf:"bytes,4,opt,name=endTime,proto3" json:"endTime,omitempty"`
	OrderIndex    int32        `protobuf:"varint,5,opt,name=orderIndex,proto3" json:"orderIndex,omitempty"`
	ScriptIndex   uint32       `protobuf:"varint,6,opt,name=scriptIndex,proto3" json:"scriptIndex,omitempty"`
	Phase         int32        `protobuf:"varint,7,opt,name=phase,proto3" json:"phase,omitempty"`
	OriginStation uint32       `protobuf:"varint,8,opt,name=originStation,proto3" json:"originStation,omitempty"`
	TargetStation uint32       `protobuf:"varint,9,opt,name=targetStation,proto3" json:"targetStation,omitempty"`
	AgvID         uint32       `protobuf:"varint,10,opt,name=agvID,proto3" json:"agvID,omitempty"`
	AgvInitPoint  uint32       `protobuf:"varint,11,opt,name=agvInitPoint,proto3" json:"agvInitPoint,omitempty"`
	MaterialID    int64        `protobuf:"varint,12,opt,name=materialID,proto3" json:"materialID,omitempty"`
	Parameters    []*Parameter `protobuf:"bytes,13,rep,name=parameters,proto3" json:"parameters,omitempty"`
	ErrorCode     int32        `protobuf:"varint,14,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	Error         string       `protobuf:"bytes,15,opt,name=error,proto3" json:"error,omitempty"`
	Description   string       `protobuf:"bytes,16,opt,name=description,proto3" json:"description,omitempty"`
	EntranceID    uint32       `protobuf:"varint,17,opt,name=entranceID,proto3" json:"entranceID,omitempty"`
	OrderType     uint32       `protobuf:"varint,18,opt,name=orderType,proto3" json:"orderType,omitempty"`
	RackID        uint32       `protobuf:"varint,19,opt,name=rackID,proto3" json:"rackID,omitempty"`
	TimeDuration  uint32       `protobuf:"varint,20,opt,name=timeDuration,proto3" json:"timeDuration,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskInfo) Descriptor deprecated 

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

Deprecated: Use TaskInfo.ProtoReflect.Descriptor instead.

func (*TaskInfo) GetAgvID 

func (x *TaskInfo) GetAgvID() uint32

func (*TaskInfo) GetAgvInitPoint 

func (x *TaskInfo) GetAgvInitPoint() uint32

func (*TaskInfo) GetBeginTime 

func (x *TaskInfo) GetBeginTime() string

func (*TaskInfo) GetDescription 

func (x *TaskInfo) GetDescription() string

func (*TaskInfo) GetEndTime 

func (x *TaskInfo) GetEndTime() string

func (*TaskInfo) GetEntranceID 

func (x *TaskInfo) GetEntranceID() uint32

func (*TaskInfo) GetError 

func (x *TaskInfo) GetError() string

func (*TaskInfo) GetErrorCode 

func (x *TaskInfo) GetErrorCode() int32

func (*TaskInfo) GetMaterialID 

func (x *TaskInfo) GetMaterialID() int64

func (*TaskInfo) GetOrderIndex 

func (x *TaskInfo) GetOrderIndex() int32

func (*TaskInfo) GetOrderType 

func (x *TaskInfo) GetOrderType() uint32

func (*TaskInfo) GetOriginStation 

func (x *TaskInfo) GetOriginStation() uint32

func (*TaskInfo) GetParameters 

func (x *TaskInfo) GetParameters() []*Parameter

func (*TaskInfo) GetPhase 

func (x *TaskInfo) GetPhase() int32

func (*TaskInfo) GetPriority 

func (x *TaskInfo) GetPriority() uint32

func (*TaskInfo) GetRackID 

func (x *TaskInfo) GetRackID() uint32

func (*TaskInfo) GetScriptIndex 

func (x *TaskInfo) GetScriptIndex() uint32

func (*TaskInfo) GetTargetStation 

func (x *TaskInfo) GetTargetStation() uint32

func (*TaskInfo) GetTaskID 

func (x *TaskInfo) GetTaskID() uint32

func (*TaskInfo) GetTimeDuration 

func (x *TaskInfo) GetTimeDuration() uint32

func (*TaskInfo) ProtoMessage 

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) ProtoReflect 

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

func (*TaskInfo) Reset 

func (x *TaskInfo) Reset()

func (*TaskInfo) String 

func (x *TaskInfo) String() string

type TaskInfos 

type TaskInfos struct {
	Tasks      []*TaskInfo `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	Totalpages uint32      `protobuf:"varint,2,opt,name=totalpages,proto3" json:"totalpages,omitempty"`
	Currpages  uint32      `protobuf:"varint,3,opt,name=currpages,proto3" json:"currpages,omitempty"`
	Totals     uint32      `protobuf:"varint,4,opt,name=totals,proto3" json:"totals,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskInfos) Descriptor deprecated 

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

Deprecated: Use TaskInfos.ProtoReflect.Descriptor instead.

func (*TaskInfos) GetCurrpages 

func (x *TaskInfos) GetCurrpages() uint32

func (*TaskInfos) GetTasks 

func (x *TaskInfos) GetTasks() []*TaskInfo

func (*TaskInfos) GetTotalpages 

func (x *TaskInfos) GetTotalpages() uint32

func (*TaskInfos) GetTotals 

func (x *TaskInfos) GetTotals() uint32

func (*TaskInfos) ProtoMessage 

func (*TaskInfos) ProtoMessage()

func (*TaskInfos) ProtoReflect 

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

func (*TaskInfos) Reset 

func (x *TaskInfos) Reset()

func (*TaskInfos) String 

func (x *TaskInfos) String() string

type TaskParameterFilter 

type TaskParameterFilter struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Type  string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskParameterFilter) Descriptor deprecated 

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

Deprecated: Use TaskParameterFilter.ProtoReflect.Descriptor instead.

func (*TaskParameterFilter) GetKey 

func (x *TaskParameterFilter) GetKey() string

func (*TaskParameterFilter) GetType 

func (x *TaskParameterFilter) GetType() string

func (*TaskParameterFilter) GetValue 

func (x *TaskParameterFilter) GetValue() string

func (*TaskParameterFilter) ProtoMessage 

func (*TaskParameterFilter) ProtoMessage()

func (*TaskParameterFilter) ProtoReflect 

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

func (*TaskParameterFilter) Reset 

func (x *TaskParameterFilter) Reset()

func (*TaskParameterFilter) String 

func (x *TaskParameterFilter) String() string

type TaskService 

type TaskService interface {
	//新任务
	New(ctx context.Context, in *NewTaskReq, opts ...client.CallOption) (*TaskID, error)
	// 暂停任务
	Pause(ctx context.Context, in *TaskID, opts ...client.CallOption) (*Response, error)
	// 取消任务
	Cancel(ctx context.Context, in *CancelReq, opts ...client.CallOption) (*Response, error)
	UpdateTask(ctx context.Context, in *UpdateTaskReq, opts ...client.CallOption) (*Response, error)
	BatchNew(ctx context.Context, in *NewTasksReq, opts ...client.CallOption) (*Response, error)
	BatchCancel(ctx context.Context, in *TaskIDs, opts ...client.CallOption) (*Response, error)
	// 设置任务参数
	SetParameters(ctx context.Context, in *LpParameters, opts ...client.CallOption) (*Response, error)
	// 删除任务参数
	DeleteParameters(ctx context.Context, in *LpParameterKeys, opts ...client.CallOption) (*Response, error)
	// 根据查询条件获取任务
	GetTask(ctx context.Context, in *TaskID, opts ...client.CallOption) (*TaskInfo, error)
	// 根据查询条件获取历史任务
	GetHistoryTask(ctx context.Context, in *TaskID, opts ...client.CallOption) (*TaskInfo, error)
	// 根据查询条件获取任务
	GetTasks(ctx context.Context, in *Query, opts ...client.CallOption) (*TaskInfos, error)
	// 根据查询条件获取历史任务
	GetHistoryTasks(ctx context.Context, in *Query, opts ...client.CallOption) (*TaskInfos, error)
	// 调用脚本的函数
	Call(ctx context.Context, in *CallOptions, opts ...client.CallOption) (*CallResponse, error)
	// 执行脚本
	Execute(ctx context.Context, in *ExecuteOptions, opts ...client.CallOption) (*ExecuteResponse, error)
	SetGP(ctx context.Context, in *GpParameter, opts ...client.CallOption) (*Response, error)
	DelGP(ctx context.Context, in *GPKey, opts ...client.CallOption) (*Response, error)
	GetGP(ctx context.Context, in *GPKey, opts ...client.CallOption) (*GpParameter, error)
	GetGPs(ctx context.Context, in *GPQuery, opts ...client.CallOption) (*GpParameters, error)
	ConfigSystemGo(ctx context.Context, in *SystemGoReq, opts ...client.CallOption) (*Response, error)
	RestartSystemGo(ctx context.Context, in *Nop, opts ...client.CallOption) (*Response, error)
	GetSystemGoConfig(ctx context.Context, in *Nop, opts ...client.CallOption) (*SystemGoResponse, error)
	Debug(ctx context.Context, in *DebugReq, opts ...client.CallOption) (*Response, error)
	DebugConfig(ctx context.Context, in *DebugConfigReq, opts ...client.CallOption) (*Response, error)
	GetDebugConfig(ctx context.Context, in *Nop, opts ...client.CallOption) (*DebugConfigResponse, error)
	//获取服务日志等级
	GetLogLevel(ctx context.Context, in *LogLevelRequest, opts ...client.CallOption) (*Loglevel, error)
	//设置服务日志等级
	SetLogLevel(ctx context.Context, in *Loglevel, opts ...client.CallOption) (*LogResponse, error)
}

func NewTaskService 

func NewTaskService(name string, c client.Client) TaskService

type TaskServiceHandler 

type TaskServiceHandler interface {
	//新任务
	New(context.Context, *NewTaskReq, *TaskID) error
	// 暂停任务
	Pause(context.Context, *TaskID, *Response) error
	// 取消任务
	Cancel(context.Context, *CancelReq, *Response) error
	UpdateTask(context.Context, *UpdateTaskReq, *Response) error
	BatchNew(context.Context, *NewTasksReq, *Response) error
	BatchCancel(context.Context, *TaskIDs, *Response) error
	// 设置任务参数
	SetParameters(context.Context, *LpParameters, *Response) error
	// 删除任务参数
	DeleteParameters(context.Context, *LpParameterKeys, *Response) error
	// 根据查询条件获取任务
	GetTask(context.Context, *TaskID, *TaskInfo) error
	// 根据查询条件获取历史任务
	GetHistoryTask(context.Context, *TaskID, *TaskInfo) error
	// 根据查询条件获取任务
	GetTasks(context.Context, *Query, *TaskInfos) error
	// 根据查询条件获取历史任务
	GetHistoryTasks(context.Context, *Query, *TaskInfos) error
	// 调用脚本的函数
	Call(context.Context, *CallOptions, *CallResponse) error
	// 执行脚本
	Execute(context.Context, *ExecuteOptions, *ExecuteResponse) error
	SetGP(context.Context, *GpParameter, *Response) error
	DelGP(context.Context, *GPKey, *Response) error
	GetGP(context.Context, *GPKey, *GpParameter) error
	GetGPs(context.Context, *GPQuery, *GpParameters) error
	ConfigSystemGo(context.Context, *SystemGoReq, *Response) error
	RestartSystemGo(context.Context, *Nop, *Response) error
	GetSystemGoConfig(context.Context, *Nop, *SystemGoResponse) error
	Debug(context.Context, *DebugReq, *Response) error
	DebugConfig(context.Context, *DebugConfigReq, *Response) error
	GetDebugConfig(context.Context, *Nop, *DebugConfigResponse) error
	//获取服务日志等级
	GetLogLevel(context.Context, *LogLevelRequest, *Loglevel) error
	//设置服务日志等级
	SetLogLevel(context.Context, *Loglevel, *LogResponse) error
}

type UpdateTask 

type UpdateTask struct {
	OrderIndex    *wrappers.Int32Value  `protobuf:"bytes,1,opt,name=orderIndex,proto3" json:"orderIndex,omitempty"`
	Priority      *wrappers.Int32Value  `protobuf:"bytes,2,opt,name=priority,proto3" json:"priority,omitempty"`
	ScriptIndex   *wrappers.Int32Value  `protobuf:"bytes,3,opt,name=scriptIndex,proto3" json:"scriptIndex,omitempty"`
	Description   *wrappers.StringValue `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	OriginStation *wrappers.Int32Value  `protobuf:"bytes,5,opt,name=originStation,proto3" json:"originStation,omitempty"`
	TargetStation *wrappers.Int32Value  `protobuf:"bytes,6,opt,name=targetStation,proto3" json:"targetStation,omitempty"`
	AgvID         *wrappers.Int32Value  `protobuf:"bytes,7,opt,name=agvID,proto3" json:"agvID,omitempty"`
	AgvInitPoint  *wrappers.Int32Value  `protobuf:"bytes,8,opt,name=agvInitPoint,proto3" json:"agvInitPoint,omitempty"`
	MaterialID    *wrappers.Int64Value  `protobuf:"bytes,9,opt,name=materialID,proto3" json:"materialID,omitempty"`
	ErrorCode     *wrappers.Int32Value  `protobuf:"bytes,10,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	Error         *wrappers.StringValue `protobuf:"bytes,11,opt,name=error,proto3" json:"error,omitempty"`
	Phase         *wrappers.Int32Value  `protobuf:"bytes,12,opt,name=phase,proto3" json:"phase,omitempty"`
	EntranceID    *wrappers.Int32Value  `protobuf:"bytes,13,opt,name=entranceID,proto3" json:"entranceID,omitempty"`
	OrderType     *wrappers.Int32Value  `protobuf:"bytes,14,opt,name=orderType,proto3" json:"orderType,omitempty"`
	RackID        *wrappers.Int32Value  `protobuf:"bytes,15,opt,name=rackID,proto3" json:"rackID,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTask) Descriptor deprecated 

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

Deprecated: Use UpdateTask.ProtoReflect.Descriptor instead.

func (*UpdateTask) GetAgvID 

func (x *UpdateTask) GetAgvID() *wrappers.Int32Value

func (*UpdateTask) GetAgvInitPoint 

func (x *UpdateTask) GetAgvInitPoint() *wrappers.Int32Value

func (*UpdateTask) GetDescription 

func (x *UpdateTask) GetDescription() *wrappers.StringValue

func (*UpdateTask) GetEntranceID 

func (x *UpdateTask) GetEntranceID() *wrappers.Int32Value

func (*UpdateTask) GetError 

func (x *UpdateTask) GetError() *wrappers.StringValue

func (*UpdateTask) GetErrorCode 

func (x *UpdateTask) GetErrorCode() *wrappers.Int32Value

func (*UpdateTask) GetMaterialID 

func (x *UpdateTask) GetMaterialID() *wrappers.Int64Value

func (*UpdateTask) GetOrderIndex 

func (x *UpdateTask) GetOrderIndex() *wrappers.Int32Value

func (*UpdateTask) GetOrderType 

func (x *UpdateTask) GetOrderType() *wrappers.Int32Value

func (*UpdateTask) GetOriginStation 

func (x *UpdateTask) GetOriginStation() *wrappers.Int32Value

func (*UpdateTask) GetPhase 

func (x *UpdateTask) GetPhase() *wrappers.Int32Value

func (*UpdateTask) GetPriority 

func (x *UpdateTask) GetPriority() *wrappers.Int32Value

func (*UpdateTask) GetRackID 

func (x *UpdateTask) GetRackID() *wrappers.Int32Value

func (*UpdateTask) GetScriptIndex 

func (x *UpdateTask) GetScriptIndex() *wrappers.Int32Value

func (*UpdateTask) GetTargetStation 

func (x *UpdateTask) GetTargetStation() *wrappers.Int32Value

func (*UpdateTask) ProtoMessage 

func (*UpdateTask) ProtoMessage()

func (*UpdateTask) ProtoReflect 

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

func (*UpdateTask) Reset 

func (x *UpdateTask) Reset()

func (*UpdateTask) String 

func (x *UpdateTask) String() string

type UpdateTaskReq 

type UpdateTaskReq struct {
	Id   uint32      `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Task *UpdateTask `protobuf:"bytes,2,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTaskReq) Descriptor deprecated 

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

Deprecated: Use UpdateTaskReq.ProtoReflect.Descriptor instead.

func (*UpdateTaskReq) GetId 

func (x *UpdateTaskReq) GetId() uint32

func (*UpdateTaskReq) GetTask 

func (x *UpdateTaskReq) GetTask() *UpdateTask

func (*UpdateTaskReq) ProtoMessage 

func (*UpdateTaskReq) ProtoMessage()

func (*UpdateTaskReq) ProtoReflect 

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

func (*UpdateTaskReq) Reset 

func (x *UpdateTaskReq) Reset()

func (*UpdateTaskReq) String 

func (x *UpdateTaskReq) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.