ichord

type Application interface {
	ID() UUID
	Startup(args *icfg.Config) error
	ShutDown() error
	// When a error occurs in the functionality of the DHT
	OnError(err error)

	// Receive a message intended for the self node
	OnDeliver(msg *Message)

	// Received a message that needs to be routed onwards
	OnForward(msg *Message, node *Node) bool // return False if chord should not forward

	// A new node has joined the network
	OnNodeJoin(node *Node)

	// A node has left the network
	OnNodeExit(node *Node)

	// Received a heartbeat signal from a peer
	OnHeartbeat(node *Node)
}

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

type ChordAPI interface {
	//Encode and decode the message
	Encode(dataBuf *bytes.Buffer, v interface{}) error
	Decode(dataBuf *bytes.Buffer, v interface{}) error

	//Operate the default db, default is map
	Set(key, value []byte) error
	Get(key []byte) ([]byte, error)
	Del(key []byte) error

	//Set to a specify db
	DBSet(dbName string, key, value []byte) error
	// Get from a specify db
	DBGet(dbName string, key []byte) ([]byte, error)
	//Del from a specify db
	DBDel(dbName string, key []byte) error

	// set default db to replace the default map
	SetDefaultDB(db KvDb)
	//add new kv db
	RegisterDB(dbName string, db KvDb)
	//close a db and remove from list
	CloseDB(dbName string)
	//close a db and remove it, it's dangerous
	DropDB(dbName string)

	//Install an app to handle messages
	InstallApp(cfg *icfg.Config, app Application) error
	//Uninstall an app
	UninstallApp(id UUID) error

	Node() Node
	//Ping is used to detect a node is connectable or not
	Ping(node *Node) bool
	//SendTo a node with []byte format data
	SendTo(node *Node, data []byte) error
	//SendMsg a message and find receiver from the message
	SendMsg(msg *Message) (*Message, error)

	//Listen will hold on a listener and accept connections then handle it.
	Listen(l net.Listener) error
	// maintain will periodically perform maintenance operations
	Maintain()
	//Sync is used to check local data replications number periodically and if not then send that data to other nodes
	Sync()
	//Count statistics how many nodes in the network
	Count() int

	//Join will use self uuid to ask specify nodes or build-in public node to initialize node
	Join(node ...*Node) error
	//Leave tells the specify node or the public nodes I will offline, update network states and re-sync data
	Leave(node ...*Node) error
	//Route find the node that stored this key or should store this key
	Route(key UUID) (*Node, error)
	//FindSuccessor returns the first successor for the given key
	FindSuccessor(key UUID) (*Node, error)
	//FindPredecessor returns the first predecessor for the given key
	FindPredecessor(key UUID) (*Node, error)

	//List returns an array contains all stored nodes' info
	List() ([]*Node, error)
	//Stabilize successor/predecessor pointers
	Stabilize() error
	//Notify a Node of our existence
	Notify(n *Node) (*Message, error)
	//FixFingers table
	FixFingers()
	//ShowFingers table
	ShowFingers() []Finger
}

type Coder interface {
	Name() string
	NewEncoder(io.Writer) Encoder
	NewDecoder(io.Reader) Decoder
}

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

type Decoder interface {
	// Decode into the given interface, or error
	Decode(v interface{}) error
}

type Encoder interface {
	// Encode given interface, or error
	Encode(v interface{}) error
}

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

type FingerTable struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type GobCoder struct{}

type JsonCoder struct{}

type KvDb interface {
	Name() string
	Set(key, value []byte) error
	Get(key []byte) ([]byte, error)
	Del(key []byte) error
	Close() error
	Drop()
}

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

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

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

type Node struct {
	Id   UUID
	Host string
	Port int
	// contains filtered or unexported fields
}

type Purpose int

type UUID = uuid.UUID