source

Documentation

Index

• Variables
• type Source
  • func New(url, appName, clusterName, namespaceName string) Source
• type Watcher

Variables

var ErrWatcherStopped = errors.New("watcher stopped")

Types

type Source

type Source interface {
	Read() ([]byte, error)
	Watch() (Watcher, error)
	Name() string
}

func New

func New(url, appName, clusterName, namespaceName string) Source

type Watcher

type Watcher interface {
	Next() ([]byte, error)
	Stop() error
}