config

package

Go to main page

Versions in this module

v1

v1.0.8

Dec 23, 2024

Changes in this version

type RdbCmdPrint

+ NoLogKey bool

+ NoLogValue bool

+ Output string

v1.0.7

Dec 17, 2024

v1.0.6

Nov 22, 2024

v1.0.5

Nov 14, 2024

Changes in this version

type ReplayConfig

+ AofPipelineMode bool

v1.0.4

Oct 12, 2024

v1.0.3

Oct 10, 2024

Changes in this version

+ func InitRdbConfig(path string) error

v1.0.2

Sep 25, 2024

v1.0.1

Sep 13, 2024

v1.0.0

Aug 16, 2024

Changes in this version

+ func InitSyncerConfig(path string) error

+ type DoubleSliceUint16 [][]uint16

+ func (d *DoubleSliceUint16) Set(value string) error

+ func (d *DoubleSliceUint16) String() string

type FilterConfig

+ SlotFilter *FilterSlotConfig

+ type FilterSlotConfig struct

+ KeySlotBlacklist DoubleSliceUint16

+ KeySlotWhitelist DoubleSliceUint16

type OutputConfig

+ Filter FilterConfig

+ Replay ReplayConfig

+ type RdbCmdConfig struct

+ Action string

+ Load RdbCmdLoad

+ Print RdbCmdPrint

+ RdbPath string

+ func GetRdbCmdConfig() *RdbCmdConfig

+ type RdbCmdLoad struct

+ Filter FilterConfig

+ Redis *RedisConfig

+ Replay ReplayConfig

+ type RdbCmdPrint struct

+ ToCmd bool

+ type ReplayConfig struct

+ BatchBufferSize uint64

+ BatchCmdCount uint

+ BatchTicker time.Duration

+ FunctionExists string

+ KeepaliveTicker time.Duration

+ KeyExists string

+ KeyExistsLog bool

+ MaxProtoBulkLen int

+ ReplaceHashTag bool

+ ReplayRdbEnableRestore *bool

+ ReplayRdbParallel int

+ ReplayTransaction *bool

+ ResumeFromBreakPoint *bool

+ Stats OutputStats

+ TargetDb int

+ TargetDbCfg *int

+ TargetDbMap map[int]int

+ UpdateCheckpointTicker time.Duration

+ type SyncConfig struct

+ Channel *ChannelConfig

+ Cluster *ClusterConfig

+ Input *InputConfig

+ Log *LogConfig

+ Output *OutputConfig

+ Server ServerConfig

+ func GetSyncerConfig() *SyncConfig

+ func (c *SyncConfig) GetLog() *LogConfig

v0

v0.1.9

Jul 26, 2024

Changes in this version

+ var RdbPipeSize = 1024

v0.1.8

Jul 2, 2024

Changes in this version

+ const NamespacePrefixKey

v0.1.7

Jun 4, 2024

v0.1.6

May 28, 2024

v0.1.5

May 17, 2024

Changes in this version

type OutputConfig

+ Stats OutputStats

+ type OutputStats struct

+ DisableLog bool

+ LogInterval time.Duration

type RedisConfig

+ AliveTime time.Duration

+ KeepAlive int

v0.1.4

May 9, 2024

v0.1.3

May 6, 2024

Changes in this version

+ func FlagsParseToStruct(prefix string, obj interface{})

+ func FlagsSetToStruct(obj interface{})

+ type FlagParser interface

+ FlagParse func(prefix string)

+ FlagSet func()

type InputMode

+ func (rt *InputMode) Set(val string) error

type LogConfig

+ Handler LogHandlerConfig

type RedisType

+ func (rt *RedisType) Set(val string) error

type SelNodeStrategy

+ func (rt *SelNodeStrategy) Set(val string) error

+ type SliceInt []int

+ func (ss *SliceInt) Set(val string) error

+ func (ss *SliceInt) String() string

+ func (ss *SliceInt) UnmarshalYAML(value *yaml.Node) error

+ type SliceString []string

+ func (ss *SliceString) Set(val string) error

+ func (ss *SliceString) String() string

+ func (ss *SliceString) UnmarshalYAML(value *yaml.Node) error

v0.1.2

Apr 24, 2024

v0.1.1

Mar 20, 2024

Changes in this version

+ const AppName

+ const CheckpointKey

+ const CheckpointKeyHashKey

+ const RedisRoleAllStr

+ const RedisRoleMasterStr

+ const RedisRoleSlaveStr

+ const TypeDecode

+ const TypeDump

+ const TypeRestore

+ const TypeRump

+ const TypeSync

+ var ErrInvalidConfig = errors.New("invalid configuration")

+ var RDBPipeSize = 1024

+ var StartTime string

+ var Version = "1"

+ func GetAddressesFromRedisConfigSlice(rcfg []RedisConfig) []string

+ func GetLogLevel() zapcore.Level

+ func InitConfig(path string) error

+ func LoadFlags() error

+ func LogModuleName(prefix string) string

+ func SetLogLevel(l zapcore.Level)

+ type AofCmdFlags struct

+ Action string

+ Offset int64

+ Path string

+ Size int64

+ type ChannelConfig struct

+ StaleCheckpointDuration time.Duration

+ Storer *StorerConfig

+ VerifyCrc bool

+ func (cc *ChannelConfig) Clone() *ChannelConfig

+ type ClusterConfig struct

+ GroupName string

+ LeaseRenewInterval time.Duration

+ LeaseTimeout time.Duration

+ MetaEtcd *EtcdConfig

+ type Config struct

+ Channel *ChannelConfig

+ Cluster *ClusterConfig

+ Filter FilterConfig

+ Input *InputConfig

+ Log *LogConfig

+ Output *OutputConfig

+ Server ServerConfig

+ func Get() *Config

+ func (c *Config) GetLog() *LogConfig

+ type DiffCmdFlags struct

+ A string

+ B string

+ DiffMode string

+ Parallel int

+ type EtcdConfig struct

+ AutoSyncInterval time.Duration

+ DialKeepAliveTime time.Duration

+ DialKeepAliveTimeout time.Duration

+ DialTimeout time.Duration

+ Endpoints []string

+ Password string

+ RejectOldCluster bool

+ Ttl int

+ Username string

+ type FakeTime time.Duration

+ func (ft *FakeTime) Duration() time.Duration

+ func (ft *FakeTime) UnmarshalYAML(value *yaml.Node) error

+ type FilterConfig struct

+ CmdBlacklist []string

+ DbBlacklist []int

+ KeyFilter *FilterKeyConfig

+ type FilterKeyConfig struct

+ PrefixKeyBlacklist []string

+ PrefixKeyWhitelist []string

+ type Flags struct

+ AofCmd AofCmdFlags

+ Cmd string

+ ConfigPath string

+ DiffCmd DiffCmdFlags

+ RdbCmd RdbCmdFlags

+ func GetFlag() *Flags

+ type FlushPolicy struct

+ Auto bool

+ DirtySize int64

+ Duration time.Duration

+ EveryWrite bool

+ type InputConfig struct

+ Mode InputMode

+ RdbParallel int

+ Redis *RedisConfig

+ SyncDelayTestKey string

+ SyncFrom SelNodeStrategy

+ func (ic *InputConfig) RdbLimiter() chan struct{}

+ type InputMode int

+ const InputModeAuto

+ const InputModeDynamic

+ const InputModeStatic

+ func (rt *InputMode) UnmarshalYAML(value *yaml.Node) error

+ func (rt InputMode) String() string

+ type LogConfig struct

+ Caller *bool

+ Func *bool

+ Hander LogHandlerConfig

+ LevelStr string

+ ModuleName *bool

+ StacktraceLevelStr string

+ type LogHandlerConfig struct

+ File *LogHandlerFileConfig

+ StdOut bool

+ type LogHandlerFileConfig struct

+ FileName string

+ MaxAge int

+ MaxBackups int

+ MaxSize int

+ type OutputConfig struct

+ BatchBufferSize uint64

+ BatchCmdCount uint

+ BatchTicker time.Duration

+ FakeExpireTime FakeTime

+ FunctionExists string

+ KeepaliveTicker time.Duration

+ KeyExists string

+ KeyExistsLog bool

+ MaxProtoBulkLen int

+ Redis *RedisConfig

+ ReplaceHashTag bool

+ ReplayRdbEnableRestore *bool

+ ReplayRdbParallel int

+ ReplayTransaction *bool

+ ResumeFromBreakPoint *bool

+ TargetDb int

+ TargetDbCfg *int

+ TargetDbMap map[int]int

+ UpdateCheckpointTicker time.Duration

+ type RdbCmdFlags struct

+ RdbAction string

+ RdbPath string

+ ToCmd bool

+ type RedisClusterOptions struct

+ HandleAskErr bool

+ HandleMoveErr bool

+ func (rco *RedisClusterOptions) Clone() *RedisClusterOptions

+ type RedisClusterShard struct

+ Master RedisNode

+ Slaves []RedisNode

+ Slots RedisSlots

+ func (rcs *RedisClusterShard) AllAddresses() []string

+ func (rcs *RedisClusterShard) Clone() *RedisClusterShard

+ func (rcs *RedisClusterShard) CompareTypology(shard *RedisClusterShard) bool

+ func (rcs *RedisClusterShard) Get(sel SelNodeStrategy) *RedisNode

+ type RedisConfig struct

+ Addresses []string

+ ClusterOptions *RedisClusterOptions

+ Otype RedisType

+ Password string

+ TlsEnable bool

+ Type RedisType

+ UserName string

+ Version string

+ func (rc *RedisConfig) Address() string

+ func (rc *RedisConfig) Clone() *RedisConfig

+ func (rc *RedisConfig) FindNode(addr string) *RedisNode

+ func (rc *RedisConfig) GetAllSlots() *RedisSlots

+ func (rc *RedisConfig) GetClusterOptions() *RedisClusterOptions

+ func (rc *RedisConfig) GetClusterShard(addr string) *RedisClusterShard

+ func (rc *RedisConfig) GetClusterShards() []*RedisClusterShard

+ func (rc *RedisConfig) GetSlots(address string) *RedisSlots

+ func (rc *RedisConfig) Index(i int) RedisConfig

+ func (rc *RedisConfig) IsCluster() bool

+ func (rc *RedisConfig) IsMigrating() bool

+ func (rc *RedisConfig) IsStanalone() bool

+ func (rc *RedisConfig) SelNodeByAddress(addr string) *RedisConfig

+ func (rc *RedisConfig) SelNodes(selAllShards bool, sel SelNodeStrategy) []RedisConfig

+ func (rc *RedisConfig) SetClusterShards(sds []*RedisClusterShard)

+ func (rc *RedisConfig) SetMigrating(m bool)

+ func (rc *RedisConfig) SetSlots(slots map[string]*RedisSlots, sortedSlots *RedisSlots)

+ type RedisNode struct

+ Address string

+ Endpoint string

+ Health string

+ HostName string

+ Id string

+ Ip string

+ Port int

+ ReplOffset int64

+ Role RedisRole

+ TlsPort int

+ func (rn *RedisNode) AddressEqual(b *RedisNode) bool

+ func (rn *RedisNode) IsHealth() bool

+ type RedisRole int

+ const RedisRoleAll

+ const RedisRoleMaster

+ const RedisRoleSlave

+ func (m *RedisRole) UnmarshalYAML(value *yaml.Node) error

+ func (m RedisRole) String() string

+ func (rr *RedisRole) Parse(str string)

+ type RedisSlotRange struct

+ Left int

+ Right int

+ type RedisSlots struct

+ Ranges []RedisSlotRange

+ func (rs *RedisSlots) Clone() *RedisSlots

+ func (rs *RedisSlots) Equal(b *RedisSlots) bool

+ func (rs *RedisSlots) Len() int

+ func (rs *RedisSlots) Less(i, j int) bool

+ func (rs *RedisSlots) Swap(i, j int)

+ type RedisType int

+ const RedisTypeCluster

+ const RedisTypeSentinel

+ const RedisTypeStandalone

+ const RedisTypeUnknown

+ func (rt *RedisType) UnmarshalYAML(value *yaml.Node) error

+ func (rt RedisType) String() string

+ type SelNodeStrategy int

+ const SelNodeStrategyMaster

+ const SelNodeStrategyPreferSlave

+ const SelNodeStrategySlave

+ func (rt *SelNodeStrategy) UnmarshalYAML(value *yaml.Node) error

+ func (rt SelNodeStrategy) String() string

+ type ServerConfig struct

+ CheckRedisTypologyTicker time.Duration

+ GracefullStopTimeout time.Duration

+ Listen string

+ ListenPeer string

+ ListenPort int

+ MetricRoutePath string

+ type StorerConfig struct

+ DirPath string

+ Flush FlushPolicy

+ LogSize int64

+ MaxSize int64

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