manager

Documentation

Index

• func MakeQueueUsageBackupKey(qID string) string
• func New(ctx context.Context, ops ...Option) types.QueueManager
• type Option
  • func WithDBClient(dbClient *dbclient.Client) Option
  • func WithEtcdClient(etcdClient *etcd.Store) Option
  • func WithJsClient(js jsonstore.JsonStore) Option
• type SnapshotObj

Functions

func MakeQueueUsageBackupKey

func MakeQueueUsageBackupKey(qID string) string

func New

func New(ctx context.Context, ops ...Option) types.QueueManager

New return a new queue manager.

Types

type Option

type Option func(manager *defaultManager)

func WithDBClient

func WithDBClient(dbClient *dbclient.Client) Option

func WithEtcdClient

func WithEtcdClient(etcdClient *etcd.Store) Option

func WithJsClient

func WithJsClient(js jsonstore.JsonStore) Option

type SnapshotObj

type SnapshotObj struct {
	QueueUsageByID map[string][]byte `json:"queueUsageByID"`
}