queuemanager

Jul 25, 2020

Changes in this version

+ func FileConfig(filename string) *naiveFileStore

+ func Mock(queues ...application.Queue) *mockStore

+ func New(ctx context.Context, config Store, platform Platform, factory QueueFactory, ...) (*queueManager, error)

+ type Platform interface

+ InvokeByUID func(ctx context.Context, uid string, request types.Request, out io.Writer) error

+ type QueueFactory func(name string) (queue.Queue, error)

+ type Store interface

+ GetQueues func() ([]application.Queue, error)

+ SetQueues func(queues []application.Queue) error