edclient

ed-client

etcd discovery client lib.

Introduce

1. After the etcd service breaks down and restarts, you can restore the connection status and re-register the service.
2. Distributed locks are used to ensure that no data loss occurs during service discovery when services are started.
3. Support Simple LB. (Concurrency security)

Usage guide

download

go get github.com/kiraqjx/ed-client

registrant

package main

import (
	"context"
	"time"

	"github.com/coreos/etcd/clientv3"
	edclient "github.com/kiraqjx/ed-client"
)

func main() {

	cli, err := clientv3.New(clientv3.Config{
		Endpoints:   []string{"127.0.0.1:2379"},
		DialTimeout: time.Second * 5,
	})
	if err != nil {
		panic(err)
	}

	r := edclient.NewRegistrant(cli, "/ed-client", "/b/", &edclient.NodeInfo{
		Server: "127.0.0.1:8081",
		Tag:    make(map[string]string),
	}, 60)

	ctx, cancel := context.WithCancel(context.Background())
	err = r.Register(ctx)
	if err != nil {
		panic(err)
	}

	time.Sleep(30 * time.Second)
	r.Quit()
	cancel()
}

discovery

package main

import (
	"context"
	"fmt"
	"time"

	"github.com/coreos/etcd/clientv3"
	edclient "github.com/kiraqjx/ed-client"
)

func main() {
	cli, err := clientv3.New(clientv3.Config{
		Endpoints:   []string{"127.0.0.1:2379"},
		DialTimeout: time.Second * 5,
	})
	if err != nil {
		panic(err)
	}

	watcher := edclient.NewWatcher(cli, "/ed-client", "/b/")

	ctx, cancel := context.WithCancel(context.Background())
	err = watcher.Start(ctx)
	if err != nil {
		panic(err)
	}

	time.Sleep(15 * time.Second)
	fmt.Println("watch node:", watcher.Nodes)
	time.Sleep(15 * time.Second)
	fmt.Println("watch node:", watcher.Nodes)
	cancel()
}

lb

package edclient

import (
	edclient "github.com/kiraqjx/ed-client"
)

func main () {
	nodes := []*edclient.NodeInfo{
		{
			Server: "127.0.0.1:8081",
		},
		{
			Server: "127.0.0.1:8082",
		},
		{
			Server: "127.0.0.1:8083",
		},
	}

	lb := edclient.NewLb(nodes)

	node := lb.Lb()
}