cache

Documentation

Index

• type CacheEntry
• type CacheFactory
  • func NewCacheFactory(ki kubernetes.Interface, ns string) CacheFactory
• type CacheType
• type MemoizationCache
  • func NewConfigMapCache(ns string, ki kubernetes.Interface, n string) MemoizationCache

Types

type CacheEntry

type CacheEntry struct {
	NodeID  string        `json:"nodeID"`
	Outputs *wfv1.Outputs `json:"outputs"`
}

type CacheFactory

type CacheFactory interface {
	GetCache(ct CacheType, name string) *MemoizationCache
}

func NewCacheFactory

func NewCacheFactory(ki kubernetes.Interface, ns string) CacheFactory

type CacheType

type CacheType string

const (
	// Only config maps are currently supported for caching
	ConfigMapCache CacheType = "ConfigMapCache"
)

type MemoizationCache

type MemoizationCache interface {
	Load(key string) (*CacheEntry, error)
	Save(key string, nodeId string, value *wfv1.Outputs) error
}

func NewConfigMapCache

func NewConfigMapCache(ns string, ki kubernetes.Interface, n string) MemoizationCache