Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CacheType ¶
type CacheType string
const ( // Only config maps are currently supported for caching ConfigMapCache CacheType = "ConfigMapCache" )
type Entry ¶
type Entry struct {
NodeID string `json:"nodeID"`
Outputs *wfv1.Outputs `json:"outputs"`
CreationTimestamp metav1.Time `json:"creationTimestamp"`
LastHitTimestamp metav1.Time `json:"lastHitTimestamp"`
}
func (*Entry) GetOutputs ¶
func (*Entry) GetOutputsWithMaxAge ¶
type Factory ¶
type Factory interface {
GetCache(ct CacheType, name string) MemoizationCache
}
func NewCacheFactory ¶
func NewCacheFactory(ki kubernetes.Interface, ns string) Factory
type MemoizationCache ¶
type MemoizationCache interface {
Load(ctx context.Context, key string) (*Entry, error)
Save(ctx context.Context, key string, nodeID string, value *wfv1.Outputs) error
}
func NewConfigMapCache ¶
func NewConfigMapCache(ns string, ki kubernetes.Interface, n string) MemoizationCache
Source Files
Click to show internal directories.
Click to hide internal directories.