ambassador

README

Ambassador

Consul gRPC resolver for load balancing

Links

• Load Balancing in gRPC
• gRPC Name Resolution

Documentation

Index

• func NewBuilder(addr, tag, datacenter string) resolver.Builder
• type Address
• type Builder
  • func (b *Builder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOption) (resolver.Resolver, error)
  • func (b *Builder) Scheme() string
• type Resolver
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(option resolver.ResolveNowOption)
• type Service
  • func NewService(name string, host string, port int, target string, ttl int) (*Service, error)
  • func (s *Service) Deregister() error
  • func (s *Service) Register() error
• type Watcher
  • func NewWatcher(consul, service, dc, tag string) (*Watcher, error)
  • func (w *Watcher) Run(ctx context.Context) error
  • func (w *Watcher) Stop()
  • func (w *Watcher) Watch() chan []Address

Functions

func NewBuilder

func NewBuilder(addr, tag, datacenter string) resolver.Builder

NewBuilder return Builder with service name

Types

type Address

type Address = string

type Builder

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

Builder is the implementaion of grpc.naming.Resolver

func (*Builder) Build

func (b *Builder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOption) (resolver.Resolver, error)

func (*Builder) Scheme

func (b *Builder) Scheme() string

type Resolver

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

func (*Resolver) Close

func (r *Resolver) Close()

func (*Resolver) ResolveNow

func (r *Resolver) ResolveNow(option resolver.ResolveNowOption)

It's just a hint, resolver can ignore this if it's not necessary.

type Service

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

func NewService

func NewService(name string, host string, port int, target string, ttl int) (*Service, error)

func (*Service) Deregister

func (s *Service) Deregister() error

func (*Service) Register

func (s *Service) Register() error

type Watcher

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

func NewWatcher

func NewWatcher(consul, service, dc, tag string) (*Watcher, error)

func (*Watcher) Run

func (w *Watcher) Run(ctx context.Context) error

func (*Watcher) Stop

func (w *Watcher) Stop()

func (*Watcher) Watch

func (w *Watcher) Watch() chan []Address