queue

package

v0.0.0-...-bdf02af Latest Latest Go to latest Published: Mar 18, 2021 License: Apache-2.0 Imports: 13 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/dangfan/later

Links

Open Source Insights

Documentation ¶

Constants ¶

View Source

const (
	CodeSuccess        = 100
	CodeTooManyRequest = 101
)

View Source

const (
	DelayBucket = "later_delay"
	UnackBucket = "later_unack"
	ErrorBucket = "later_error"
)

Variables ¶

View Source

var (
	RedisConnectTimeout  = 50 * time.Millisecond
	RedisReadTimeout     = 50 * time.Millisecond
	RedisWriteTimeout    = 100 * time.Millisecond
	RedisPoolMaxIdle     = 200
	RedisPoolIdleTimeout = 3 * time.Minute
)

View Source

var (
	TaskTTL       = 24 * 3600
	ZrangeCount   = 20
	RetryInterval = 10 //second

	DelayWorkerInterval = 100 * time.Millisecond
	UnackWorkerInterval = 1000 * time.Millisecond
	ErrorWorkerInterval = 1000 * time.Millisecond
)

View Source

var (
	CallbackTTR         = 3 * time.Second //time to run
	MaxIdleConnsPerHost = 10
	MaxIdleConns        = 1024
	IdleConnTimeout     = time.Minute * 5
)

Functions ¶

func InitRedis ¶

func InitRedis(address string) error

func ListenAndServe ¶

func ListenAndServe(addr string) error

func RunWorker ¶

func RunWorker()

func Slice ¶

func Slice(s string) (b []byte)

No copy to change string to slice, use your own risk

func String ¶

func String(b []byte) (s string)

No copy to change slice to string, use your own risk

Types ¶

type Task ¶

type Task struct {
	// ID is a global unique id
	ID string
	// Topic use to classify tasks
	Topic string
	// ExecuteTime is the time to deliver
	ExecuteTime int64
	// MaxRetry is max deliver retry times
	MaxRetry int
	//HasRetry is the current retry times
	HasRetry int
	// Callback is the deliver address
	Callback string
	// Content is the task content to deliver
	Content string
	// CreatTime is the time task created
	CreatTime int64
}

Task is the task to execute

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL