Skip to main content

consul

consul

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

Package consul

Index

## 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-L34)
type Resolver struct {
// contains filtered or unexported fields
}
### func [NewResolver](https://github.com/gojek/courier-go/blob/main/consul/resolver.go#L36)
func NewResolver(config *Config) (*Resolver, error)
### func \(\*Resolver\) [Done](https://github.com/gojek/courier-go/blob/main/consul/resolver.go#L72)
func (r *Resolver) Done() <-chan struct{}
### func \(\*Resolver\) [Start](https://github.com/gojek/courier-go/blob/main/consul/resolver.go#L80)
func (r *Resolver) Start()
### func \(\*Resolver\) [Stop](https://github.com/gojek/courier-go/blob/main/consul/resolver.go#L76)
func (r *Resolver) Stop()
### func \(\*Resolver\) [UpdateChan](https://github.com/gojek/courier-go/blob/main/consul/resolver.go#L68)
func (r *Resolver) UpdateChan() <-chan []courier.TCPAddress

Generated by gomarkdoc