grpcetcd

Documentation

Index

• func NewBuilder(client *clientv3.Client, le logger.Entry) (gresolver.Builder, error)
• type Discovery
  • func NewDiscovery(cli *clientv3.Client, path string, le logger.Entry, ...) *Discovery
  • func (d *Discovery) Dial(ctx context.Context) (cc *grpc.ClientConn, err error)
• type Registry
  • func NewRegistry(cli *clientv3.Client, path string, ttl int64, le logger.Entry) *Registry
  • func (r *Registry) Register(ctx context.Context, addr string) (revoke func(context.Context), err error)

Functions

func NewBuilder

func NewBuilder(client *clientv3.Client, le logger.Entry) (gresolver.Builder, error)

NewBuilder creates a resolver builder.

Types

type Discovery

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

func NewDiscovery

func NewDiscovery(
	cli *clientv3.Client,
	path string,
	le logger.Entry,
	dialOpts ...grpc.DialOption,
) *Discovery

func (*Discovery) Dial

func (d *Discovery) Dial(ctx context.Context) (cc *grpc.ClientConn, err error)

Dial connects to the target service

type Registry

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

func NewRegistry

func NewRegistry(
	cli *clientv3.Client,
	path string,
	ttl int64,
	le logger.Entry,
) *Registry

func (*Registry) Register

func (r *Registry) Register(ctx context.Context, addr string) (revoke func(context.Context), err error)

Register registers the service with etcd addr: the address of the service, eg: 10.10.10.10:50051 returns a revoke function to deregister the service