deck

README

deck

Task class memory-level queue processing.

Installation

go get -u github.com/coolstina/deck

Feature

• Enqueue based on task ID
• Iteratively get queue data(Support custom data persistence)
• Check if task queue data exists
• Check task queue length
• Get the task list

Documentation

Index

• type Decker
  • func NewDecker(showLogger bool) Decker
• type Effected
• type Option
• type OptionFunc
  • func WithInterval(interval time.Duration) OptionFunc
  • func WithReceiveDoneNotification(receive bool) OptionFunc
  • func WithStorage(storage Storage) OptionFunc
• type Storage

Types

type Decker

type Decker interface {
	Enqueue(taskId int, values ...interface{}) Effected
	Exists(taskId int) bool
	Values(taskId int) *list.List
	Len(taskId int) int
	FetchOrStorage(ctx context.Context, taskId int, ops ...Option) <-chan interface{}
}

func NewDecker

func NewDecker(showLogger bool) Decker

type Effected

type Effected struct {
	TaskId  int
	Already int
	Newness int
}

type Option

type Option interface {
	// contains filtered or unexported methods
}

type OptionFunc

type OptionFunc func(option *option)

func WithInterval

func WithInterval(interval time.Duration) OptionFunc

func WithReceiveDoneNotification

func WithReceiveDoneNotification(receive bool) OptionFunc

func WithStorage

func WithStorage(storage Storage) OptionFunc

type Storage

type Storage func(value interface{})

Storage custom storage queue data to same store, filesystem, redis and so on.