queuemanager

Documentation

Index

• 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
• type QueueFactory
• type Store

Functions

func FileConfig

func FileConfig(filename string) *naiveFileStore

func Mock

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

func New

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

Types

type Platform

type Platform interface {
	InvokeByUID(ctx context.Context, uid string, request types.Request, out io.Writer) error
}

Minimal required platform features

type QueueFactory

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

type Store

type Store interface {
	// Save queues list
	SetQueues(queues []application.Queue) error
	// Load queues list
	GetQueues() ([]application.Queue, error)
}

Store contains queues configuration for reload