etcdnaming

README

etcdnaming

a tool which using ectd for some clients to find server when its started

etcd & grpc

• ETCD Link | vendor version：v3.3.19
• GRPC Link | vendor version：v1.26.0

installation

• fisrt

github.com/coreos/go-systemd v22.0.0

go get github.com/coreos/go-systemd

• than: added this into go.mod

replace github.com/coreos/go-systemd => $GOPATH/src/github.com/coreos/go-systemd

• last:

go get github.com/go-trellis/etcdnaming

Server

server example

Client

client example

Documentation

Index

• Constants
• func Dial(opts ...grpc.DialOption) (*grpc.ClientConn, error)
• func DialContext(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)
• func NewBuilder(opt BuilderOptions)
• type BuilderOptions
• type ServerRegister
  • func NewDefaultServerRegister(c ServerRegisterConfig) ServerRegister
• type ServerRegisterConfig

Constants

const (

	// DialTarget 访问目标
	DialTarget = schema + ":///"
)

Functions

func Dial

func Dial(opts ...grpc.DialOption) (*grpc.ClientConn, error)

Dial 拨号

func DialContext

func DialContext(ctx context.Context, opts ...grpc.DialOption) (*grpc.ClientConn, error)

DialContext 带上下文的拨号

func NewBuilder

func NewBuilder(opt BuilderOptions)

NewBuilder 获取builder

Types

type BuilderOptions

type BuilderOptions struct {
	Server     string
	Version    string
	Endpoint   string
	LooperTime time.Duration
}

BuilderOptions builder's configure

type ServerRegister

type ServerRegister interface {
	// Regist 注册服务
	Regist() error
	// Revoke 注销服务
	Revoke() error
}

ServerRegister regist or revoke server interface

func NewDefaultServerRegister

func NewDefaultServerRegister(c ServerRegisterConfig) ServerRegister

NewDefaultServerRegister instance of server regitster

type ServerRegisterConfig

type ServerRegisterConfig struct {
	Name             string
	Target           string
	Service          string // host & port
	Version          string // server's version
	TTL              time.Duration
	Interval         time.Duration
	RegistRetryTimes int
	// contains filtered or unexported fields
}

ServerRegisterConfig struct server regiter config name: server name target: etcd' client url, separate by ',' serv: server address host:port interval: Rotation time to registe serv into etcd ttl: expired time, seconds registRetryTimes: allow failed to regist server and retry times; -1 alaways retry