k8s

Documentation

Index

• type Client
  • func NewClient() (*Client, error)
  • func (c *Client) ListPods(ctx context.Context, namespace string, labels map[string]string) ([]*apiv1.Pod, error)
• type EventHandlerWithContext
• type Informers
  • func NewInformers(k8sclient *Client, stopCh chan struct{}, namespace string, ...) (*Informers, error)
  • func (is *Informers) Run()
  • func (is *Informers) SetPodEventHandlers(ctx context.Context, handlers []EventHandlerWithContext) error

Types

type Client

type Client struct {
	CoreClientset kubernetes.Interface
}

Client is a wrapper for Kubernetes clientset.

func NewClient

func NewClient() (*Client, error)

NewClient creates a Client instance.

func (*Client) ListPods

func (c *Client) ListPods(ctx context.Context, namespace string, labels map[string]string) ([]*apiv1.Pod, error)

ListPods lists pods.

type EventHandlerWithContext

type EventHandlerWithContext interface {
	ProcessAdd(ctx context.Context, obj interface{})
	ProcessUpdate(ctx context.Context, oldObj, newObj interface{})
	ProcessDelete(ctx context.Context, obj interface{})
}

EventHandlerWithContext is an interface similar to cache.EventHandler but with a context object.

type Informers

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

Informers keeps multiple informers.

func NewInformers

func NewInformers(
	k8sclient *Client,
	stopCh chan struct{},
	namespace string,
	labels map[string]string,
) (*Informers, error)

NewInformers creates a new Informer for Pod.

func (*Informers) Run

func (is *Informers) Run()

Run runs the informer.

func (*Informers) SetPodEventHandlers

func (is *Informers) SetPodEventHandlers(
	ctx context.Context,
	handlers []EventHandlerWithContext,
) error

SetPodEventHandlers sets the specified handlers to the Pod informer.