proxy

Documentation

Index

• func NewCachingDatastoreProxy(delegate datastore.Datastore, cacheConfig *cache.Config) (datastore.Datastore, error)
• func NewHedgingProxy(delegate datastore.Datastore, initialSlowRequestThreshold time.Duration, ...) datastore.Datastore
• func NewReadonlyDatastore(delegate datastore.Datastore) datastore.Datastore

Functions

func NewCachingDatastoreProxy

func NewCachingDatastoreProxy(
	delegate datastore.Datastore,
	cacheConfig *cache.Config,
) (datastore.Datastore, error)

NewCachingDatastoreProxy creates a new datastore proxy which caches namespace definitions that are loaded at specific datastore revisions.

func NewHedgingProxy

func NewHedgingProxy(
	delegate datastore.Datastore,
	initialSlowRequestThreshold time.Duration,
	maxSampleCount uint64,
	hedgingQuantile float64,
) datastore.Datastore

NewHedgingProxy creates a proxy which performs request hedging on read operations according to the specified config.

func NewReadonlyDatastore

func NewReadonlyDatastore(delegate datastore.Datastore) datastore.Datastore

NewReadonlyDatastore creates a proxy which disables write operations to a downstream delegate datastore.