task

package
v2.7.0-nightly.20230607 Latest Latest
Warning

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

Go to latest
Published: Jun 6, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthTask        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTask          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTask = fmt.Errorf("proto: unexpected end of group")
)
View Source
var State_name = map[int32]string{
	0: "UNKNOWN",
	1: "RUNNING",
	2: "SUCCESS",
	3: "FAILURE",
	4: "CLAIMED",
}
View Source
var State_value = map[string]int32{
	"UNKNOWN": 0,
	"RUNNING": 1,
	"SUCCESS": 2,
	"FAILURE": 3,
	"CLAIMED": 4,
}

Functions

This section is empty.

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Group) Descriptor

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

func (*Group) GetGroup

func (m *Group) GetGroup() string

func (*Group) GetNamespace

func (m *Group) GetNamespace() string

func (*Group) Marshal

func (m *Group) Marshal() (dAtA []byte, err error)

func (*Group) MarshalLogObject

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

func (*Group) MarshalTo

func (m *Group) MarshalTo(dAtA []byte) (int, error)

func (*Group) MarshalToSizedBuffer

func (m *Group) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Group) ProtoMessage

func (*Group) ProtoMessage()

func (*Group) Reset

func (m *Group) Reset()

func (*Group) Size

func (m *Group) Size() (n int)

func (*Group) String

func (m *Group) String() string

func (*Group) Unmarshal

func (m *Group) Unmarshal(dAtA []byte) error

func (*Group) XXX_DiscardUnknown

func (m *Group) XXX_DiscardUnknown()

func (*Group) XXX_Marshal

func (m *Group) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Group) XXX_Merge

func (m *Group) XXX_Merge(src proto.Message)

func (*Group) XXX_Size

func (m *Group) XXX_Size() int

func (*Group) XXX_Unmarshal

func (m *Group) XXX_Unmarshal(b []byte) error

type ListTaskRequest

type ListTaskRequest struct {
	Group                *Group   `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListTaskRequest) Descriptor

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

func (*ListTaskRequest) GetGroup

func (m *ListTaskRequest) GetGroup() *Group

func (*ListTaskRequest) Marshal

func (m *ListTaskRequest) Marshal() (dAtA []byte, err error)

func (*ListTaskRequest) MarshalLogObject

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

func (*ListTaskRequest) MarshalTo

func (m *ListTaskRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListTaskRequest) MarshalToSizedBuffer

func (m *ListTaskRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListTaskRequest) ProtoMessage

func (*ListTaskRequest) ProtoMessage()

func (*ListTaskRequest) Reset

func (m *ListTaskRequest) Reset()

func (*ListTaskRequest) Size

func (m *ListTaskRequest) Size() (n int)

func (*ListTaskRequest) String

func (m *ListTaskRequest) String() string

func (*ListTaskRequest) Unmarshal

func (m *ListTaskRequest) Unmarshal(dAtA []byte) error

func (*ListTaskRequest) XXX_DiscardUnknown

func (m *ListTaskRequest) XXX_DiscardUnknown()

func (*ListTaskRequest) XXX_Marshal

func (m *ListTaskRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListTaskRequest) XXX_Merge

func (m *ListTaskRequest) XXX_Merge(src proto.Message)

func (*ListTaskRequest) XXX_Size

func (m *ListTaskRequest) XXX_Size() int

func (*ListTaskRequest) XXX_Unmarshal

func (m *ListTaskRequest) XXX_Unmarshal(b []byte) error

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
)

func (State) EnumDescriptor

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

func (State) String

func (x State) String() string

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TaskInfo) Descriptor

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

func (*TaskInfo) GetGroup

func (m *TaskInfo) GetGroup() *Group

func (*TaskInfo) GetID

func (m *TaskInfo) GetID() string

func (*TaskInfo) GetInputData

func (m *TaskInfo) GetInputData() string

func (*TaskInfo) GetInputType

func (m *TaskInfo) GetInputType() string

func (*TaskInfo) GetReason

func (m *TaskInfo) GetReason() string

func (*TaskInfo) GetState

func (m *TaskInfo) GetState() State

func (*TaskInfo) Marshal

func (m *TaskInfo) Marshal() (dAtA []byte, err error)

func (*TaskInfo) MarshalLogObject

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

func (*TaskInfo) MarshalTo

func (m *TaskInfo) MarshalTo(dAtA []byte) (int, error)

func (*TaskInfo) MarshalToSizedBuffer

func (m *TaskInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TaskInfo) ProtoMessage

func (*TaskInfo) ProtoMessage()

func (*TaskInfo) Reset

func (m *TaskInfo) Reset()

func (*TaskInfo) Size

func (m *TaskInfo) Size() (n int)

func (*TaskInfo) String

func (m *TaskInfo) String() string

func (*TaskInfo) Unmarshal

func (m *TaskInfo) Unmarshal(dAtA []byte) error

func (*TaskInfo) XXX_DiscardUnknown

func (m *TaskInfo) XXX_DiscardUnknown()

func (*TaskInfo) XXX_Marshal

func (m *TaskInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TaskInfo) XXX_Merge

func (m *TaskInfo) XXX_Merge(src proto.Message)

func (*TaskInfo) XXX_Size

func (m *TaskInfo) XXX_Size() int

func (*TaskInfo) XXX_Unmarshal

func (m *TaskInfo) XXX_Unmarshal(b []byte) error

Jump to

Keyboard shortcuts

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