kubernetes

Documentation

Index

• func NewKubernetesClientSet(ctx context.Context, interval, pollingTimeout, timeout time.Duration) (*kubernetes.Clientset, error)
• type Config
• type K8SWatcher
  • func NewWatcher(ctx context.Context, k8sWatcher Watcher, ...) *K8SWatcher
  • func (w *K8SWatcher) Run(ctx context.Context)
• type Watcher

Functions

func NewKubernetesClientSet

func NewKubernetesClientSet(ctx context.Context, interval, pollingTimeout, timeout time.Duration) (*kubernetes.Clientset, error)

NewKubernetesClientSet missing godoc

Types

type Config

type Config struct {
	PollInterval time.Duration `envconfig:"optional,default=2s,APP_KUBERNETES_POLL_INTERVAL"`
	PollTimeout  time.Duration `envconfig:"optional,default=1m,APP_KUBERNETES_POLL_TIMEOUT"`
	Timeout      time.Duration `envconfig:"optional,default=2m,APP_KUBERNETES_TIMEOUT"`
}

Config missing godoc

type K8SWatcher

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

K8SWatcher is a structure containing dependencies for the watch mechanism

func NewWatcher

func NewWatcher(ctx context.Context, k8sWatcher Watcher, processWatchEventsFunc processWatchEventsFunc, reconnectInterval time.Duration, resourceName, correlationID string) *K8SWatcher

NewWatcher return initialized K8SWatcher structure

func (*K8SWatcher) Run

func (w *K8SWatcher) Run(ctx context.Context)

Run starts goroutine that uses kubernetes watch mechanism to listen for resource changes

type Watcher

type Watcher interface {
	Watch(ctx context.Context, opts metav1.ListOptions) (watch.Interface, error)
}

Watcher is a K8S watcher that listen for resources changes and receive events based on that