lib

package

v0.0.0-...-967259b Latest Latest Go to latest Published: May 5, 2021 License: MIT Imports: 18 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

This section is empty.

This section is empty.

func NewDiskKV(clusterID uint64, nodeID uint64) sm.IOnDiskStateMachine

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

func (d *DiskKV) Close() error

func (d *DiskKV) Lookup(key interface{}) (interface{}, error)

func (d *DiskKV) Open(stopc <-chan struct{}) (uint64, error)

Open Open打开状态机并返回最后一个Raft Log条目的索引

func (d *DiskKV) PrepareSnapshot() (interface{}, error)

PrepareSnapshot 准备快照

func (d *DiskKV) RecoverFromSnapshot(reader io.Reader, i <-chan struct{}) error

func (d *DiskKV) SaveSnapshot(ctx interface{}, w io.Writer, i2 <-chan struct{}) error

func (d *DiskKV) Sync() error

Sync 同步会同步状态机的所有内核状态。自更新以来

func (d *DiskKV) Update(entries []sm.Entry) ([]sm.Entry, error)

type KVData struct {
	Key string
	Val string
}