consul

Documentation

Overview

Package consul handles the monitor capabilities of harvester using ConsulLogger.

Index

• type Item
  • func NewKeyItem(key string) Item
  • func NewPrefixItem(key string) Item
• type Watcher
  • func New(addr, dc, token string, timeout time.Duration, ii ...Item) (*Watcher, error)
  • func (w *Watcher) Watch(ctx context.Context, ch chan<- []*change.Change) error

Types

type Item

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

Item definition.

func NewKeyItem

func NewKeyItem(key string) Item

NewKeyItem creates a new key watch item for the watcher.

func NewPrefixItem

func NewPrefixItem(key string) Item

NewPrefixItem creates a prefix key watch item for the watcher.

type Watcher

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

Watcher of ConsulLogger changes.

func New

func New(addr, dc, token string, timeout time.Duration, ii ...Item) (*Watcher, error)

New creates a new watcher.

func (*Watcher) Watch

func (w *Watcher) Watch(ctx context.Context, ch chan<- []*change.Change) error

Watch key and prefixes for changes.