snap

type ApplyOptions struct {
	DB     *badger.DB
	Region *metapb.Region
}

type ApplySnapAbortError string

type CFFile struct {
	CF          string
	Path        string
	TmpPath     string
	SstWriter   *table.Builder
	File        *os.File
	KVCount     int
	Size        uint64
	WrittenSize uint64
	Checksum    uint32
	WriteDigest hash.Hash32
}

type MetaFile struct {
	Meta *rspb.SnapshotMeta
	Path string
	File *os.File

	// for writing snapshot
	TmpPath string
}

type Snap struct {
	CFFiles []*CFFile

	MetaFile  *MetaFile
	SizeTrack *int64
	// contains filtered or unexported fields
}

type SnapEntry int

type SnapKey struct {
	RegionID uint64
	Term     uint64
	Index    uint64
}

type SnapKeyWithSending struct {
	SnapKey   SnapKey
	IsSending bool
}

type SnapManager struct {
	MaxTotalSize uint64
	// contains filtered or unexported fields
}

type SnapManagerBuilder struct {
	// contains filtered or unexported fields
}

type SnapState struct {
	StateType SnapStateType
	Receiver  chan *eraftpb.Snapshot
}

type SnapStateType int

type SnapStatistics struct {
	Size    uint64
	KVCount int
}

type SnapStats struct {
	ReceivingCount int
	SendingCount   int
}

type Snapshot interface {
	io.Reader
	io.Writer
	Build(dbSnap *badger.Txn, region *metapb.Region, snapData *rspb.RaftSnapshotData, stat *SnapStatistics, deleter SnapshotDeleter) error
	Path() string
	Exists() bool
	Delete()
	Meta() (os.FileInfo, error)
	TotalSize() uint64
	Save() error
	Apply(option ApplyOptions) error
}

type SnapshotDeleter interface {
	// DeleteSnapshot returns true if it successfully delete the specified snapshot.
	DeleteSnapshot(key SnapKey, snapshot Snapshot, checkEntry bool) bool
}