consul

Documentation

Index

• func NewBuilder(scheme string) *builder
• type ConsulConf
  • func (c ConsulConf) Validate() error
• type Publisher
  • func NewPublisher(config ConsulConf, listenOn string, opts ...PublisherOption) (*Publisher, error)
  • func (p *Publisher) Deregister() error
  • func (p *Publisher) Register() error
• type PublisherOption
• type Resolver
  • func (r *Resolver) Close()
  • func (r *Resolver) ResolveNow(opts resolver.ResolveNowOptions)
  • func (r *Resolver) Watcher()

Functions

func NewBuilder

func NewBuilder(scheme string) *builder

Types

type ConsulConf

type ConsulConf struct {
	Host        string
	Key         string
	Token       string `json:",optional"`
	HealthCheck bool   `json:",default=true,optional"`
}

func (ConsulConf) Validate

func (c ConsulConf) Validate() error

type Publisher

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

func NewPublisher

func NewPublisher(config ConsulConf, listenOn string, opts ...PublisherOption) (*Publisher, error)

func (*Publisher) Deregister

func (p *Publisher) Deregister() error

func (*Publisher) Register

func (p *Publisher) Register() error

type PublisherOption

type PublisherOption func(client *Publisher)

type Resolver

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

implements grpc.naming.Resolver

func (*Resolver) Close

func (r *Resolver) Close()

func (*Resolver) ResolveNow

func (r *Resolver) ResolveNow(opts resolver.ResolveNowOptions)

func (*Resolver) Watcher

func (r *Resolver) Watcher()