watcher

package

v0.1.3 Latest Latest Go to latest Published: Oct 30, 2018 License: MIT Imports: 11 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Backend struct {
	Name  string
	Host  string
	Port  string
	Probe *BackendProbe
}

type BackendConfig struct {
	Backends BackendList
	Primary  *Backend
}

func NewBackendConfig() *BackendConfig

type BackendList []Backend

func BackendListFromSubset(ep v1.EndpointSubset, portName string) (BackendList, error)

func (l BackendList) Contains(b *Backend) bool

func (l BackendList) EqualsEndpoints(ep v1.EndpointSubset) bool

type BackendProbe struct {
	URL       string
	Interval  int
	Timeout   int
	Window    int
	Threshold int
}

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

func NewBackendWatcher(client kubernetes.Interface, namespace, serviceName, portName string, retryBackoff time.Duration) *BackendWatcher

func (v *BackendWatcher) Run() (chan *BackendConfig, chan error)

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

func MustNewTemplateWatcher(filename string) *TemplateWatcher

func NewTemplateWatcher(filename string) (*TemplateWatcher, error)

func (t *TemplateWatcher) Run() (chan []byte, chan error)