redis

Documentation

Index

• Constants
• func IsEnabled(addrs []string) bool
• func MakeApplicationsKeyInManager() string
• func MakeKeyInManager(namespace, id string) string
• func MakeKeyInScheduler(namespace, id string) string
• func MakeNamespaceKeyInManager(namespace string) string
• func MakeNamespaceKeyInScheduler(namespace string) string
• func MakePeerKeyInManager(hostname, ip string) string
• func MakePersistentCacheHostKeyInScheduler(schedulerClusterID uint, hostID string) string
• func MakePersistentCacheHostsInScheduler(schedulerClusterID uint) string
• func MakePersistentCachePeerKeyInScheduler(schedulerClusterID uint, peerID string) string
• func MakePersistentCachePeersInScheduler(schedulerClusterID uint) string
• func MakePersistentCacheTaskKeyInScheduler(schedulerClusterID uint, taskID string) string
• func MakePersistentCacheTasksInScheduler(schedulerClusterID uint) string
• func MakeSchedulerKeyInManager(clusterID uint, hostname, ip string) string
• func MakeSchedulersKeyForPeerInManager(hostname, ip string) string
• func MakeSeedPeerKeyInManager(clusterID uint, hostname, ip string) string
• func MakeSeedPeersKeyForPeerInManager(hostname, ip string) string
• func NewRedis(cfg *redis.UniversalOptions) (redis.UniversalClient, error)

Constants

const (
	// SeedPeerNamespace prefix of seed peers namespace cache key.
	SeedPeersNamespace = "seed-peers"

	// PeersNamespace prefix of peers namespace cache key.
	PeersNamespace = "peers"

	// SchedulersNamespace prefix of schedulers namespace cache key.
	SchedulersNamespace = "schedulers"

	// SchedulerClustersNamespace prefix of scheduler clusters namespace cache key.
	SchedulerClustersNamespace = "scheduler-clusters"

	// TasksNamespace prefix of tasks namespace cache key.
	PersistentCacheTasksNamespace = "persistent-cache-tasks"

	// PersistentCachePeersNamespace prefix of persistent cache peers namespace cache key.
	PersistentCachePeersNamespace = "persistent-cache-peers"

	// PersistentCacheHostsNamespace prefix of persistent cache hosts namespace cache key.
	PersistentCacheHostsNamespace = "persistent-cache-hosts"

	// ApplicationsNamespace prefix of applications namespace cache key.
	ApplicationsNamespace = "applications"
)

const (
	// KeySeparator is the separator of redis key.
	KeySeparator = ":"
)

Functions

func IsEnabled

func IsEnabled(addrs []string) bool

IsEnabled check redis is enabled.

func MakeApplicationsKeyInManager

func MakeApplicationsKeyInManager() string

MakeApplicationsKeyInManager make applications key in manager.

func MakeKeyInManager

func MakeKeyInManager(namespace, id string) string

MakeKeyInManager make key in manager.

func MakeKeyInScheduler

func MakeKeyInScheduler(namespace, id string) string

MakeKeyInScheduler make key in scheduler.

func MakeNamespaceKeyInManager

func MakeNamespaceKeyInManager(namespace string) string

MakeNamespaceKeyInManager make namespace key in manager.

func MakeNamespaceKeyInScheduler

func MakeNamespaceKeyInScheduler(namespace string) string

MakeNamespaceKeyInScheduler make namespace key in scheduler.

func MakePeerKeyInManager

func MakePeerKeyInManager(hostname, ip string) string

MakePeerKeyInManager make peer key in manager.

func MakePersistentCacheHostKeyInScheduler

func MakePersistentCacheHostKeyInScheduler(schedulerClusterID uint, hostID string) string

MakePersistentCacheHostKeyInScheduler make persistent cache host key in scheduler.

func MakePersistentCacheHostsInScheduler

func MakePersistentCacheHostsInScheduler(schedulerClusterID uint) string

MakePersistentCacheHostsInScheduler make persistent cache hosts in scheduler.

func MakePersistentCachePeerKeyInScheduler

func MakePersistentCachePeerKeyInScheduler(schedulerClusterID uint, peerID string) string

MakePersistentCachePeerKeyInScheduler make persistent cache peer key in scheduler.

func MakePersistentCachePeersInScheduler

func MakePersistentCachePeersInScheduler(schedulerClusterID uint) string

func MakePersistentCacheTaskKeyInScheduler

func MakePersistentCacheTaskKeyInScheduler(schedulerClusterID uint, taskID string) string

MakeSchedulerClusterKeyInManager make scheduler cluster key in manager.

func MakePersistentCacheTasksInScheduler

func MakePersistentCacheTasksInScheduler(schedulerClusterID uint) string

MakePersistentCacheTasksInScheduler make persistent cache tasks in scheduler.

func MakeSchedulerKeyInManager

func MakeSchedulerKeyInManager(clusterID uint, hostname, ip string) string

MakeSchedulerKeyInManager make scheduler key in manager.

func MakeSchedulersKeyForPeerInManager

func MakeSchedulersKeyForPeerInManager(hostname, ip string) string

MakeSchedulersKeyForPeerInManager make schedulers key for peer in manager.

func MakeSeedPeerKeyInManager

func MakeSeedPeerKeyInManager(clusterID uint, hostname, ip string) string

MakeSeedPeerKeyInManager make seed peer key in manager.

func MakeSeedPeersKeyForPeerInManager

func MakeSeedPeersKeyForPeerInManager(hostname, ip string) string

MakeSeedPeersKeyForPeerInManager make seed peers key for peer in manager.

func NewRedis

func NewRedis(cfg *redis.UniversalOptions) (redis.UniversalClient, error)

NewRedis returns a new redis client.