task

Documentation

Index

• type BaseTask
  • func NewTask(taskType TaskType) *BaseTask
  • func (t *BaseTask) GetDescription() string
  • func (t *BaseTask) GetFailureCount() int
  • func (t *BaseTask) GetId() string
  • func (t *BaseTask) GetLogLabels() map[string]string
  • func (t *BaseTask) GetMetadata() interface{}
  • func (t *BaseTask) GetQueueName() string
  • func (t *BaseTask) GetType() TaskType
  • func (t *BaseTask) IncrementFailureCount()
  • func (t *BaseTask) WithLogLabels(labels map[string]string) *BaseTask
  • func (t *BaseTask) WithMetadata(metadata interface{}) *BaseTask
  • func (t *BaseTask) WithQueueName(name string) *BaseTask
• type MetadataDescriptable
• type Task
• type TaskType

Types

type BaseTask

type BaseTask struct {
	Id           string
	Type         TaskType
	LogLabels    map[string]string
	FailureCount int // Failed executions count
	QueueName    string

	Metadata interface{}
}

func NewTask

func NewTask(taskType TaskType) *BaseTask

func (*BaseTask) GetDescription

func (t *BaseTask) GetDescription() string

func (*BaseTask) GetFailureCount

func (t *BaseTask) GetFailureCount() int

func (*BaseTask) GetId

func (t *BaseTask) GetId() string

func (*BaseTask) GetLogLabels

func (t *BaseTask) GetLogLabels() map[string]string

func (*BaseTask) GetMetadata

func (t *BaseTask) GetMetadata() interface{}

func (*BaseTask) GetQueueName

func (t *BaseTask) GetQueueName() string

func (*BaseTask) GetType

func (t *BaseTask) GetType() TaskType

func (*BaseTask) IncrementFailureCount

func (t *BaseTask) IncrementFailureCount()

func (*BaseTask) WithLogLabels

func (t *BaseTask) WithLogLabels(labels map[string]string) *BaseTask

func (*BaseTask) WithMetadata

func (t *BaseTask) WithMetadata(metadata interface{}) *BaseTask

func (*BaseTask) WithQueueName

func (t *BaseTask) WithQueueName(name string) *BaseTask

type MetadataDescriptable

type MetadataDescriptable interface {
	GetDescription() string
}

type Task

type Task interface {
	GetId() string
	GetType() TaskType
	IncrementFailureCount()
	GetFailureCount() int
	GetLogLabels() map[string]string
	GetQueueName() string
	GetMetadata() interface{}
	GetDescription() string
}

type TaskType

type TaskType string