discovery

README

discovery

基于etcd服务发现的封装

Documentation

Index

• Constants
• Variables
• type ClientArgs
  • func (args *ClientArgs) CreateGRpcClient() (*GRpcClient, error)
• type EtcdArgs
  • func (args *EtcdArgs) SplitEndPoints()
• type FPickTTL
• type GRpcClient
  • func NewGRpcClient(etcd []string) (*GRpcClient, error)
  • func (client *GRpcClient) Close() error
  • func (client *GRpcClient) GetService(name string) (*grpc.ClientConn, error)
• type GRpcHost
  • func NewGRpcHost(etcd []string, ip string, port uint16) *GRpcHost
  • func (s *GRpcHost) AddService(desc *grpc.ServiceDesc, impl interface{})
  • func (s *GRpcHost) Serve() error
  • func (s *GRpcHost) SetTimeout(seconds int64)
• type HostArgs
  • func (args *HostArgs) CreateGRpcHost() *GRpcHost
  • func (args *HostArgs) SetupFirstLocalIp()

Constants

const (
	RootPrefix    = "/afpro.micro.root/"
	NodePrefix    = RootPrefix + "node/"
	ServicePrefix = RootPrefix + "service/"
	ConfigPrefix  = RootPrefix + "config/"
)

Variables

var (
	LogRoot      = log.NewRoot(log.NewStdOutput())
	LogTagPrefix = "discovery"

	EtcdOpTimeout = time.Duration(5) * time.Second
	GRpcTimeout   = time.Duration(5) * time.Second
)

var (
	ErrNoServiceFound               = errors.New("no service with specified name found on cluster")
	ErrNoAvailableGrpcHostConnected = errors.New("no available grpc host connected")
	ErrInvalidIP                    = errors.New("invalid ip")
)

Types

type ClientArgs

type ClientArgs struct {
	EtcdArgs
}

func (*ClientArgs) CreateGRpcClient

func (args *ClientArgs) CreateGRpcClient() (*GRpcClient, error)

type EtcdArgs

type EtcdArgs struct {
	Etcd      string `args:"name=etcd;usage=etcd endpoints, separate by ',';"`
	EndPoints []string
}

func (*EtcdArgs) SplitEndPoints

func (args *EtcdArgs) SplitEndPoints()

type FPickTTL

type FPickTTL func(size int, getTTL func(index int) int64) int

var (
	PickTTL FPickTTL = etcdDefaultPick
)

type GRpcClient

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

func NewGRpcClient

func NewGRpcClient(etcd []string) (*GRpcClient, error)

func (*GRpcClient) Close

func (client *GRpcClient) Close() error

func (*GRpcClient) GetService

func (client *GRpcClient) GetService(name string) (*grpc.ClientConn, error)

type GRpcHost

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

func NewGRpcHost

func NewGRpcHost(etcd []string, ip string, port uint16) *GRpcHost

func (*GRpcHost) AddService

func (s *GRpcHost) AddService(desc *grpc.ServiceDesc, impl interface{})

func (*GRpcHost) Serve

func (s *GRpcHost) Serve() error

noinspection GoUnhandledErrorResult

func (*GRpcHost) SetTimeout

func (s *GRpcHost) SetTimeout(seconds int64)

type HostArgs

type HostArgs struct {
	EtcdArgs
	IP   string `args:"name=ip;usage=host ip;"`
	Port uint   `args:"name=port;usage=host port;"`
}

func (*HostArgs) CreateGRpcHost

func (args *HostArgs) CreateGRpcHost() *GRpcHost

func (*HostArgs) SetupFirstLocalIp

func (args *HostArgs) SetupFirstLocalIp()