cache

Documentation

Index

• Constants
• func MakeBucketsCacheKey(name string) string
• func MakeCacheKey(namespace string, id string) string
• func MakeModelKey(clusterID uint, hostname, ip, id string) string
• func MakeModelVersionKey(clusterID uint, hostname, ip, id, version string) string
• func MakePeerCacheKey(hostname, ip string) string
• func MakeSchedulerCacheKey(clusterID uint, hostname, ip string) string
• func MakeSchedulersCacheKeyForPeer(hostname, ip string) string
• func MakeSeedPeerCacheKey(clusterID uint, hostname, ip string) string
• type Cache
  • func New(cfg *config.Config) (*Cache, error)

Constants

const (
	// Seed Peer prefix of cache key.
	SeedPeerNamespace = "seed-peers"

	// Peer prefix of cache key.
	PeerNamespace = "peers"

	// Scheduler prefix of cache key.
	SchedulerNamespace = "schedulers"

	// Buckets prefix of cache key.
	BucketsNamespace = "buckets"
)

const (
	// PeerCacheTTL is the ttl for peer cache.
	PeerCacheTTL = 30 * time.Minute
)

Functions

func MakeBucketsCacheKey

func MakeBucketsCacheKey(name string) string

Make cache key for buckets.

func MakeCacheKey

func MakeCacheKey(namespace string, id string) string

Make cache key.

func MakeModelKey

func MakeModelKey(clusterID uint, hostname, ip, id string) string

Make cache model key.

func MakeModelVersionKey

func MakeModelVersionKey(clusterID uint, hostname, ip, id, version string) string

Make cache model version key.

func MakePeerCacheKey

func MakePeerCacheKey(hostname, ip string) string

Make cache key for peer.

func MakeSchedulerCacheKey

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

Make cache key for scheduler.

func MakeSchedulersCacheKeyForPeer

func MakeSchedulersCacheKeyForPeer(hostname, ip string) string

Make schedulers cache key for peer.

func MakeSeedPeerCacheKey

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

Make cache key for seed peer.

Types

type Cache

type Cache struct {
	*cache.Cache
	TTL time.Duration
}

Cache is cache client.

func New

func New(cfg *config.Config) (*Cache, error)

New cache instance.