Versions in this module Expand all Collapse all v0 v0.0.1 Dec 11, 2018 Changes in this version + const ItemSize + type Conn struct + func Dial(url string) (*Conn, error) + func (c *Conn) Close() error + func (c *Conn) Delete(key []byte) error + func (c *Conn) Get(key []byte) ([]byte, error) + func (c *Conn) Keys() ([][]byte, error) + func (c *Conn) Ping() error + func (c *Conn) Reconsilate() (net.Conn, error) + func (c *Conn) Set(key, value []byte) error + func (c *Conn) Tidy() error + type Item [ItemSize]byte + type Metric interface + ClientConnected func(string) + ClientDisconnected func(string) + CountChanged func(int, int) + PeerConnected func(string) + PeerDisconnected func(string) + type MetricLog struct + func NewMetricLog() *MetricLog + func (ml *MetricLog) ClientConnected(clientURL string) + func (ml *MetricLog) ClientDisconnected(clientURL string) + func (ml *MetricLog) CountChanged(valueCount, deletedCount int) + func (ml *MetricLog) PeerConnected(peerURL string) + func (ml *MetricLog) PeerDisconnected(peerURL string) + type MetricMock struct + func NewMetricMock() *MetricMock + func (mm *MetricMock) ClientConnected(_ string) + func (mm *MetricMock) ClientDisconnected(_ string) + func (mm *MetricMock) CountChanged(valueCount, deletedCount int) + func (mm *MetricMock) PeerConnected(_ string) + func (mm *MetricMock) PeerDisconnected(_ string) + type Node struct + Store *Store + func NewNode(o Options, m Metric) (*Node, error) + func (n *Node) Close() error + func (n *Node) ListenURL() string + type Options struct + ListenURL string + PeerPingInterval time.Duration + PeerReconnectInterval time.Duration + PeerURLs []string + TidyInterval time.Duration + type Server struct + func NewServer(store *Store, listenURL string, m Metric) (*Server, error) + func (s *Server) AddPeer(peerURL string, peerPingInterval time.Duration, ...) + func (s *Server) Close() error + func (s *Server) ListenURL() string + func (s *Server) Reconcilate(url string) (int, error) + type Set struct + func NewSet() *Set + func (s *Set) Insert(item Item) error + func (s *Set) Items() []Item + func (s *Set) Len() int + func (s *Set) Remove(item Item) error + type Store struct + func NewStore(m Metric) *Store + func (s *Store) Delete(key []byte) error + func (s *Store) DeletedLen() int + func (s *Store) Each(fn func([]byte, []byte) error) (err error) + func (s *Store) Get(key []byte) ([]byte, error) + func (s *Store) Len() int + func (s *Store) Set(key, value []byte) error + func (s *Store) State() *Set + func (s *Store) Tidy() error