keys

Documentation

Index

• Variables
• func GetAppliedIndexKey(shardID uint64, key []byte) []byte
• func GetHardStateKey(shardID uint64, replicaID uint64, key []byte) []byte
• func GetMaxIndexKey(shardID uint64, key []byte) []byte
• func GetMetadataIndex(key []byte) (uint64, error)
• func GetMetadataKey(shardID uint64, index uint64, key []byte) []byte
• func GetRaftLogIndex(key []byte) (uint64, error)
• func GetRaftLogKey(shardID uint64, index uint64, key []byte) []byte
• func GetRaftPrefix(shardID uint64) []byte
• func GetShardIDFromAppliedIndexKey(key []byte) (uint64, error)
• func GetShardIDFromMetadataKey(key []byte) (uint64, error)
• func GetSnapshotKey(shardID uint64, index uint64, key []byte) []byte
• func GetStoreIdentKey() []byte
• func IsAppliedIndexKey(key []byte) bool
• func IsMetadataKey(key []byte) bool
• func IsRaftLogKey(key []byte) bool

Variables

var (

	// DataPrefixSize data prefix size
	DataPrefixSize = dataPrefixKeySize + 8
)

data is in (z, z+1)

var (
	// we use this fixed key to write a dummy record into the KVStore with sync=true
	// to force a sync of the WAL of the KVStore.
	ForcedSyncKey = []byte{0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF, 0xFF}
)

Functions

func GetAppliedIndexKey

func GetAppliedIndexKey(shardID uint64, key []byte) []byte

GetAppliedIndexKey returns key that used to store `applied log index` for `storage.DataStorage`

func GetHardStateKey

func GetHardStateKey(shardID uint64, replicaID uint64, key []byte) []byte

GetHardStateKey returns key that used to store `raftpb.HardState`

func GetMaxIndexKey

func GetMaxIndexKey(shardID uint64, key []byte) []byte

GetMaxIndexKey returns key that used to max applied log index

func GetMetadataIndex

func GetMetadataIndex(key []byte) (uint64, error)

func GetMetadataKey

func GetMetadataKey(shardID uint64, index uint64, key []byte) []byte

GetMetadataKey returns key that used to store `shard metadata` for `storage.DataStorage`

func GetRaftLogIndex

func GetRaftLogIndex(key []byte) (uint64, error)

func GetRaftLogKey

func GetRaftLogKey(shardID uint64, index uint64, key []byte) []byte

GetRaftLogKey returns key that used to store `raftpb.Entry`

func GetRaftPrefix

func GetRaftPrefix(shardID uint64) []byte

func GetShardIDFromAppliedIndexKey

func GetShardIDFromAppliedIndexKey(key []byte) (uint64, error)

GetShardIDFromAppliedIndexKey returns shard id

func GetShardIDFromMetadataKey

func GetShardIDFromMetadataKey(key []byte) (uint64, error)

func GetSnapshotKey

func GetSnapshotKey(shardID uint64, index uint64, key []byte) []byte

GetSnapshotKey returns the key used to store snapshot metadata in LogDB.

func GetStoreIdentKey

func GetStoreIdentKey() []byte

GetStoreIdentKey return key of StoreIdent

func IsAppliedIndexKey

func IsAppliedIndexKey(key []byte) bool

func IsMetadataKey

func IsMetadataKey(key []byte) bool

func IsRaftLogKey

func IsRaftLogKey(key []byte) bool