synapsequeue

Documentation

Index

• func New(redisDB core.RedisDB, logger lumber.Logger, ...) core.SynapseQueueManager
• func NewSynapseTaskQueue(redisDB core.RedisDB, synapsePool core.SynapsePoolManager, ...) (core.SynapseTaskQueue, error)

Functions

func New

func New(redisDB core.RedisDB,
	logger lumber.Logger,
	synapseManager core.SynapseClientManager,
	synapsePool core.SynapsePoolManager,
	synapseStore core.SynapseStore) core.SynapseQueueManager

New returns new synapseQueue

func NewSynapseTaskQueue

func NewSynapseTaskQueue(redisDB core.RedisDB,
	synapsePool core.SynapsePoolManager,
	synapseManager core.SynapseClientManager,
	synapseQueue core.SynapseQueueManager,
	buildStore core.BuildStore,
	logger lumber.Logger) (core.SynapseTaskQueue, error)

NewSynapseTaskQueue creates queue producer and returns new synapseTaskQueue