config

package

Go to main page

Versions in this module

v0

v0.3.0

Mar 9, 2022

Changes in this version

type CustomizeConfig

+ CustomWrapNewTransport func(transport.Trans) transport.Trans

v0.2.0

Jan 5, 2022

Changes in this version

type Config

+ AdvertiseClientAddr string

+ AdvertiseRaftAddr string

+ Logger *zap.Logger

+ func (c *Config) GetModuleLogger(name string, options ...zap.Option) *zap.Logger

type CustomizeConfig

+ CustomTransportFilter func(meta.RaftMessage) bool

type ReplicationConfig

+ CompactLogCheckDuration typeutil.Duration

type TestConfig

+ ReplicaSetSnapshotJobWait time.Duration

v0.1.0

Oct 13, 2021

Changes in this version

+ type Config struct

+ Capacity typeutil.ByteSize

+ ClientAddr string

+ Customize CustomizeConfig

+ DataPath string

+ DeployPath string

+ FS vfs.FS

+ GitHash string

+ Labels [][]string

+ Metric metric.Cfg

+ Prophet pconfig.Config

+ Raft RaftConfig

+ RaftAddr string

+ Replication ReplicationConfig

+ ShardGroups uint64

+ Snapshot SnapshotConfig

+ Storage StorageConfig

+ Test TestConfig

+ UseMemoryAsStorage bool

+ Version string

+ Worker WorkerConfig

+ func (c *Config) Adjust()

+ func (c *Config) GetLabels() []metapb.Pair

+ func (c *Config) SnapshotDir() string

+ type CustomizeConfig struct

+ CustomAdjustCompactFuncFactory func(group uint64) ...

+ CustomAdjustInitAppliedIndexFactory func(group uint64) ...

+ CustomCanReadLocalFunc func(bhmetapb.Shard) bool

+ CustomInitShardsFactory func() []bhmetapb.Shard

+ CustomShardPoolShardFactory func(g uint64, start, end []byte, unique string, offsetInPool uint64) bhmetapb.Shard

+ CustomShardStateAwareFactory func() aware.ShardStateAware

+ CustomSnapshotDataApplyFuncFactory func(group uint64) func(dataPath string, shard bhmetapb.Shard) error

+ CustomSnapshotDataCreateFuncFactory func(group uint64) func(dataPath string, shard bhmetapb.Shard) error

+ CustomSnapshotManagerFactory func() snapshot.SnapshotManager

+ CustomSplitCheckFuncFactory func(group uint64) ...

+ CustomSplitCompletedFuncFactory func(group uint64) func(old *bhmetapb.Shard, news []bhmetapb.Shard)

+ CustomStoreHeartbeatDataProcessor StoreHeartbeatDataProcessor

+ CustomTransportFactory func() transport.Transport

+ type RaftConfig struct

+ ElectionTimeoutTicks int

+ HeartbeatTicks int

+ MaxEntryBytes typeutil.ByteSize

+ MaxInflightMsgs int

+ MaxSizePerMsg typeutil.ByteSize

+ RaftLog RaftLogConfig

+ SendRaftBatchSize uint64

+ TickInterval typeutil.Duration

+ func (c *RaftConfig) GetElectionTimeoutDuration() time.Duration

+ func (c *RaftConfig) GetHeartbeatDuration() time.Duration

+ type RaftLogConfig struct

+ CompactDuration typeutil.Duration

+ CompactProtectLag uint64

+ CompactThreshold uint64

+ DisableCompactProtect []uint64

+ DisableSync bool

+ ForceCompactBytes uint64

+ ForceCompactCount uint64

+ MaxAllowTransferLag uint64

+ type ReplicationConfig struct

+ AllowRemoveLeader bool

+ DisableShardSplit bool

+ MaxPeerDownTime typeutil.Duration

+ ShardCapacityBytes typeutil.ByteSize

+ ShardHeartbeatDuration typeutil.Duration

+ ShardSplitCheckBytes typeutil.ByteSize

+ ShardSplitCheckDuration typeutil.Duration

+ ShardStateCheckDuration typeutil.Duration

+ StoreHeartbeatDuration typeutil.Duration

+ type ShardConfig struct

+ SplitCheckDiff uint64

+ SplitCheckInterval typeutil.Duration

+ type SnapshotConfig struct

+ MaxConcurrencySnapChunks uint64

+ SnapChunkSize typeutil.ByteSize

+ type StorageConfig struct

+ DataMoveFunc func(bhmetapb.Shard, []bhmetapb.Shard) error

+ DataStorageFactory func(group uint64, shardID uint64) storage.DataStorage

+ ForeachDataStorageFunc func(cb func(storage.DataStorage))

+ MetaStorage storage.MetadataStorage

+ type StoreHeartbeatDataProcessor interface

+ CollectData func() []byte

+ HandleHeartbeatRsp func(data []byte) error

+ type TestConfig struct

+ PeerReplicaSetSnapshotJobWait time.Duration

+ SaveDynamicallyShardInitStateWait time.Duration

+ ShardPoolCreateWaitC chan struct{}

+ ShardStateAware aware.TestShardStateAware

+ Shards map[uint64]*TestShardConfig

+ type TestShardConfig struct

+ SkipApply bool

+ SkipSaveRaftApplyState bool

+ type WorkerConfig struct

+ ApplyWorkerCount uint64

+ RaftEventWorkers uint64

+ SendRaftMsgWorkerCount uint64

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL