Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

raftstore

package

Go to main page

Versions in this module

v1

v1.5.1

Jan 20, 2020

v1.5.0

Jan 8, 2020

v1.4.0

Nov 13, 2019

Changes in this version

+ const DefaultElectionTick

+ const DefaultTickInterval

type Config

+ ElectionTick int

+ TickInterval int

type Partition

+ FirstCommittedIndex func() uint64

+ IsOfflinePeer func() bool

+ TryToLeader func(nodeID uint64) error

type PeerAddress

+ func (p PeerAddress) String() string

type RaftStore

+ RaftServer func() *raft.RaftServer

v1.1.1

Jun 11, 2019

v1.1.0

May 9, 2019

v1.0.0

Apr 2, 2019

Changes in this version

+ const DefaultHeartbeatPort

+ const DefaultNumOfLogsToRetain

+ const DefaultReplicaPort

+ var ErrIllegalAddress = errors.New("illegal address")

+ var ErrNoSuchNode = errors.New("no such node")

+ var ErrNotLeader = errors.New("not a raft leader")

+ var ErrUnknownSocketType = errors.New("unknown socket type")

+ func AddNode(manager NodeManager, nodeID uint64, addr string, heartbeat int, replicate int)

+ func DeleteNode(manager NodeManager, nodeID uint64)

+ type Config struct

+ HeartbeatPort int

+ IPAddr string

+ NodeID uint64

+ NumOfLogsToRetain uint64

+ RaftPath string

+ ReplicaPort int

+ type NodeManager interface

+ AddNode func(nodeID uint64, addr string)

+ AddNodeWithPort func(nodeID uint64, addr string, heartbeat int, replicate int)

+ DeleteNode func(nodeID uint64)

+ type NodeResolver interface

+ func NewNodeResolver() NodeResolver

+ type Partition interface

+ AppliedIndex func() uint64

+ ChangeMember func(changeType proto.ConfChangeType, peer proto.Peer, context []byte) (resp interface{}, err error)

+ CommittedIndex func() uint64

+ Delete func() error

+ IsRaftLeader func() bool

+ LeaderTerm func() (leaderID, term uint64)

+ Status func() (status *PartitionStatus)

+ Stop func() error

+ Submit func(cmd []byte) (resp interface{}, err error)

+ Truncate func(index uint64)

+ type PartitionConfig struct

+ Applied uint64

+ ID uint64

+ Leader uint64

+ Peers []PeerAddress

+ SM PartitionFsm

+ Term uint64

+ WalPath string

+ type PartitionFsm interface

+ type PartitionStatus = raft.Status

+ type PeerAddress struct

+ Address string

+ HeartbeatPort int

+ ReplicaPort int

+ type RaftStore interface

+ CreatePartition func(cfg *PartitionConfig) (Partition, error)

+ RaftConfig func() *raft.Config

+ RaftStatus func(raftID uint64) (raftStatus *raft.Status)

+ Stop func()

+ func NewRaftStore(cfg *Config) (mr RaftStore, err error)

+ type RocksDBStore struct

+ func NewRocksDBStore(dir string, lruCacheSize, writeBufferSize int) (store *RocksDBStore)

+ func (rs *RocksDBStore) BatchPut(cmdMap map[string][]byte, isSync bool) error

+ func (rs *RocksDBStore) Del(key interface{}, isSync bool) (result interface{}, err error)

+ func (rs *RocksDBStore) DeleteKeyAndPutIndex(key string, cmdMap map[string][]byte, isSync bool) error

+ func (rs *RocksDBStore) Get(key interface{}) (result interface{}, err error)

+ func (rs *RocksDBStore) Iterator(snapshot *gorocksdb.Snapshot) *gorocksdb.Iterator

+ func (rs *RocksDBStore) Open(lruCacheSize, writeBufferSize int) error

+ func (rs *RocksDBStore) Put(key, value interface{}, isSync bool) (result interface{}, err error)

+ func (rs *RocksDBStore) ReleaseSnapshot(snapshot *gorocksdb.Snapshot)

+ func (rs *RocksDBStore) Replace(key string, value interface{}, isSync bool) (result interface{}, err error)

+ func (rs *RocksDBStore) RocksDBSnapshot() *gorocksdb.Snapshot

+ func (rs *RocksDBStore) SeekForPrefix(prefix []byte) (result map[string][]byte, err error)

+ type Store interface

+ Del func(key interface{}) (interface{}, error)

+ Get func(key interface{}) (interface{}, error)

+ Put func(key, val interface{}) (interface{}, error)

Incompatible versions in this module

v2.0.0+incompatible

Apr 10, 2020

v2.0.0-rc.1+incompatible

Apr 9, 2020