consul

Documentation

Index

• Constants
• func RegisterDefault(watchInterval time.Duration, addr string)
• type Resolver
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(resolver.ResolveNowOption)
• type ResolverBuilder
  • func (b *ResolverBuilder) Build(target resolver.Target, cc resolver.ClientConn, opts resolver.BuildOption) (resolver.Resolver, error)
  • func (b *ResolverBuilder) Scheme() string

Constants

const (
	Scheme = "srv"
)

Scheme to prefix for lookups (srv://consul/<service>)

Functions

func RegisterDefault

func RegisterDefault(watchInterval time.Duration, addr string)

RegisterDefault resolver how often to watch for updates Address comes from CONSUL_HTTP_ADDR env var

Types

type Resolver

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

func (*Resolver) Close

func (r *Resolver) Close()

func (*Resolver) ResolveNow

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

type ResolverBuilder

type ResolverBuilder struct {
	WatchInterval      time.Duration
	ConsulClientConfig *api.Config
}

ResolverBuilder builds our name resolver for Consul

func (*ResolverBuilder) Build

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

Build the consul resolver by calling the consul api and starting watchers/updaters for resolving server addresses

func (*ResolverBuilder) Scheme

func (b *ResolverBuilder) Scheme() string

Scheme returns the scheme of this builder