driver

Documentation

Index

• Constants
• func GetKeyPre(serviceName string) string
• func GetNodeId(serviceName string) string
• func GetStableJobStore(serviceName string) string
• func GetStableJobStoreTxKey(serviceName string) string
• type Driver

Constants

const GlobalKeyPrefix = "distributed-cron:"

GlobalKeyPrefix is global redis key preifx

Functions

func GetKeyPre

func GetKeyPre(serviceName string) string

func GetNodeId

func GetNodeId(serviceName string) string

func GetStableJobStore

func GetStableJobStore(serviceName string) string

func GetStableJobStoreTxKey

func GetStableJobStoreTxKey(serviceName string) string

Types

type Driver

type Driver interface {
	// Ping is check dirver is valid
	Ping() error
	SetLogger(log dlog.Logger)
	SetHeartBeat(node *node.Node)
	SetTimeout(timeout time.Duration)
	GetServiceNodeList(ServiceName string) ([]*node.Node, error)
	RegisterServiceNode(node *node.Node) (string, error)
}

Driver is a driver interface