registry

README

gRPC服务发现

使用google.golang.org/grpc/resolver实现服务发现

• Feature
  • go-micro/registry
    • 服务发现
    • 版本选择
  • istio

使用

默认mock未实现，需要import _ github.com/hb-go/grpc-contrib/registry/micro或_ github.com/hb-go/grpc-contrib/registry/istio

go-micro默认使用mdns

// 服务注册与注销
registry.Register(&_ExampleService_serviceDesc, opts...)
registry.Deregister(&_ExampleService_serviceDesc, opts...)
registry.Deregister(nil)

// 服务发现
target := registry.NewTarget(&_ExampleService_serviceDesc, opts...)
conn, err := grpc.Dial(target, grpc.WithInsecure(), grpc.WithBalancerName(roundrobin.Name), grpc.WithBlock())

Documentation

Index

• Variables
• func Deregister(sd *grpc.ServiceDesc, opts ...Option)
• func NewTarget(sd *grpc.ServiceDesc, opts ...Option) string
• func Register(sd *grpc.ServiceDesc, opts ...Option) error
• type Option
  • func WithAddr(addr string) Option
  • func WithVersion(version string) Option
• type Options
• type Registry
  • func NewRegistry() Registry

Variables

var (
	DefaultRegistry = NewRegistry()
)

Functions

func Deregister

func Deregister(sd *grpc.ServiceDesc, opts ...Option)

func NewTarget

func NewTarget(sd *grpc.ServiceDesc, opts ...Option) string

func Register

func Register(sd *grpc.ServiceDesc, opts ...Option) error

Types

type Option

type Option func(options *Options)

func WithAddr

func WithAddr(addr string) Option

func WithVersion

func WithVersion(version string) Option

type Options

type Options struct {
	Version string
	Addr    string
}

type Registry

type Registry interface {
	// 生成grpc.Dial target
	NewTarget(sd *grpc.ServiceDesc, opts ...Option) string

	// 注册服务
	Register(sd *grpc.ServiceDesc, opts ...Option) error
	// 注销服务
	// sd=nil，注销全部服务
	Deregister(sd *grpc.ServiceDesc, opts ...Option)
}

func NewRegistry

func NewRegistry() Registry