utils

Documentation

Index

• Constants
• func Contains(search interface{}, target interface{}) bool
• func RemoveDuplicates(arr []string) []string

Constants

const (
	TaskMailMsg = "mail_msg"
	TaskTestMsg = "test_msg"
)

任务类型

const (
	TaskStatusPending   = 0
	TaskStatusReady     = 1
	TaskStatusRunning   = 2
	TaskStatusFinish    = 3
	TaskStatusTerminate = 97
	TaskStatusTimeOut   = 98
	TaskStatusError     = 99
)

任务状态

const (
	BucketName = "bucket_%d"
	BucketNum  = 5
)

bucket

const (
	AsyncPendingKey     = "async:%s:pending"      // zSet
	AsyncReadyKey       = "async:%s:ready"        // list
	AsyncRunningKey     = "async:%s:running"      // zSet
	AsyncRetryKey       = "async:%s:retry"        // hSet
	AsyncTTLKey         = "async:%s:ttl"          // hSet
	AsyncPeriodKey      = "async:%s:period"       // zSet
	AsyncBucketKey      = "async:%s:bucket"       // hSet
	AsyncResultKey      = "async:%s:result"       // hSet
	AsyncTerminateKey   = "async:%s:terminate"    // hSet
	AsyncInfoKey        = "async:%s:info"         // hSet
	AsyncPeriodRetryKey = "async:%s:period:retry" // hSet
	AsyncStatusKey      = "async:%s:status"       // hSet
)

async

const (
	MaxWorker = 2000
)

MaxWorker worker

Functions

func Contains

func Contains(search interface{}, target interface{}) bool

Contains .

func RemoveDuplicates

func RemoveDuplicates(arr []string) []string

RemoveDuplicates .