k8s

Documentation

Index

• Variables
• func GetClient() (*kubernetes.Clientset, error)
• func GetConfig() (*rest.Config, error)
• type EventWatcher
  • func WatchEvents(_ context.Context, ns string) (*EventWatcher, error)
  • func (w EventWatcher) OnAdd(obj interface{})
  • func (w EventWatcher) OnDelete(_ interface{})
  • func (w EventWatcher) OnUpdate(_, newObj interface{})
  • func (w EventWatcher) Start(ctx context.Context)
• type TemplateContext

Variables

var Registry = &registry{}

Functions

func GetClient

func GetClient() (*kubernetes.Clientset, error)

func GetConfig

func GetConfig() (*rest.Config, error)

GetConfig returns the configuration to connect to the Kubernetes API server.

Types

type EventWatcher

type EventWatcher struct {
	Events chan *v1.Event
	// contains filtered or unexported fields
}

func WatchEvents

func WatchEvents(_ context.Context, ns string) (*EventWatcher, error)

func (EventWatcher) OnAdd

func (w EventWatcher) OnAdd(obj interface{})

func (EventWatcher) OnDelete

func (w EventWatcher) OnDelete(_ interface{})

func (EventWatcher) OnUpdate

func (w EventWatcher) OnUpdate(_, newObj interface{})

func (EventWatcher) Start

func (w EventWatcher) Start(ctx context.Context)

type TemplateContext

type TemplateContext struct {
	Service *corev1.Service
	Pod     *corev1.Pod
	Event   *corev1.Event
}