k8s

Documentation

Index

• type Metadata
  • func LoadIdentity(path string) (Metadata, error)
• type PodInformer
  • func NewPodInformer(k8sClient kubernetes.Interface, nodeName string) *PodInformer
  • func (p *PodInformer) Add(ctx context.Context, handler cache.ResourceEventHandler) (cache.ResourceEventHandlerRegistration, error)
  • func (p *PodInformer) Remove(reg cache.ResourceEventHandlerRegistration) error

Types

type Metadata

type Metadata struct {
	Namespace, Pod, Container string
}

var (
	// Instance is the singleton instance of the identity.  This is goroutine safe.
	Instance Metadata
)

func LoadIdentity

func LoadIdentity(path string) (Metadata, error)

LoadIdentity loads the identity from the specified path.

type PodInformer

type PodInformer struct {
	K8sClient kubernetes.Interface
	NodeName  string
	// contains filtered or unexported fields
}

func NewPodInformer

func NewPodInformer(k8sClient kubernetes.Interface, nodeName string) *PodInformer

func (*PodInformer) Add

func (p *PodInformer) Add(ctx context.Context, handler cache.ResourceEventHandler) (cache.ResourceEventHandlerRegistration, error)

Add adds a handler to the informer. The handler will be called when a pod is added, updated, or deleted. Lazily creates and starts the informer if it does not already exist.

func (*PodInformer) Remove

func (p *PodInformer) Remove(reg cache.ResourceEventHandlerRegistration) error

Remove removes a handler from the informer. Lazily shuts down the informer if there are no more handlers.