task

Documentation

Index

• Variables
• type Task
  • func (*Task) Descriptor() ([]byte, []int)
  • func (x *Task) GetAttempts() uint32
  • func (x *Task) GetCreatedAt() *timestamppb.Timestamp
  • func (x *Task) GetFailedReason() string
  • func (x *Task) GetId() string
  • func (x *Task) GetProcessedEvent() *event.ProcessedEvent
  • func (x *Task) GetTaskStatus() TaskStatus
  • func (x *Task) GetUpdatedAt() *timestamppb.Timestamp
  • func (*Task) ProtoMessage()
  • func (x *Task) ProtoReflect() protoreflect.Message
  • func (x *Task) Reset()
  • func (x *Task) String() string
• type TaskStatus
  • func (TaskStatus) Descriptor() protoreflect.EnumDescriptor
  • func (x TaskStatus) Enum() *TaskStatus
  • func (TaskStatus) EnumDescriptor() ([]byte, []int)
  • func (x TaskStatus) Number() protoreflect.EnumNumber
  • func (x TaskStatus) String() string
  • func (TaskStatus) Type() protoreflect.EnumType

Variables

var (
	TaskStatus_name = map[int32]string{
		0: "TASK_STATUS_INVALID",
		1: "TASK_STATUS_NOT_EXECUTED",
		2: "TASK_STATUS_RETRIABLE_FAILED",
		3: "TASK_STATUS_UNRETRIABLE_FAILED",
		4: "TASK_STATUS_SUCCESS",
	}
	TaskStatus_value = map[string]int32{
		"TASK_STATUS_INVALID":            0,
		"TASK_STATUS_NOT_EXECUTED":       1,
		"TASK_STATUS_RETRIABLE_FAILED":   2,
		"TASK_STATUS_UNRETRIABLE_FAILED": 3,
		"TASK_STATUS_SUCCESS":            4,
	}
)

Enum value maps for TaskStatus.

var File_task_task_proto protoreflect.FileDescriptor

Types

type Task

type Task struct {
	Id             string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TaskStatus     TaskStatus             `protobuf:"varint,2,opt,name=task_status,json=taskStatus,proto3,enum=task.TaskStatus" json:"task_status,omitempty"`
	Attempts       uint32                 `protobuf:"varint,3,opt,name=attempts,proto3" json:"attempts,omitempty"`
	FailedReason   string                 `protobuf:"bytes,4,opt,name=failed_reason,json=failedReason,proto3" json:"failed_reason,omitempty"`
	ProcessedEvent *event.ProcessedEvent  `protobuf:"bytes,5,opt,name=processed_event,json=processedEvent,proto3" json:"processed_event,omitempty"`
	CreatedAt      *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt      *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Task) Descriptor

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetAttempts

func (x *Task) GetAttempts() uint32

func (*Task) GetCreatedAt

func (x *Task) GetCreatedAt() *timestamppb.Timestamp

func (*Task) GetFailedReason

func (x *Task) GetFailedReason() string

func (*Task) GetId

func (x *Task) GetId() string

func (*Task) GetProcessedEvent

func (x *Task) GetProcessedEvent() *event.ProcessedEvent

func (*Task) GetTaskStatus

func (x *Task) GetTaskStatus() TaskStatus

func (*Task) GetUpdatedAt

func (x *Task) GetUpdatedAt() *timestamppb.Timestamp

func (*Task) ProtoMessage

func (*Task) ProtoMessage()

func (*Task) ProtoReflect

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

func (*Task) Reset

func (x *Task) Reset()

func (*Task) String

func (x *Task) String() string

type TaskStatus

type TaskStatus int32

const (
	TaskStatus_TASK_STATUS_INVALID            TaskStatus = 0
	TaskStatus_TASK_STATUS_NOT_EXECUTED       TaskStatus = 1
	TaskStatus_TASK_STATUS_RETRIABLE_FAILED   TaskStatus = 2
	TaskStatus_TASK_STATUS_UNRETRIABLE_FAILED TaskStatus = 3
	TaskStatus_TASK_STATUS_SUCCESS            TaskStatus = 4
)

func (TaskStatus) Descriptor

func (TaskStatus) Descriptor() protoreflect.EnumDescriptor

func (TaskStatus) Enum

func (x TaskStatus) Enum() *TaskStatus

func (TaskStatus) EnumDescriptor

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