datastore

Documentation

Index

• Constants
• func GetDataLifetimeKeyFromInputData(predecessor lifetimesapi.InputDataSpec) (string, error)
• func GetDataLifetimeKeyFromOutputData(successor lifetimesapi.OutputDataSpec) (string, error)
• type DataStoreOperations
• type LifetimeCache
• type ValidationDataStoreOperations

Constants

const (
	LifetimeCachePrefix = "ltc%"

	DataLifetimePrefix = "dlt-"
	CsiPrefix          = "csi-"
)

Functions

func GetDataLifetimeKeyFromInputData

func GetDataLifetimeKeyFromInputData(
	predecessor lifetimesapi.InputDataSpec) (string, error)

func GetDataLifetimeKeyFromOutputData

func GetDataLifetimeKeyFromOutputData(
	successor lifetimesapi.OutputDataSpec) (
	string, error)

Types

type DataStoreOperations

type DataStoreOperations interface {
	Close() error
}

type LifetimeCache

type LifetimeCache struct {
	EndTime                string              `json:"endTime"`
	SuccessorLifetimes     map[string]struct{} `json:"successorLifetimes,omitempty"`
	SuccessorPodTerminated bool                `json:"successorPodTerminated,omitempty"`
}

type ValidationDataStoreOperations

type ValidationDataStoreOperations interface {
	DataStoreOperations

	GetDataLifetimeKeys() ([]string, error)
	GetDataLifetime(key string) (*LifetimeCache, error)

	AddDataLifetime(key string, endTime string) (*LifetimeCache, error)
	DeleteDataLifetime(key string) error

	AddSuccessorDataLifetimeCustomResource(key string, successor string) error
	DeleteSuccessorDataLifetimeCustomResource(key string, successor string) error
}