test

Documentation

Index

• type Peer
  • func InitPeer(ip string, port, bootPort int) *Peer
  • func NewPeer(ip string, port, bootPort int, isBootstrapNode bool) *Peer
  • func (p *Peer) Store(entity string, data *[]byte) (*[]byte, error)
• type Storage
  • func NewStorage() *Storage
  • func (s *Storage) GetKeys() map[string][][]byte
  • func (s *Storage) Handle(action string, request string, data *[]byte) (response *[]byte, err error)
  • func (s *Storage) MainEntity() string
  • func (s *Storage) Read(entity string, key []byte) (data *[]byte, err error)
  • func (s *Storage) Store(entity string, key []byte, data *[]byte) (*[]byte, error)

Types

type Peer

type Peer struct {
	kademlia.Node
}

func InitPeer

func InitPeer(ip string, port, bootPort int) *Peer

func NewPeer

func NewPeer(ip string, port, bootPort int, isBootstrapNode bool) *Peer

func (*Peer) Store

func (p *Peer) Store(entity string, data *[]byte) (*[]byte, error)

type Storage

type Storage struct {
	KV map[string][]byte
}

func NewStorage

func NewStorage() *Storage

func (*Storage) GetKeys

func (s *Storage) GetKeys() map[string][][]byte

func (*Storage) Handle

func (s *Storage) Handle(action string, request string, data *[]byte) (response *[]byte, err error)

func (*Storage) MainEntity

func (s *Storage) MainEntity() string

func (*Storage) Read

func (s *Storage) Read(entity string, key []byte) (data *[]byte, err error)

func (*Storage) Store

func (s *Storage) Store(entity string, key []byte, data *[]byte) (*[]byte, error)