proxy

Documentation

Index

• func NewHedgingProxy(delegate datastore.Datastore, initialSlowRequestThreshold time.Duration, ...) (datastore.Datastore, error)
• func NewObservableDatastoreProxy(d datastore.Datastore) datastore.Datastore
• func NewReadonlyDatastore(delegate datastore.Datastore) datastore.Datastore
• func NewSingleflightDatastoreProxy(d datastore.Datastore) datastore.Datastore

Functions

func NewHedgingProxy

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

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

func NewObservableDatastoreProxy

func NewObservableDatastoreProxy(d datastore.Datastore) datastore.Datastore

NewObservableDatastoreProxy creates a new datastore proxy which adds tracing and metrics to the datastore.

func NewReadonlyDatastore

func NewReadonlyDatastore(delegate datastore.Datastore) datastore.Datastore

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

func NewSingleflightDatastoreProxy

func NewSingleflightDatastoreProxy(d datastore.Datastore) datastore.Datastore

NewSingleflightDatastoreProxy creates a new Datastore proxy which deduplicates calls to Datastore methods that can share results.