task

Documentation

Index

• Variables
• type Group
  • func (*Group) Descriptor() ([]byte, []int)
  • func (x *Group) GetGroup() string
  • func (x *Group) GetNamespace() string
  • func (x *Group) MarshalLogObject(enc zapcore.ObjectEncoder) error
  • func (*Group) ProtoMessage()
  • func (x *Group) ProtoReflect() protoreflect.Message
  • func (x *Group) Reset()
  • func (x *Group) String() string
• type ListTaskRequest
  • func (*ListTaskRequest) Descriptor() ([]byte, []int)
  • func (x *ListTaskRequest) GetGroup() *Group
  • func (x *ListTaskRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
  • func (*ListTaskRequest) ProtoMessage()
  • func (x *ListTaskRequest) ProtoReflect() protoreflect.Message
  • func (x *ListTaskRequest) Reset()
  • func (x *ListTaskRequest) String() string
• type State
  • func (State) Descriptor() protoreflect.EnumDescriptor
  • func (x State) Enum() *State
  • func (State) EnumDescriptor() ([]byte, []int)
  • func (x State) Number() protoreflect.EnumNumber
  • func (x State) String() string
  • func (State) Type() protoreflect.EnumType
• type TaskInfo
  • func (*TaskInfo) Descriptor() ([]byte, []int)
  • func (x *TaskInfo) GetGroup() *Group
  • func (x *TaskInfo) GetId() string
  • func (x *TaskInfo) GetInputData() string
  • func (x *TaskInfo) GetInputType() string
  • func (x *TaskInfo) GetReason() string
  • func (x *TaskInfo) GetState() State
  • func (x *TaskInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error
  • func (*TaskInfo) ProtoMessage()
  • func (x *TaskInfo) ProtoReflect() protoreflect.Message
  • func (x *TaskInfo) Reset()
  • func (x *TaskInfo) String() string

Variables

var (
	State_name = map[int32]string{
		0: "UNKNOWN",
		1: "RUNNING",
		2: "SUCCESS",
		3: "FAILURE",
		4: "CLAIMED",
	}
	State_value = map[string]int32{
		"UNKNOWN": 0,
		"RUNNING": 1,
		"SUCCESS": 2,
		"FAILURE": 3,
		"CLAIMED": 4,
	}
)

Enum value maps for State.

var File_task_task_proto protoreflect.FileDescriptor

Types

type Group

type Group struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Group     string `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*Group) Descriptor

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

Deprecated: Use Group.ProtoReflect.Descriptor instead.

func (*Group) GetGroup

func (x *Group) GetGroup() string

func (*Group) GetNamespace

func (x *Group) GetNamespace() string

func (*Group) MarshalLogObject

func (x *Group) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*Group) ProtoMessage

func (*Group) ProtoMessage()

func (*Group) ProtoReflect

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

func (*Group) Reset

func (x *Group) Reset()

func (*Group) String

func (x *Group) String() string

type ListTaskRequest

type ListTaskRequest struct {
	Group *Group `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTaskRequest) Descriptor

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

Deprecated: Use ListTaskRequest.ProtoReflect.Descriptor instead.

func (*ListTaskRequest) GetGroup

func (x *ListTaskRequest) GetGroup() *Group

func (*ListTaskRequest) MarshalLogObject

func (x *ListTaskRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error

func (*ListTaskRequest) ProtoMessage

func (*ListTaskRequest) ProtoMessage()

func (*ListTaskRequest) ProtoReflect

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

func (*ListTaskRequest) Reset

func (x *ListTaskRequest) Reset()

func (*ListTaskRequest) String

func (x *ListTaskRequest) String() string

type State

type State int32

const (
	State_UNKNOWN State = 0
	State_RUNNING State = 1
	State_SUCCESS State = 2
	State_FAILURE State = 3
	State_CLAIMED State = 4 // not a real state used by task logic
)

func (State) Descriptor

func (State) Descriptor() protoreflect.EnumDescriptor

func (State) Enum

func (x State) Enum() *State

func (State) EnumDescriptor

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

Deprecated: Use State.Descriptor instead.

func (State) Number

func (x State) Number() protoreflect.EnumNumber

func (State) String

func (x State) String() string

func (State) Type

func (State) Type() protoreflect.EnumType

type TaskInfo

type TaskInfo struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Group     *Group `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	State     State  `protobuf:"varint,3,opt,name=state,proto3,enum=taskapi.State" json:"state,omitempty"`
	Reason    string `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	InputType string `protobuf:"bytes,5,opt,name=input_type,json=inputType,proto3" json:"input_type,omitempty"`
	InputData string `protobuf:"bytes,6,opt,name=input_data,json=inputData,proto3" json:"input_data,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskInfo) Descriptor

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

Deprecated: Use TaskInfo.ProtoReflect.Descriptor instead.

func (*TaskInfo) GetGroup

func (x *TaskInfo) GetGroup() *Group

func (*TaskInfo) GetId

func (x *TaskInfo) GetId() string

func (*TaskInfo) GetInputData

func (x *TaskInfo) GetInputData() string

func (*TaskInfo) GetInputType

func (x *TaskInfo) GetInputType() string

func (*TaskInfo) GetReason

func (x *TaskInfo) GetReason() string

func (*TaskInfo) GetState

func (x *TaskInfo) GetState() State

func (*TaskInfo) MarshalLogObject

func (x *TaskInfo) MarshalLogObject(enc zapcore.ObjectEncoder) error

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