raftstore

Jan 20, 2020 GO-2024-2430 +4 more

  GO-2024-2430: Authenticated users can crash the CubeFS servers with maliciously crafted requests in github.com/cubefs/cubefs

  GO-2024-2431: Insecure random string generator used for sensitive data in github.com/cubefs/cubefs

  GO-2024-2432: CubeFS timing attack can leak user passwords in github.com/cubefs/cubefs

  GO-2024-2433: CubeFS leaks magic secret key when starting Blobstore access service in github.com/cubefs/cubefs

  GO-2024-2434: CubeFS leaks users key in logs in github.com/cubefs/cubefs

Jan 8, 2020 GO-2024-2430 +4 more

  GO-2024-2430: Authenticated users can crash the CubeFS servers with maliciously crafted requests in github.com/cubefs/cubefs

  GO-2024-2431: Insecure random string generator used for sensitive data in github.com/cubefs/cubefs

  GO-2024-2432: CubeFS timing attack can leak user passwords in github.com/cubefs/cubefs

  GO-2024-2433: CubeFS leaks magic secret key when starting Blobstore access service in github.com/cubefs/cubefs

  GO-2024-2434: CubeFS leaks users key in logs in github.com/cubefs/cubefs

Nov 13, 2019 GO-2024-2430 +4 more

  GO-2024-2430: Authenticated users can crash the CubeFS servers with maliciously crafted requests in github.com/cubefs/cubefs

  GO-2024-2431: Insecure random string generator used for sensitive data in github.com/cubefs/cubefs

  GO-2024-2432: CubeFS timing attack can leak user passwords in github.com/cubefs/cubefs

  GO-2024-2433: CubeFS leaks magic secret key when starting Blobstore access service in github.com/cubefs/cubefs

  GO-2024-2434: CubeFS leaks users key in logs in github.com/cubefs/cubefs

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

Jun 11, 2019 GO-2024-2430 +4 more

  GO-2024-2430: Authenticated users can crash the CubeFS servers with maliciously crafted requests in github.com/cubefs/cubefs

  GO-2024-2431: Insecure random string generator used for sensitive data in github.com/cubefs/cubefs

  GO-2024-2432: CubeFS timing attack can leak user passwords in github.com/cubefs/cubefs

  GO-2024-2433: CubeFS leaks magic secret key when starting Blobstore access service in github.com/cubefs/cubefs

  GO-2024-2434: CubeFS leaks users key in logs in github.com/cubefs/cubefs

May 9, 2019 GO-2024-2430 +4 more

  GO-2024-2430: Authenticated users can crash the CubeFS servers with maliciously crafted requests in github.com/cubefs/cubefs

  GO-2024-2431: Insecure random string generator used for sensitive data in github.com/cubefs/cubefs

  GO-2024-2432: CubeFS timing attack can leak user passwords in github.com/cubefs/cubefs

  GO-2024-2433: CubeFS leaks magic secret key when starting Blobstore access service in github.com/cubefs/cubefs

  GO-2024-2434: CubeFS leaks users key in logs in github.com/cubefs/cubefs

Apr 2, 2019 GO-2024-2430 +4 more

  GO-2024-2430: Authenticated users can crash the CubeFS servers with maliciously crafted requests in github.com/cubefs/cubefs

  GO-2024-2431: Insecure random string generator used for sensitive data in github.com/cubefs/cubefs

  GO-2024-2432: CubeFS timing attack can leak user passwords in github.com/cubefs/cubefs

  GO-2024-2433: CubeFS leaks magic secret key when starting Blobstore access service in github.com/cubefs/cubefs

  GO-2024-2434: CubeFS leaks users key in logs in github.com/cubefs/cubefs

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)