consul

consul

import "github.com/gojek/courier-go/consul"

Package consul

Index

• type Config
  • func DefaultConfig() *Config
  • func (c *Config) Validate() error
• type Resolver
  • func NewResolver(config *Config) (*Resolver, error)
  • func (r *Resolver) Done() \<-chan struct{}
  • func (r *Resolver) Start()
  • func (r *Resolver) Stop()
  • func (r *Resolver) UpdateChan() \<-chan []courier.TCPAddress

## type [Config](https://github.com/gojek/courier-go/blob/main/consul/config.go#L9-L15)

type Config struct {
    ConsulAddress string
    HealthyOnly   bool
    KVKey         string
    WaitTime      time.Duration
    Logger        *log.Logger
}

### func [DefaultConfig](https://github.com/gojek/courier-go/blob/main/consul/config.go#L17)

func DefaultConfig() *Config

### func \(\*Config\) [Validate](https://github.com/gojek/courier-go/blob/main/consul/config.go#L25)

func (c *Config) Validate() error

## type [Resolver](https://github.com/gojek/courier-go/blob/main/consul/resolver.go#L16-L35)

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

### func [NewResolver](https://github.com/gojek/courier-go/blob/main/consul/resolver.go#L37)

func NewResolver(config *Config) (*Resolver, error)

### func \(\*Resolver\) [Done](https://github.com/gojek/courier-go/blob/main/consul/resolver.go#L73)

func (r *Resolver) Done() <-chan struct{}

### func \(\*Resolver\) [Start](https://github.com/gojek/courier-go/blob/main/consul/resolver.go#L81)

func (r *Resolver) Start()

### func \(\*Resolver\) [Stop](https://github.com/gojek/courier-go/blob/main/consul/resolver.go#L77)

func (r *Resolver) Stop()

### func \(\*Resolver\) [UpdateChan](https://github.com/gojek/courier-go/blob/main/consul/resolver.go#L69)

func (r *Resolver) UpdateChan() <-chan []courier.TCPAddress

Generated by gomarkdoc