raftproxy

Documentation

Index

• type RaftCache
• type RaftProxy
  • func NewRaftProxy(imp cache.UnImplementedCache, raftAddr, joinAddr, localId string) *RaftProxy
  • func (c *RaftProxy) Delete(key string) (ok bool)
  • func (c *RaftProxy) Get(key string) (value string, ok bool)
  • func (c *RaftProxy) Join(nodeID, addr string) error
  • func (c *RaftProxy) OpenRaft(storage string) error
  • func (c *RaftProxy) Put(key string, value string) (created bool)

Types

type RaftCache

type RaftCache interface {
	raft.FSM
	cache.UnImplementedCache
	OpenRaft(storage string) error
}

type RaftProxy

type RaftProxy struct {
	Imp cache.UnImplementedCache

	RaftCache
	// contains filtered or unexported fields
}

func NewRaftProxy

func NewRaftProxy(imp cache.UnImplementedCache, raftAddr, joinAddr, localId string) *RaftProxy

func (*RaftProxy) Delete

func (c *RaftProxy) Delete(key string) (ok bool)

func (*RaftProxy) Get

func (c *RaftProxy) Get(key string) (value string, ok bool)

func (*RaftProxy) Join

func (c *RaftProxy) Join(nodeID, addr string) error

Join joins a node, identified by nodeID and located at addr, to this store. The node must be ready to respond to Raft communications at that address.

func (*RaftProxy) OpenRaft

func (c *RaftProxy) OpenRaft(storage string) error

func (*RaftProxy) Put

func (c *RaftProxy) Put(key string, value string) (created bool)

Put updates or insert a new entry, evicts the old entry if cache size is larger than capacity