api

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Jan 18, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	CMD_name = map[int32]string{
		0: "Unknown",
		1: "Register",
		2: "Close",
		3: "Status",
		4: "Assign",
		5: "Interrupt",
	}
	CMD_value = map[string]int32{
		"Unknown":   0,
		"Register":  1,
		"Close":     2,
		"Status":    3,
		"Assign":    4,
		"Interrupt": 5,
	}
)

Enum value maps for CMD.

View Source 
var (
	WorkerStatus_name = map[int32]string{
		0: "Idle",
		1: "Busy",
		2: "Closing",
	}
	WorkerStatus_value = map[string]int32{
		"Idle":    0,
		"Busy":    1,
		"Closing": 2,
	}
)

Enum value maps for WorkerStatus.

View Source 
var (
	TaskStatus_name = map[int32]string{
		0: "Running",
		1: "Finished",
		2: "Error",
		3: "Interrupted",
	}
	TaskStatus_value = map[string]int32{
		"Running":     0,
		"Finished":    1,
		"Error":       2,
		"Interrupted": 3,
	}
)

Enum value maps for TaskStatus.

View Source 
var File_api_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AssignPayload 

type AssignPayload struct {
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Data   string `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	FuncId string `protobuf:"bytes,3,opt,name=func_id,json=funcId,proto3" json:"func_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AssignPayload) Descriptor deprecated 

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

Deprecated: Use AssignPayload.ProtoReflect.Descriptor instead.

func (*AssignPayload) GetData 

func (x *AssignPayload) GetData() string

func (*AssignPayload) GetFuncId 

func (x *AssignPayload) GetFuncId() string

func (*AssignPayload) GetTaskId 

func (x *AssignPayload) GetTaskId() string

func (*AssignPayload) ProtoMessage 

func (*AssignPayload) ProtoMessage()

func (*AssignPayload) ProtoReflect 

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

func (*AssignPayload) Reset 

func (x *AssignPayload) Reset()

func (*AssignPayload) String 

func (x *AssignPayload) String() string

type CMD 

type CMD int32
const (
	CMD_Unknown   CMD = 0
	CMD_Register  CMD = 1
	CMD_Close     CMD = 2
	CMD_Status    CMD = 3
	CMD_Assign    CMD = 4
	CMD_Interrupt CMD = 5
)

func (CMD) Descriptor 

func (CMD) Descriptor() protoreflect.EnumDescriptor

func (CMD) Enum 

func (x CMD) Enum() *CMD

func (CMD) EnumDescriptor deprecated 

func (CMD) EnumDescriptor() ([]byte, []int)

Deprecated: Use CMD.Descriptor instead.

func (CMD) Number 

func (x CMD) Number() protoreflect.EnumNumber

func (CMD) String 

func (x CMD) String() string

func (CMD) Type 

func (CMD) Type() protoreflect.EnumType

type EmptyPayload 

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

func (*EmptyPayload) Descriptor deprecated 

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

Deprecated: Use EmptyPayload.ProtoReflect.Descriptor instead.

func (*EmptyPayload) ProtoMessage 

func (*EmptyPayload) ProtoMessage()

func (*EmptyPayload) ProtoReflect 

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

func (*EmptyPayload) Reset 

func (x *EmptyPayload) Reset()

func (*EmptyPayload) String 

func (x *EmptyPayload) String() string

type InterruptPayload 

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

func (*InterruptPayload) Descriptor deprecated 

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

Deprecated: Use InterruptPayload.ProtoReflect.Descriptor instead.

func (*InterruptPayload) GetTaskId 

func (x *InterruptPayload) GetTaskId() string

func (*InterruptPayload) ProtoMessage 

func (*InterruptPayload) ProtoMessage()

func (*InterruptPayload) ProtoReflect 

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

func (*InterruptPayload) Reset 

func (x *InterruptPayload) Reset()

func (*InterruptPayload) String 

func (x *InterruptPayload) String() string

type Msg 

type Msg struct {
	Cmd CMD `protobuf:"varint,1,opt,name=cmd,proto3,enum=api.CMD" json:"cmd,omitempty"`
	// Types that are assignable to Payload:
	//	*Msg_Status
	//	*Msg_Assign
	//	*Msg_Interrupt
	//	*Msg_Empty
	Payload isMsg_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*Msg) Descriptor deprecated 

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

Deprecated: Use Msg.ProtoReflect.Descriptor instead.

func (*Msg) GetAssign 

func (x *Msg) GetAssign() *AssignPayload

func (*Msg) GetCmd 

func (x *Msg) GetCmd() CMD

func (*Msg) GetEmpty 

func (x *Msg) GetEmpty() *EmptyPayload

func (*Msg) GetInterrupt 

func (x *Msg) GetInterrupt() *InterruptPayload

func (*Msg) GetPayload 

func (m *Msg) GetPayload() isMsg_Payload

func (*Msg) GetStatus 

func (x *Msg) GetStatus() *StatusPayload

func (*Msg) ProtoMessage 

func (*Msg) ProtoMessage()

func (*Msg) ProtoReflect 

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

func (*Msg) Reset 

func (x *Msg) Reset()

func (*Msg) String 

func (x *Msg) String() string

type Msg_Assign 

type Msg_Assign struct {
	Assign *AssignPayload `protobuf:"bytes,3,opt,name=assign,proto3,oneof"`
}

type Msg_Empty 

type Msg_Empty struct {
	Empty *EmptyPayload `protobuf:"bytes,5,opt,name=empty,proto3,oneof"`
}

type Msg_Interrupt 

type Msg_Interrupt struct {
	Interrupt *InterruptPayload `protobuf:"bytes,4,opt,name=interrupt,proto3,oneof"`
}

type Msg_Status 

type Msg_Status struct {
	Status *StatusPayload `protobuf:"bytes,2,opt,name=status,proto3,oneof"`
}

type StatusPayload 

type StatusPayload struct {
	WorkStatus WorkerStatus `protobuf:"varint,1,opt,name=work_status,json=workStatus,proto3,enum=api.WorkerStatus" json:"work_status,omitempty"`
	TaskId     string       `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	TaskStatus TaskStatus   `protobuf:"varint,3,opt,name=task_status,json=taskStatus,proto3,enum=api.TaskStatus" json:"task_status,omitempty"`
	ExecResult string       `protobuf:"bytes,4,opt,name=exec_result,json=execResult,proto3" json:"exec_result,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusPayload) Descriptor deprecated 

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

Deprecated: Use StatusPayload.ProtoReflect.Descriptor instead.

func (*StatusPayload) GetExecResult 

func (x *StatusPayload) GetExecResult() string

func (*StatusPayload) GetTaskId 

func (x *StatusPayload) GetTaskId() string

func (*StatusPayload) GetTaskStatus 

func (x *StatusPayload) GetTaskStatus() TaskStatus

func (*StatusPayload) GetWorkStatus 

func (x *StatusPayload) GetWorkStatus() WorkerStatus

func (*StatusPayload) ProtoMessage 

func (*StatusPayload) ProtoMessage()

func (*StatusPayload) ProtoReflect 

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

func (*StatusPayload) Reset 

func (x *StatusPayload) Reset()

func (*StatusPayload) String 

func (x *StatusPayload) String() string

type TaskStatus 

type TaskStatus int32
const (
	TaskStatus_Running     TaskStatus = 0
	TaskStatus_Finished    TaskStatus = 1
	TaskStatus_Error       TaskStatus = 2
	TaskStatus_Interrupted TaskStatus = 3
)

func (TaskStatus) Descriptor 

func (TaskStatus) Descriptor() protoreflect.EnumDescriptor

func (TaskStatus) Enum 

func (x TaskStatus) Enum() *TaskStatus

func (TaskStatus) EnumDescriptor deprecated 

func (TaskStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use TaskStatus.Descriptor instead.

func (TaskStatus) Number 

func (x TaskStatus) Number() protoreflect.EnumNumber

func (TaskStatus) String 

func (x TaskStatus) String() string

func (TaskStatus) Type 

func (TaskStatus) Type() protoreflect.EnumType

type WorkerStatus 

type WorkerStatus int32
const (
	WorkerStatus_Idle    WorkerStatus = 0
	WorkerStatus_Busy    WorkerStatus = 1
	WorkerStatus_Closing WorkerStatus = 2
)

func (WorkerStatus) Descriptor 

func (WorkerStatus) Descriptor() protoreflect.EnumDescriptor

func (WorkerStatus) Enum 

func (x WorkerStatus) Enum() *WorkerStatus

func (WorkerStatus) EnumDescriptor deprecated 

func (WorkerStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use WorkerStatus.Descriptor instead.

func (WorkerStatus) Number 

func (x WorkerStatus) Number() protoreflect.EnumNumber

func (WorkerStatus) String 

func (x WorkerStatus) String() string

func (WorkerStatus) Type 

func (WorkerStatus) Type() protoreflect.EnumType

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.