Versions in this module Expand all Collapse all v0 v0.1.0 Jun 23, 2021 Changes in this version + type DiskQueue struct + func (module DiskQueue) Close(k string) error + func (module DiskQueue) Depth(k string) int64 + func (module DiskQueue) GetQueues() []string + func (module DiskQueue) Name() string + func (module DiskQueue) Pop(k string, timeoutInSeconds time.Duration) ([]byte, error) + func (module DiskQueue) Push(k string, v []byte) error + func (module DiskQueue) ReadChan(k string) chan []byte + func (module DiskQueue) Setup(cfg *config.Config) + func (module DiskQueue) Start() error + func (module DiskQueue) Stop() error
Go to main page