package main

import (
	"github.com/arriqaaq/chord"
	"github.com/arriqaaq/chord/internal"
	"log"
	"os"
	"os/signal"
	"time"
)

func createNode(id string, addr string, joinNode *internal.Node) (*chord.Node, error) {

	cnf := chord.DefaultConfig()
	cnf.Id = id
	cnf.Addr = addr
	cnf.Timeout = 10 * time.Millisecond
	cnf.MaxIdle = 100 * time.Millisecond

	n, err := chord.NewNode(cnf, joinNode)
	return n, err
}


func main() {

	joinNode := chord.NewInode("1", "0.0.0.0:8001")

	h, err := createNode("8", "0.0.0.0:8003", joinNode)
	if err != nil {
		log.Fatalln(err)
		return
	}

	c := make(chan os.Signal, 1)
	signal.Notify(c, os.Interrupt)
	<-c
	h.Stop()
}

Contributors

Stargazers

Forkers

321dao zhangf911 nguyenquangminh ismiyati butkevicius mdey18 hien abhihash01 rohitkumar1438 pynchmeister vuminh88 jitendraky bonedaddy izouxv yunhel toyzhong r0l1 junxie6 schwartx enixdark zeta1999 anita-walker starnleymbote zebra-uestc vskiadas90 zetianzheng mmirko tristoney anhlt18vn arbersephirotheca aabbdev fgeth saneyuki-akiyama hapbp zzsoszz shivamgupta42 blastbao schiopumatei ggopalai achillesxu atinkolli luis-sousa-pinto muddlebee