proxy

Documentation

Index

• func NewHedgingProxy(delegate datastore.Datastore, initialSlowRequestThreshold time.Duration, ...) datastore.Datastore
• func NewMappingProxy(delegate datastore.Datastore, mapper namespace.Mapper, ...) datastore.Datastore
• func NewReadonlyDatastore(delegate datastore.Datastore) datastore.Datastore
• type MapperFunc

Functions

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 NewMappingProxy

func NewMappingProxy(delegate datastore.Datastore, mapper namespace.Mapper, watchBufferLength uint16) datastore.Datastore

NewMappingProxy creates a proxy which maps user provided namespaces names to encoded namespace names according to a mapping.

func NewReadonlyDatastore

func NewReadonlyDatastore(delegate datastore.Datastore) datastore.Datastore

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

Types

type MapperFunc

type MapperFunc func(string) (string, error)

MapperFunc is used to translate ObjectTypes into another form before interacting with a datastore.