proxy

May 30, 2023

Changes in this version

type ReplicatedRouteOption

+ func WithMemoryScoringFunc(memScoreFunc func(mem float64) float64) ReplicatedRouteOption

Mar 6, 2023

Changes in this version

type Route

+ AllServerIDs func() []ServerID

Mar 1, 2023

Changes in this version

+ const RandomMaxValues

+ type Config struct

+ Route Route

+ Servers []S

+ type Memcache struct

+ func New(conf Config[S], newFunc func(conf S) memproxy.Memcache, ...) (*Memcache, error)

+ func NewSimpleReplicatedMemcache(servers []SimpleServerConfig, numConnsPerServer int, stats ServerStats, ...) (*Memcache, func(), error)

+ func (m *Memcache) Close() error

+ func (m *Memcache) Pipeline(ctx context.Context, options ...memproxy.PipelineOption) memproxy.Pipeline

+ type MemcacheOption func(conf *memcacheConfig)

+ func WithMemcacheSessionProvider(provider memproxy.SessionProvider) MemcacheOption

+ type Pipeline struct

+ func (p *Pipeline) Delete(key string, options memproxy.DeleteOptions) func() (memproxy.DeleteResponse, error)

+ func (p *Pipeline) Execute()

+ func (p *Pipeline) Finish()

+ func (p *Pipeline) LeaseGet(key string, options memproxy.LeaseGetOptions) func() (memproxy.LeaseGetResponse, error)

+ func (p *Pipeline) LeaseSet(key string, data []byte, cas uint64, options memproxy.LeaseSetOptions) func() (memproxy.LeaseSetResponse, error)

+ func (p *Pipeline) LowerSession() memproxy.Session

+ type ReplicatedRouteOption func(conf *replicatedRouteConfig)

+ func WithMinPercentage(percentage float64) ReplicatedRouteOption

+ func WithRandFunc(randFunc func(n uint64) uint64) ReplicatedRouteOption

+ type Route interface

+ NewSelector func() Selector

+ func NewReplicatedRoute(servers []ServerID, stats ServerStats, options ...ReplicatedRouteOption) Route

+ type Selector interface

+ HasNextAvailableServer func() bool

+ Reset func()

+ SelectForDelete func(key string) []ServerID

+ SelectServer func(key string) ServerID

+ SetFailedServer func(server ServerID)

+ type ServerConfig interface

+ GetID func() ServerID

+ type ServerID int

+ type ServerStats interface

+ GetMemUsage func(server ServerID) float64

+ IsServerFailed func(server ServerID) bool

+ NotifyServerFailed func(server ServerID)

+ type SimpleServerConfig struct

+ Host string

+ ID ServerID

+ Port uint16

+ func (c SimpleServerConfig) Address() string

+ func (c SimpleServerConfig) GetID() ServerID

+ type SimpleServerStats struct

+ func NewSimpleServerStats(servers []S, factory func(conf S) StatsClient, options ...SimpleStatsOption) *SimpleServerStats

+ func NewSimpleStats(servers []SimpleServerConfig, options ...SimpleStatsOption) *SimpleServerStats

+ func (s *SimpleServerStats) GetMemUsage(server ServerID) float64

+ func (s *SimpleServerStats) IsServerFailed(server ServerID) bool

+ func (s *SimpleServerStats) NotifyServerFailed(server ServerID)

+ func (s *SimpleServerStats) Shutdown()

+ type SimpleStatsOption func(conf *simpleStatsConfig)

+ func WithSimpleStatsCheckDuration(d time.Duration) SimpleStatsOption

+ func WithSimpleStatsErrorLogger(logger func(err error)) SimpleStatsOption

+ func WithSimpleStatsMemLogger(memLogger func(server ServerID, mem uint64, err error)) SimpleStatsOption

+ type StatsClient interface

+ Close func() error

+ GetMemUsage func() (uint64, error)

+ func NewSimpleStatsClient(conf SimpleServerConfig) StatsClient