model

package
v0.6.1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 17, 2018 License: Apache-2.0 Imports: 2 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrStoreKeyNotFound = errors.New("key not found")
)

Functions

func MakeRaftApplyIndexKey

func MakeRaftApplyIndexKey(rangeID uint64) []byte

func MakeRaftHardStateKey

func MakeRaftHardStateKey(rangeID uint64) []byte

func MakeRaftLastIndexKey

func MakeRaftLastIndexKey(rangeID uint64) []byte

func MakeRaftLogEntryKey

func MakeRaftLogEntryKey(rangeID uint64, index uint64) []byte

func MakeRaftSnapshotMetaKey

func MakeRaftSnapshotMetaKey(rangeID uint64) []byte

func MakeRangeIDUnreplicatedPrefix

func MakeRangeIDUnreplicatedPrefix(rangeID uint64) []byte

Types

type DataNode

type DataNode struct {
	NodeInfo
}

type Iterator

type Iterator interface {
	// return false if over
	Next() bool

	Key() []byte
	Value() []byte

	Error() error
	Release()
}

type KVStore

type KVStore interface {
	Open() error
	Close() error

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

	// scan
	NewIterator(startKey, endKey []byte) Iterator

	// Batch
	NewWriteBatch() WriteBatch

	// Get Snapshot
	GetSnapshot() (Snapshot, error)

	Scan(prefix []byte) Iterator

	Destroy()

	// Size KV Pair Size,不压缩
	Size() int64

	// DiskUsage fdb table file size
	DiskUsage() uint64

	// FindMiddleKey 查找中间Key
	FindMiddleKey() ([]byte, error)

	// split store to two store
	// paths has two path
	Split(splitKey []byte, paths []string) ([]KVStore, error)
}

type MasterConfig

type MasterConfig struct {
	Id    uint64
	Peers map[uint64]*NodeInfo
}

type NodeInfo

type NodeInfo struct {
	Ip     string
	Port   int
	Id     uint64
	Status int
}

type Snapshot

type Snapshot interface {
	NewIterator(startKey, endKey []byte) Iterator
	Get(key []byte) ([]byte, error)
	Release()
}

type WriteBatch

type WriteBatch interface {
	Put(key, value []byte)
	Delete(key []byte)
	Commit() error
}

Directories

Path Synopsis
pkg
alarmpb
Package alarmpb is a generated protocol buffer package.
Package alarmpb is a generated protocol buffer package.
aspb
Package aspb is a generated protocol buffer package.
Package aspb is a generated protocol buffer package.
errorpb
Package errorpb is a generated protocol buffer package.
Package errorpb is a generated protocol buffer package.
eventpb
Package eventpb is a generated protocol buffer package.
Package eventpb is a generated protocol buffer package.
funcpb
Package funcpb is a generated protocol buffer package.
Package funcpb is a generated protocol buffer package.
kvrpcpb
Package kvrpcpb is a generated protocol buffer package.
Package kvrpcpb is a generated protocol buffer package.
lockpb
Package lockrpcpb is a generated protocol buffer package.
Package lockrpcpb is a generated protocol buffer package.
metapb
Package metapb is a generated protocol buffer package.
Package metapb is a generated protocol buffer package.
ms_raftcmdpb
Package ms_raftcmdpb is a generated protocol buffer package.
Package ms_raftcmdpb is a generated protocol buffer package.
mspb
Package mspb is a generated protocol buffer package.
Package mspb is a generated protocol buffer package.
raft_cmdpb
Package raft_cmdpb is a generated protocol buffer package.
Package raft_cmdpb is a generated protocol buffer package.
redispb
Package redispb is a generated protocol buffer package.
Package redispb is a generated protocol buffer package.
schpb
Package schpb is a generated protocol buffer package.
Package schpb is a generated protocol buffer package.
statspb
Package statspb is a generated protocol buffer package.
Package statspb is a generated protocol buffer package.
taskpb
Package taskpb is a generated protocol buffer package.
Package taskpb is a generated protocol buffer package.
timestamp
Package timestamp is a generated protocol buffer package.
Package timestamp is a generated protocol buffer package.

Jump to

Keyboard shortcuts

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