watcher

Documentation

Index

• Constants
• func EndpointSubsetIndex(es []v1.EndpointSubset, portName string) (int, error)
• type Endpoint
• type EndpointConfig
  • func NewEndpointConfig() *EndpointConfig
• type EndpointList
  • func EndpointListFromSubset(ep v1.EndpointSubset, portName string) (EndpointList, error)
  • func (l EndpointList) Contains(b *Endpoint) bool
  • func (l EndpointList) EqualsEndpoints(ep v1.EndpointSubset) bool
• type EndpointProbe
• type EndpointWatcher
  • func NewEndpointWatcher(client kubernetes.Interface, namespace, serviceName, portName string, ...) *EndpointWatcher
  • func (v *EndpointWatcher) Run(ctx context.Context) (chan *EndpointConfig, chan error)
• type TemplateWatcher
  • func MustNewTemplateWatcher(filename string, polling bool) TemplateWatcher
  • func NewTemplateWatcher(filename string, polling bool) (TemplateWatcher, error)

Constants

const (
	// how often to check for template file changes
	POLL_INTERVAL = 15 * time.Second
	// how often print template info for troubleshooting
	TIMESTAMP_DISPLAY_INTERVAL = 1 * time.Hour
)

Functions

func EndpointSubsetIndex

func EndpointSubsetIndex(es []v1.EndpointSubset, portName string) (int, error)

EndpointSubsetIndex returns the index of EndpointSubset for which port.Name matches provided portName

Types

type Endpoint

type Endpoint struct {
	Name  string
	Host  string
	Port  string
	Probe *EndpointProbe
}

type EndpointConfig

type EndpointConfig struct {
	Endpoints EndpointList
	Primary   *Endpoint
}

func NewEndpointConfig

func NewEndpointConfig() *EndpointConfig

type EndpointList

type EndpointList []Endpoint

func EndpointListFromSubset

func EndpointListFromSubset(ep v1.EndpointSubset, portName string) (EndpointList, error)

func (EndpointList) Contains

func (l EndpointList) Contains(b *Endpoint) bool

func (EndpointList) EqualsEndpoints

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

type EndpointProbe

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

type EndpointWatcher

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

func NewEndpointWatcher

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

func (*EndpointWatcher) Run

func (v *EndpointWatcher) Run(ctx context.Context) (chan *EndpointConfig, chan error)

type TemplateWatcher

type TemplateWatcher interface {
	Run() (chan []byte, chan error)
}

func MustNewTemplateWatcher

func MustNewTemplateWatcher(filename string, polling bool) TemplateWatcher

func NewTemplateWatcher

func NewTemplateWatcher(filename string, polling bool) (TemplateWatcher, error)