config

package

v1.0.0 Latest Latest Go to latest Published: Aug 23, 2023 License: Apache-2.0, Apache-2.0 Imports: 2 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/wuhuizuo/tidb6

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
Variables
func DefineFlagsForCheckpointAdvancerConfig(f *pflag.FlagSet)
type Config
- func Default() Config

Constants ¶

View Source

const (
	DefaultConsistencyCheckTick = 5
	DefaultTryAdvanceThreshold  = 4 * time.Minute
	DefaultBackOffTime          = 5 * time.Second
	DefaultTickInterval         = 12 * time.Second
	DefaultFullScanTick         = 4
	DefaultAdvanceByCache       = true
)

Variables ¶

View Source

var (
	DefaultMaxConcurrencyAdvance = 8
)

Functions ¶

func DefineFlagsForCheckpointAdvancerConfig ¶

func DefineFlagsForCheckpointAdvancerConfig(f *pflag.FlagSet)

Types ¶

type Config ¶

type Config struct {
	// The gap between two retries.
	BackoffTime time.Duration `toml:"backoff-time" json:"backoff-time"`
	// The gap between calculating checkpoints.
	TickDuration time.Duration `toml:"tick-interval" json:"tick-interval"`
	// The threshold for polling TiKV for checkpoint of some range.
	TryAdvanceThreshold time.Duration `toml:"try-advance-threshold" json:"try-advance-threshold"`
}

func Default ¶

func Default() Config

func (Config) GetDefaultStartPollThreshold ¶

func (conf Config) GetDefaultStartPollThreshold() time.Duration

GetDefaultStartPollThreshold returns the threshold of begin polling the checkpoint in the normal condition (the subscribe manager is available.)

func (*Config) GetFromFlags ¶

func (conf *Config) GetFromFlags(f *pflag.FlagSet) error

func (Config) GetSubscriberErrorStartPollThreshold ¶

func (conf Config) GetSubscriberErrorStartPollThreshold() time.Duration

GetSubscriberErrorStartPollThreshold returns the threshold of begin polling the checkpoint when the subscriber meets error.

func (Config) TickTimeout ¶

func (conf Config) TickTimeout() time.Duration

TickTimeout returns the max duration for each tick.

Source Files ¶

View all Source files

advancer_conf.go

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