storage

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

type DiskStorage struct {
	Dir string

	Mu       sync.RWMutex
	Segments []*Segment

	ReserveSegmentCount int

	MetaStorage
	// contains filtered or unexported fields
}

type EntryReader interface {
	GetNext() (*raftpb.Entry, error)
	NextRaftIndex() uint64
}

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

type IndexEntry struct {
	RaftIndex    uint64
	FilePosition uint32
}

type MemoryEventReader struct {
}

type MemoryStorage struct {
	MetaStorage
	// contains filtered or unexported fields
}

type MetaStorage interface {
	InitialState() (raftpb.HardState, raftpb.ConfState, error)
	SaveHardState(st raftpb.HardState) error

	Get(key []byte) ([]byte, error)
	Set(key, value []byte) error
	Delete(key []byte) error

	//key is key+flavor
	SetGtidSet(flavor string, key string, gtidSet gomysql.GTIDSet) error
	GetGtidSet(flavor string, key string) (gomysql.GTIDSet, error)
	SetBinlogProgress(appliedIndex uint64, executedGtidSet gomysql.GTIDSet) error

	GetFde(preGtidEventIndex uint64) ([]byte, error)

	//get the raft index of PreviousGtidSet
	GetPreviousGtidSet(slaveExecutedGtids *gomysql.MysqlGTIDSet) (uint64, error)
	SetPreviousGtidSet(raftIndex uint64, previousGtidSet *gomysql.MysqlGTIDSet) error

	GetNextBinlogFile(startRaftIndex uint64) (string, error)
	UpdatePugedGtidset(firstIndex uint64) error

	Close2() error
}

type MetaStore struct {
	DB         *bolt.DB
	Dir        string
	BucketName []byte
}

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

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

type Segment struct {
	Mu         sync.RWMutex
	FirstIndex uint64
	LastIndex  uint64

	LogFile  *MmapFile
	LogIndex *Index
	Status   SegmentStatus
}

type SegmentStatus int8

type Storage interface {
	// entries returns a slice of log entries in the range [lo,hi).
	// MaxSize limits the total size of the log entries returned, but
	// entries returns at least one entry if any.
	Entries(lo, hi, maxSize uint64) ([]raftpb.Entry, error)
	// Term returns the term of entry i, which must be in the range
	// [FirstIndex()-1, LastIndex()]. The term of the entry before
	// FirstIndex is retained for matching purposes even though the
	// rest of that entry may not be available.SaveHardState
	Term(i uint64) (uint64, error)
	// LastIndex returns the index of the last entry in the log.
	LastIndex() (uint64, error)
	// FirstIndex returns the index of the first log entry that is
	// possibly available via entries (older entries have been incorporated
	// into the latest Snapshot; if storage only contains the dummy entry the
	// first log entry is not available).
	FirstIndex() (uint64, error)
	// Snapshot returns the most recent snapshot.
	// If snapshot is temporarily unavailable, it should return ErrSnapshotTemporarilyUnavailable,
	// so raft state machine could know that Storage needs some time to prepare
	// snapshot and call Snapshot later.
	Snapshot() (raftpb.Snapshot, error)
	SaveRaftEntries(entries []raftpb.Entry) error
	TruncateSuffix(i uint64) error
	StartPurgeLog()
	StopPurgeLog()

	MetaStorage
	NewEntryReaderAt(raftIndex uint64) (EntryReader, error)
	Close() error
}