consul

Documentation

Index

• type ConsulWatcher
  • func NewConsulWatcher(o Options) *ConsulWatcher
  • func (watcher *ConsulWatcher) LookupRoutes(ctx context.Context, host string) ([]xresolver.Route, error)
  • func (watcher *ConsulWatcher) MonitorEvent(e monitor.Event)
  • func (watcher *ConsulWatcher) WatchService(watchURL string, service string)
• type Options

Types

type ConsulWatcher

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

func NewConsulWatcher

func NewConsulWatcher(o Options) *ConsulWatcher

func (*ConsulWatcher) LookupRoutes

func (watcher *ConsulWatcher) LookupRoutes(ctx context.Context, host string) ([]xresolver.Route, error)

func (*ConsulWatcher) MonitorEvent

func (watcher *ConsulWatcher) MonitorEvent(e monitor.Event)

func (*ConsulWatcher) WatchService

func (watcher *ConsulWatcher) WatchService(watchURL string, service string)

type Options

type Options struct {
	// Watch is what to url to match with the consul service
	// exp. { "http://beta.google.com:8080/notify" : "caduceus" }
	Watch map[string]string `json:"watch"`

	Logger log.Logger `json:"-"`
}