kademlia

README

contract.go

kademlia.go

nodeid.go

routingtable.go

Documentation

Index

• Constants
• func Client()
• func Equal(x interface{}, table *RoutingTable) bool
• func RunServer()
• type Contract
  • func (contract *Contract) String() string
• type ContractRecord
  • func (rec *ContractRecord) Less(other interface{}) bool
• type FindNodeRequest
• type FindNodeResponse
• type Kademlia
  • func NewKademlia(contract *Contract, networkId string) (ret *Kademlia)
  • func (k *Kademlia) Call(contract *Contract, method string, args, reply interface{}) error
  • func (k *Kademlia) HandleRPC(request, response *RPCHeader) error
  • func (k *Kademlia) Serve() error
• type KademliaCore
  • func (kc *KademliaCore) FindNode(args *FindNodeRequest, response *FindNodeResponse) error
  • func (kc *KademliaCore) Ping(args *PingRequest, response *PingResponce) error
• type NodeID
  • func NewNodeID(data string) (ret NodeID)
  • func NewRandomNodeID() (ret NodeID)
  • func (node NodeID) Equals(other NodeID) bool
  • func (node NodeID) Less(other interface{}) bool
  • func (node NodeID) PrefixLen() (ret int)
  • func (node NodeID) String() string
  • func (node NodeID) Xor(other NodeID) (ret NodeID)
• type PingRequest
• type PingResponce
• type RPCHeader
• type RoutingTable
  • func NewRoutingTable(node *Contract) (ret *RoutingTable)
  • func (table *RoutingTable) FindClosest(target NodeID, count int) (ret []interface{})
  • func (table *RoutingTable) Update(contract *Contract)

Constants

const BucketSize = 20

const IdLength = 20

Functions

func Client

func Client()

func Equal

func Equal(x interface{}, table *RoutingTable) bool

func RunServer

func RunServer()

Types

type Contract

type Contract struct {
	Id      NodeID
	Address string
}

func (*Contract) String

func (contract *Contract) String() string

type ContractRecord

type ContractRecord struct {
	// contains filtered or unexported fields
}

func (*ContractRecord) Less

func (rec *ContractRecord) Less(other interface{}) bool

type FindNodeRequest

type FindNodeRequest struct {
	RPCHeader
	// contains filtered or unexported fields
}

type FindNodeResponse

type FindNodeResponse struct {
	RPCHeader
	// contains filtered or unexported fields
}

type Kademlia

type Kademlia struct {
	NetworkId string
	// contains filtered or unexported fields
}

func NewKademlia

func NewKademlia(contract *Contract, networkId string) (ret *Kademlia)

func (*Kademlia) Call

func (k *Kademlia) Call(contract *Contract, method string, args, reply interface{}) error

rpc client

func (*Kademlia) HandleRPC

func (k *Kademlia) HandleRPC(request, response *RPCHeader) error

func (*Kademlia) Serve

func (k *Kademlia) Serve() error

rpc server

type KademliaCore

type KademliaCore struct {
	// contains filtered or unexported fields
}

func (*KademliaCore) FindNode

func (kc *KademliaCore) FindNode(args *FindNodeRequest, response *FindNodeResponse) error

func (*KademliaCore) Ping

func (kc *KademliaCore) Ping(args *PingRequest, response *PingResponce) error

type NodeID

type NodeID [IdLength]byte

func NewNodeID

func NewNodeID(data string) (ret NodeID)

func NewRandomNodeID

func NewRandomNodeID() (ret NodeID)

func (NodeID) Equals

func (node NodeID) Equals(other NodeID) bool

func (NodeID) Less

func (node NodeID) Less(other interface{}) bool

func (NodeID) PrefixLen

func (node NodeID) PrefixLen() (ret int)

func (NodeID) String

func (node NodeID) String() string

func (NodeID) Xor

func (node NodeID) Xor(other NodeID) (ret NodeID)

type PingRequest

type PingRequest struct {
	RPCHeader
}

type PingResponce

type PingResponce struct {
	RPCHeader
}

type RPCHeader

type RPCHeader struct {
	Sender *Contract
	// contains filtered or unexported fields
}

type RoutingTable

type RoutingTable struct {
	// contains filtered or unexported fields
}

func NewRoutingTable

func NewRoutingTable(node *Contract) (ret *RoutingTable)

func (*RoutingTable) FindClosest

func (table *RoutingTable) FindClosest(target NodeID, count int) (ret []interface{})

func (*RoutingTable) Update

func (table *RoutingTable) Update(contract *Contract)