integrity

Documentation

Index

• Constants
• type Checksum
• type Config
  • func (c *Config) Enabled() bool
  • func (c *Config) ErrorHandle() bool
  • func (c *Config) Validate() error

Constants

const (
	// CheckLevelNone means no integrity check, the default value.
	CheckLevelNone string = "none"
	// CheckLevelCorrectness means check each row data correctness.
	CheckLevelCorrectness string = "correctness"
)

const (
	// CorruptionHandleLevelWarn is the default value,
	// log the corrupted event, and mark it as corrupted and send it to the downstream.
	CorruptionHandleLevelWarn string = "warn"
	// CorruptionHandleLevelError means log the corrupted event, and then stopped the changefeed.
	CorruptionHandleLevelError string = "error"
)

Types

type Checksum

type Checksum struct {
	Current   uint32
	Previous  uint32
	Corrupted bool
	Version   int
}

Checksum represent checksum for an RowChangedEvent

type Config

type Config struct {
	IntegrityCheckLevel   string `toml:"integrity-check-level" json:"integrity-check-level"`
	CorruptionHandleLevel string `toml:"corruption-handle-level" json:"corruption-handle-level"`
}

Config represents integrity check config for a changefeed.

func (*Config) Enabled

func (c *Config) Enabled() bool

Enabled returns true if the integrity check is enabled.

func (*Config) ErrorHandle

func (c *Config) ErrorHandle() bool

ErrorHandle returns true if the corruption handle level is error.

func (*Config) Validate

func (c *Config) Validate() error

Validate the integrity config.