v1.7.8 Latest Latest

This package is not in the latest version of its module.

Go to latest
Published: Dec 4, 2020 License: Apache-2.0 Imports: 13 Imported by: 0



Package utils provides reusable and sharable utilities for other packages and components.



This section is empty.


This section is empty.


func DeSerializeJob added in v1.5.0

func DeSerializeJob(jobBytes []byte) (*work.Job, error)

DeSerializeJob decodes bytes to ptr of work.Job.

func DirExists added in v1.5.0

func DirExists(path string) bool

DirExists check if the specified dir exists

func FileExists added in v1.5.0

func FileExists(file string) bool

FileExists check if the specified exists.

func IsEmptyStr added in v1.5.0

func IsEmptyStr(str string) bool

IsEmptyStr check if the specified str is empty (len ==0) after triming prefix and suffix spaces.

func IsValidPort added in v1.5.0

func IsValidPort(port uint) bool

IsValidPort check if port is valid.

func IsValidURL added in v1.5.0

func IsValidURL(address string) bool

IsValidURL validates if the url is well-formted

func KeyJobCtlCommands added in v1.5.0

func KeyJobCtlCommands(namespace string, jobID string) string

KeyJobCtlCommands returns the key for publishing ctl commands like 'stop' etc.

func KeyJobStats added in v1.5.0

func KeyJobStats(namespace string, jobID string) string

KeyJobStats returns the key of job stats

func KeyNamespacePrefix added in v1.5.0

func KeyNamespacePrefix(namespace string) string

KeyNamespacePrefix returns the based key based on the namespace.

func KeyPeriod added in v1.5.0

func KeyPeriod(namespace string) string

KeyPeriod returns the key of period

func KeyPeriodicJobTimeSlots added in v1.7.0

func KeyPeriodicJobTimeSlots(namespace string) string

KeyPeriodicJobTimeSlots returns the key of the time slots of scheduled jobs.

func KeyPeriodicLock added in v1.5.0

func KeyPeriodicLock(namespace string) string

KeyPeriodicLock returns the key of locker under period

func KeyPeriodicNotification added in v1.5.0

func KeyPeriodicNotification(namespace string) string

KeyPeriodicNotification returns the key of periodic pub/sub channel.

func KeyPeriodicPolicy added in v1.5.0

func KeyPeriodicPolicy(namespace string) string

KeyPeriodicPolicy returns the key of periodic policies.

func KeyPeriodicPolicyScore added in v1.5.0

func KeyPeriodicPolicyScore(namespace string) string

KeyPeriodicPolicyScore returns the key of policy key and score mapping.

func KeyUpstreamJobAndExecutions added in v1.7.0

func KeyUpstreamJobAndExecutions(namespace, upstreamJobID string) string

KeyUpstreamJobAndExecutions returns the key for persisting executions.

func MakeIdentifier added in v1.5.0

func MakeIdentifier() string

MakeIdentifier creates uuid for job.

func MakePeriodicPolicyUUID added in v1.5.0

func MakePeriodicPolicyUUID() (string, int64)

MakePeriodicPolicyUUID returns an UUID for the periodic policy.

func MakeUniquePeriodicID added in v1.5.0

func MakeUniquePeriodicID(name, spec string, epoch int64) string

MakeUniquePeriodicID creates id for the periodic job.

func ReadEnv added in v1.5.0

func ReadEnv(key string) string

ReadEnv return the value of env variable.

func RedisKeyDead added in v1.5.0

func RedisKeyDead(namespace string) string

RedisKeyDead returns key of the dead jobs.

func RedisKeyLastPeriodicEnqueue added in v1.5.0

func RedisKeyLastPeriodicEnqueue(namespace string) string

RedisKeyLastPeriodicEnqueue returns key of timestamp if last periodic enqueue.

func RedisKeyScheduled added in v1.5.0

func RedisKeyScheduled(namespace string) string

RedisKeyScheduled returns key of scheduled job.

func RedisNamespacePrefix added in v1.5.0

func RedisNamespacePrefix(namespace string) string

RedisNamespacePrefix ... Same with 'KeyNamespacePrefix', only for compatibility.

func SerializeJob added in v1.5.0

func SerializeJob(job *work.Job) ([]byte, error)

SerializeJob encodes work.Job to json data.

func TranslateRedisAddress added in v1.5.0

func TranslateRedisAddress(commaFormat string) (string, bool)

TranslateRedisAddress translates the comma format to redis URL


type CtlContextKey added in v1.7.0

type CtlContextKey string

CtlContextKey is used to keep controller reference in the system context

const (
	// CtlKeyOfLaunchJobFunc is context key to keep the ctl launch job func
	CtlKeyOfLaunchJobFunc CtlContextKey = "controller_launch_job_func"

type JobScore added in v1.5.0

type JobScore struct {
	JobBytes []byte
	Score    int64

JobScore represents the data item with score in the redis db.

func GetZsetByScore added in v1.5.0

func GetZsetByScore(pool *redis.Pool, key string, scores []int64) ([]JobScore, error)

GetZsetByScore get the items from the zset filtered by the specified score scope.

Jump to

Keyboard shortcuts

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