config

Dec 3, 2022

Changes in this version

+ const DefaultIdleTimeout

+ const DefaultKeepalive

+ const DefaultMaxRetries

+ const DefaultMaxRetryBackoff

+ const DefaultMemberCountQuorum

+ const DefaultMinRetryBackoff

+ const DefaultReadQuorum

+ const DefaultTriggerBalancerInterval

+ const DefaultTriggerCompactionInterval

+ const DefaultWriteQuorum

type Client

+ Dialer func(ctx context.Context, network, addr string) (net.Conn, error)

+ IdleCheckFrequency time.Duration

+ IdleTimeout time.Duration

+ Limiter redis.Limiter

+ MaxConnAge time.Duration

+ MaxRetries int

+ MaxRetryBackoff time.Duration

+ MinIdleConns int

+ MinRetryBackoff time.Duration

+ OnConnect func(ctx context.Context, cn *redis.Conn) error

+ PoolFIFO bool

+ PoolSize int

+ TLSConfig *tls.Config

+ func (c *Client) RedisOptions() *redis.Options

type Config

+ EnableClusterEventsChannel bool

+ IdleClose time.Duration

+ TriggerBalancerInterval time.Duration

type DMap

+ Engine *Engine

type DMaps

+ Engine *Engine

+ TriggerCompactionInterval time.Duration

+ type Engine struct

+ Config map[string]interface{}

+ Implementation storage.Engine

+ Name string

+ func NewEngine() *Engine

+ func (s *Engine) Sanitize() error

+ func (s *Engine) Validate() error

Aug 19, 2022

Changes in this version

+ const DefaultLeaveTimeout

type Config

+ LeaveTimeout time.Duration

Feb 22, 2022

Changes in this version

+ const DefaultKeepAlivePeriod

Aug 17, 2021

Changes in this version

+ const DefaultCheckEmptyFragmentsInterval

+ const DefaultPoolTimeout

+ const DefaultRoutingTablePushInterval

+ const DefaultStorageEngine

+ const LogLevelDebug

+ const LogLevelError

+ const LogLevelInfo

+ const LogLevelWarn

type Client

+ PoolTimeout time.Duration

+ func (c *Client) Validate() error

type Config

+ DMaps *DMaps

+ RoutingTablePushInterval time.Duration

+ StorageEngines *StorageEngines

+ type DMap struct

+ EvictionPolicy EvictionPolicy

+ LRUSamples int

+ MaxIdleDuration time.Duration

+ MaxInuse int

+ MaxKeys int

+ StorageEngine string

+ TTLDuration time.Duration

+ func (dm *DMap) Sanitize() error

+ func (dm *DMap) Validate() error

+ type DMaps struct

+ CheckEmptyFragmentsInterval time.Duration

+ Custom map[string]DMap

+ EvictionPolicy EvictionPolicy

+ LRUSamples int

+ MaxIdleDuration time.Duration

+ MaxInuse int

+ MaxKeys int

+ NumEvictionWorkers int64

+ StorageEngine string

+ TTLDuration time.Duration

+ func (dm *DMaps) Sanitize() error

+ func (dm *DMaps) Validate() error

+ type IConfig interface

+ Sanitize func() error

+ Validate func() error

+ type StorageEngines struct

+ Config map[string]map[string]interface{}

+ Impls map[string]storage.Engine

+ Plugins []string

+ func NewStorageEngine() *StorageEngines

+ func (s *StorageEngines) Sanitize() error

+ func (s *StorageEngines) Validate() error

Nov 19, 2020

Changes in this version

+ const DefaultBootstrapTimeout

+ const DefaultDialTimeout

+ const DefaultReadTimeout

+ const DefaultWriteTimeout

+ type Client struct

+ DialTimeout time.Duration

+ KeepAlive time.Duration

+ MaxConn int

+ MinConn int

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ func NewClient() *Client

+ func (c *Client) HasTimeout() bool

+ func (c *Client) Sanitize()

type Config

+ BootstrapTimeout time.Duration

+ Client *Client

+ func Load(filename string) (*Config, error)

May 4, 2020

Changes in this version

+ const AsyncReplicationMode

+ const DefaultDiscoveryPort

+ const DefaultJoinRetryInterval

+ const DefaultLRUSamples

+ const DefaultLoadFactor

+ const DefaultLogLevel

+ const DefaultLogVerbosity

+ const DefaultMaxJoinAttempts

+ const DefaultPartitionCount

+ const DefaultPort

+ const DefaultRequestTimeout

+ const DefaultTableSize

+ const LRUEviction

+ const MinimumMemberCountQuorum

+ const MinimumReplicaCount

+ const SyncReplicationMode

+ func NewMemberlistConfig(env string) (*memberlist.Config, error)

+ type CacheConfig struct

+ DMapConfigs map[string]DMapCacheConfig

+ EvictionPolicy EvictionPolicy

+ LRUSamples int

+ MaxIdleDuration time.Duration

+ MaxInuse int

+ MaxKeys int

+ NumEvictionWorkers int64

+ TTLDuration time.Duration

+ type Config struct

+ BindAddr string

+ BindPort int

+ Cache *CacheConfig

+ DialTimeout time.Duration

+ Hasher hasher.Hasher

+ Interface string

+ JoinRetryInterval time.Duration

+ KeepAlivePeriod time.Duration

+ LoadFactor float64

+ LogLevel string

+ LogOutput io.Writer

+ LogVerbosity int32

+ Logger *log.Logger

+ MaxJoinAttempts int

+ MemberCountQuorum int32

+ MemberlistConfig *memberlist.Config

+ MemberlistInterface string

+ PartitionCount uint64

+ Peers []string

+ ReadQuorum int

+ ReadRepair bool

+ ReplicaCount int

+ ReplicationMode int

+ RequestTimeout time.Duration

+ Serializer serializer.Serializer

+ ServiceDiscovery map[string]interface{}

+ Started func()

+ TableSize int

+ WriteQuorum int

+ func New(env string) *Config

+ func (c *Config) Sanitize() error

+ func (c *Config) SetupNetworkConfig() (err error)

+ func (c *Config) Validate() error

+ type DMapCacheConfig struct

+ EvictionPolicy EvictionPolicy

+ LRUSamples int

+ MaxIdleDuration time.Duration

+ MaxInuse int

+ MaxKeys int

+ TTLDuration time.Duration

+ type EvictionPolicy string