Documentation ¶ Index ¶ func NewFsQueue(ctx context.Context, fileName string, logger logx.Wrapper) (queuex.Queue, error) func NewFsQueueWithFNNow(ctx context.Context, fileName string, now base.FNNow, logger logx.Wrapper) (queuex.Queue, error) Constants ¶ This section is empty. Variables ¶ This section is empty. Functions ¶ func NewFsQueue ¶ func NewFsQueue(ctx context.Context, fileName string, logger logx.Wrapper) (queuex.Queue, error) func NewFsQueueWithFNNow ¶ func NewFsQueueWithFNNow(ctx context.Context, fileName string, now base.FNNow, logger logx.Wrapper) (queuex.Queue, error) Types ¶ This section is empty. Source Files ¶ View all Source files inner_task.goqueue.go Click to show internal directories. Click to hide internal directories.