taskspb

Documentation

Overview

Package taskspb contains Cloud Tasks proto definations which will be used for tasks workflow management.

Index

• Variables
• type BatchCancelTask
  • func (*BatchCancelTask) Descriptor() ([]byte, []int)
  • func (x *BatchCancelTask) GetKillRunning() bool
  • func (x *BatchCancelTask) GetPurpose() string
  • func (x *BatchCancelTask) GetRetries() int32
  • func (x *BatchCancelTask) GetTasks() []string
  • func (*BatchCancelTask) ProtoMessage()
  • func (x *BatchCancelTask) ProtoReflect() protoreflect.Message
  • func (x *BatchCancelTask) Reset()
  • func (x *BatchCancelTask) String() string
• type CancelChildrenTask
  • func (*CancelChildrenTask) Descriptor() ([]byte, []int)
  • func (x *CancelChildrenTask) GetTaskId() string
  • func (*CancelChildrenTask) ProtoMessage()
  • func (x *CancelChildrenTask) ProtoReflect() protoreflect.Message
  • func (x *CancelChildrenTask) Reset()
  • func (x *CancelChildrenTask) String() string
• type CleanupOldTasks
  • func (*CleanupOldTasks) Descriptor() ([]byte, []int)
  • func (x *CleanupOldTasks) GetRetries() int32
  • func (x *CleanupOldTasks) GetTaskIds() []string
  • func (*CleanupOldTasks) ProtoMessage()
  • func (x *CleanupOldTasks) ProtoReflect() protoreflect.Message
  • func (x *CleanupOldTasks) Reset()
  • func (x *CleanupOldTasks) String() string

Variables

var File_go_chromium_org_luci_swarming_server_tasks_taskspb_tasks_proto protoreflect.FileDescriptor

Types

type BatchCancelTask

type BatchCancelTask struct {
	Tasks       []string `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	KillRunning bool     `protobuf:"varint,2,opt,name=kill_running,json=killRunning,proto3" json:"kill_running,omitempty"`
	Retries     int32    `protobuf:"varint,3,opt,name=retries,proto3" json:"retries,omitempty"`
	Purpose     string   `protobuf:"bytes,4,opt,name=purpose,proto3" json:"purpose,omitempty"`
	// contains filtered or unexported fields
}

A Cloud task for cancelling tasks in batches.

func (*BatchCancelTask) Descriptor

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

Deprecated: Use BatchCancelTask.ProtoReflect.Descriptor instead.

func (*BatchCancelTask) GetKillRunning

func (x *BatchCancelTask) GetKillRunning() bool

func (*BatchCancelTask) GetPurpose

func (x *BatchCancelTask) GetPurpose() string

func (*BatchCancelTask) GetRetries

func (x *BatchCancelTask) GetRetries() int32

func (*BatchCancelTask) GetTasks

func (x *BatchCancelTask) GetTasks() []string

func (*BatchCancelTask) ProtoMessage

func (*BatchCancelTask) ProtoMessage()

func (*BatchCancelTask) ProtoReflect

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

func (*BatchCancelTask) Reset

func (x *BatchCancelTask) Reset()

func (*BatchCancelTask) String

func (x *BatchCancelTask) String() string

type CancelChildrenTask

type CancelChildrenTask struct {

	// Swarming Task ID of the parent task.
	TaskId string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	// contains filtered or unexported fields
}

A Cloud task for canceling a task's children.

func (*CancelChildrenTask) Descriptor

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

Deprecated: Use CancelChildrenTask.ProtoReflect.Descriptor instead.

func (*CancelChildrenTask) GetTaskId

func (x *CancelChildrenTask) GetTaskId() string

func (*CancelChildrenTask) ProtoMessage

func (*CancelChildrenTask) ProtoMessage()

func (*CancelChildrenTask) ProtoReflect

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

func (*CancelChildrenTask) Reset

func (x *CancelChildrenTask) Reset()

func (*CancelChildrenTask) String

func (x *CancelChildrenTask) String() string

type CleanupOldTasks

type CleanupOldTasks struct {
	TaskIds []string `protobuf:"bytes,1,rep,name=task_ids,json=taskIds,proto3" json:"task_ids,omitempty"`
	Retries int32    `protobuf:"varint,2,opt,name=retries,proto3" json:"retries,omitempty"`
	// contains filtered or unexported fields
}

Used by the cron that cleans up old entity groups with old tasks.

func (*CleanupOldTasks) Descriptor

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

Deprecated: Use CleanupOldTasks.ProtoReflect.Descriptor instead.

func (*CleanupOldTasks) GetRetries

func (x *CleanupOldTasks) GetRetries() int32

func (*CleanupOldTasks) GetTaskIds

func (x *CleanupOldTasks) GetTaskIds() []string

func (*CleanupOldTasks) ProtoMessage

func (*CleanupOldTasks) ProtoMessage()

func (*CleanupOldTasks) ProtoReflect

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

func (*CleanupOldTasks) Reset

func (x *CleanupOldTasks) Reset()

func (*CleanupOldTasks) String

func (x *CleanupOldTasks) String() string