dynamodb

Documentation

Index

• Constants
• func New(cnf *config.Config) iface.Backend
• type Backend
  • func (b *Backend) GetState(taskUUID string) (*tasks.TaskState, error)
  • func (b *Backend) GroupCompleted(groupUUID string, groupTaskCount int) (bool, error)
  • func (b *Backend) GroupTaskStates(groupUUID string, groupTaskCount int) ([]*tasks.TaskState, error)
  • func (b *Backend) InitGroup(groupUUID string, taskUUIDs []string) error
  • func (b *Backend) PurgeGroupMeta(groupUUID string) error
  • func (b *Backend) PurgeState(taskUUID string) error
  • func (b *Backend) SetStateFailure(signature *tasks.Signature, err string) error
  • func (b *Backend) SetStatePending(signature *tasks.Signature) error
  • func (b *Backend) SetStateReceived(signature *tasks.Signature) error
  • func (b *Backend) SetStateRetry(signature *tasks.Signature) error
  • func (b *Backend) SetStateStarted(signature *tasks.Signature) error
  • func (b *Backend) SetStateSuccess(signature *tasks.Signature, results []*tasks.TaskResult) error
  • func (b *Backend) TriggerChord(groupUUID string) (bool, error)

Constants

const (
	BatchItemsLimit  = 99
	MaxFetchAttempts = 3
)

Functions

func New

func New(cnf *config.Config) iface.Backend

New creates a Backend instance

Types

type Backend

type Backend struct {
	common.Backend
	// contains filtered or unexported fields
}

Backend ...

func (*Backend) GetState

func (b *Backend) GetState(taskUUID string) (*tasks.TaskState, error)

GetState ...

func (*Backend) GroupCompleted

func (b *Backend) GroupCompleted(groupUUID string, groupTaskCount int) (bool, error)

GroupCompleted ...

func (*Backend) GroupTaskStates

func (b *Backend) GroupTaskStates(groupUUID string, groupTaskCount int) ([]*tasks.TaskState, error)

GroupTaskStates ...

func (*Backend) InitGroup

func (b *Backend) InitGroup(groupUUID string, taskUUIDs []string) error

InitGroup ...

func (*Backend) PurgeGroupMeta

func (b *Backend) PurgeGroupMeta(groupUUID string) error

PurgeGroupMeta ...

func (*Backend) PurgeState

func (b *Backend) PurgeState(taskUUID string) error

PurgeState ...

func (*Backend) SetStateFailure

func (b *Backend) SetStateFailure(signature *tasks.Signature, err string) error

SetStateFailure ...

func (*Backend) SetStatePending

func (b *Backend) SetStatePending(signature *tasks.Signature) error

SetStatePending ...

func (*Backend) SetStateReceived

func (b *Backend) SetStateReceived(signature *tasks.Signature) error

SetStateReceived ...

func (*Backend) SetStateRetry

func (b *Backend) SetStateRetry(signature *tasks.Signature) error

SetStateRetry ...

func (*Backend) SetStateStarted

func (b *Backend) SetStateStarted(signature *tasks.Signature) error

SetStateStarted ...

func (*Backend) SetStateSuccess

func (b *Backend) SetStateSuccess(signature *tasks.Signature, results []*tasks.TaskResult) error

SetStateSuccess ...

func (*Backend) TriggerChord

func (b *Backend) TriggerChord(groupUUID string) (bool, error)

TriggerChord ...