task

package
v2.7.0-nightly.20230612 Latest Latest
Warning

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

 Go to latest Published: Jun 8, 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

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.