Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

backends

package

Go to main page

Versions in this module

v1

v1.3.2

Jan 13, 2021

v1.3.1

Mar 24, 2020

v1.3.0

Mar 24, 2020

Changes in this version

+ type Nil struct

+ func (Nil) GetState(taskUUID string) (*tasks.TaskState, error)

+ func (Nil) GroupCompleted(groupUUID string, groupTaskCount int) (bool, error)

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

+ func (Nil) InitGroup(groupUUID string, taskUUIDs []string) error

+ func (Nil) PurgeGroupMeta(groupUUID string) error

+ func (Nil) PurgeState(taskUUID string) error

+ func (Nil) SetStateFailure(signature *tasks.Signature, err string) error

+ func (Nil) SetStatePending(signature *tasks.Signature) error

+ func (Nil) SetStateReceived(signature *tasks.Signature) error

+ func (Nil) SetStateRetry(signature *tasks.Signature) error

+ func (Nil) SetStateStarted(signature *tasks.Signature) error

+ func (Nil) SetStateSuccess(signature *tasks.Signature, results []*tasks.TaskResult) error

+ func (Nil) TriggerChord(groupUUID string) (bool, error)

v1.2.1

Mar 5, 2020

v1.2.0

Mar 5, 2020

v1.1.1

Mar 5, 2020

v1.1.0

Feb 4, 2020

Changes in this version

+ type AMQPBackend struct

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

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

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

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

+ func (b *AMQPBackend) PurgeGroupMeta(groupUUID string) error

+ func (b *AMQPBackend) PurgeState(taskUUID string) error

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

+ func (b *AMQPBackend) SetStatePending(signature *tasks.Signature) error

+ func (b *AMQPBackend) SetStateReceived(signature *tasks.Signature) error

+ func (b *AMQPBackend) SetStateRetry(signature *tasks.Signature) error

+ func (b *AMQPBackend) SetStateStarted(signature *tasks.Signature) error

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

+ func (b *AMQPBackend) TriggerChord(groupUUID string) (bool, error)

+ type AsyncResult struct

+ Signature *tasks.Signature

+ func NewAsyncResult(signature *tasks.Signature, backend Interface) *AsyncResult

+ func (asyncResult *AsyncResult) Get(sleepDuration time.Duration) ([]reflect.Value, error)

+ func (asyncResult *AsyncResult) GetState() *tasks.TaskState

+ func (asyncResult *AsyncResult) GetWithTimeout(timeoutDuration, sleepDuration time.Duration) ([]reflect.Value, error)

+ func (asyncResult *AsyncResult) Touch() ([]reflect.Value, error)

+ type ChainAsyncResult struct

+ func NewChainAsyncResult(sigs []*tasks.Signature, backend Interface) *ChainAsyncResult

+ func (chainAsyncResult *ChainAsyncResult) Get(sleepDuration time.Duration) ([]reflect.Value, error)

+ func (chainAsyncResult *ChainAsyncResult) GetWithTimeout(timeoutDuration, sleepDuration time.Duration) ([]reflect.Value, error)

+ type ChordAsyncResult struct

+ func NewChordAsyncResult(groupTasks []*tasks.Signature, chordCallback *tasks.Signature, ...) *ChordAsyncResult

+ func (chordAsyncResult *ChordAsyncResult) Get(sleepDuration time.Duration) ([]reflect.Value, error)

+ func (chordAsyncResult *ChordAsyncResult) GetWithTimeout(timeoutDuration, sleepDuration time.Duration) ([]reflect.Value, error)

+ type EagerBackend struct

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

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

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

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

+ func (b *EagerBackend) PurgeGroupMeta(groupUUID string) error

+ func (b *EagerBackend) PurgeState(taskUUID string) error

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

+ func (b *EagerBackend) SetStatePending(signature *tasks.Signature) error

+ func (b *EagerBackend) SetStateReceived(signature *tasks.Signature) error

+ func (b *EagerBackend) SetStateRetry(signature *tasks.Signature) error

+ func (b *EagerBackend) SetStateStarted(signature *tasks.Signature) error

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

+ func (b *EagerBackend) TriggerChord(groupUUID string) (bool, error)

+ type Interface interface

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

+ GroupCompleted func(groupUUID string, groupTaskCount int) (bool, error)

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

+ InitGroup func(groupUUID string, taskUUIDs []string) error

+ PurgeGroupMeta func(groupUUID string) error

+ PurgeState func(taskUUID string) error

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

+ SetStatePending func(signature *tasks.Signature) error

+ SetStateReceived func(signature *tasks.Signature) error

+ SetStateRetry func(signature *tasks.Signature) error

+ SetStateStarted func(signature *tasks.Signature) error

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

+ TriggerChord func(groupUUID string) (bool, error)

+ func NewAMQPBackend(cnf *config.Config) Interface

+ func NewEagerBackend() Interface

+ func NewMemcacheBackend(cnf *config.Config, servers []string) Interface

+ func NewMongodbBackend(cnf *config.Config) Interface

+ func NewRedisBackend(cnf *config.Config, host, password, socketPath string, db int) Interface

+ type MemcacheBackend struct

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

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

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

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

+ func (b *MemcacheBackend) PurgeGroupMeta(groupUUID string) error

+ func (b *MemcacheBackend) PurgeState(taskUUID string) error

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

+ func (b *MemcacheBackend) SetStatePending(signature *tasks.Signature) error

+ func (b *MemcacheBackend) SetStateReceived(signature *tasks.Signature) error

+ func (b *MemcacheBackend) SetStateRetry(signature *tasks.Signature) error

+ func (b *MemcacheBackend) SetStateStarted(signature *tasks.Signature) error

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

+ func (b *MemcacheBackend) TriggerChord(groupUUID string) (bool, error)

+ type MongodbBackend struct

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

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

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

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

+ func (b *MongodbBackend) PurgeGroupMeta(groupUUID string) error

+ func (b *MongodbBackend) PurgeState(taskUUID string) error

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

+ func (b *MongodbBackend) SetStatePending(signature *tasks.Signature) error

+ func (b *MongodbBackend) SetStateReceived(signature *tasks.Signature) error

+ func (b *MongodbBackend) SetStateRetry(signature *tasks.Signature) error

+ func (b *MongodbBackend) SetStateStarted(signature *tasks.Signature) error

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

+ func (b *MongodbBackend) TriggerChord(groupUUID string) (bool, error)

+ type RedisBackend struct

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

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

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

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

+ func (b *RedisBackend) PurgeGroupMeta(groupUUID string) error

+ func (b *RedisBackend) PurgeState(taskUUID string) error

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

+ func (b *RedisBackend) SetStatePending(signature *tasks.Signature) error

+ func (b *RedisBackend) SetStateReceived(signature *tasks.Signature) error

+ func (b *RedisBackend) SetStateRetry(signature *tasks.Signature) error

+ func (b *RedisBackend) SetStateStarted(signature *tasks.Signature) error

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

+ func (b *RedisBackend) TriggerChord(groupUUID string) (bool, error)