kubernetes

Documentation

Index

• Variables
• func RegisterDaemonSetInformer(informerFactory informers.SharedInformerFactory, exporter Exporter, ...)
• func RegisterDeploymentInformer(informerFactory informers.SharedInformerFactory, exporter Exporter, ...)
• func RegisterJobInformer(informerFactory informers.SharedInformerFactory, exporter Exporter, ...)
• func RegisterPodInformer(informerFactory informers.SharedInformerFactory, exporter Exporter, ...)
• func RegisterStatefulSetInformer(informerFactory informers.SharedInformerFactory, exporter Exporter, ...)
• type Client
  • func NewClient(kubeConfigPath string) (*Client, error)
  • func (c *Client) HasSynced() bool
  • func (c *Client) Start(stopCh chan struct{}) error
• type ContainerLog
• type DaemonSetInformer
• type DeploymentInformer
• type Exporter
• type JobInformer
• type PodInformer
• type ReleaseManagerExporter
  • func (e *ReleaseManagerExporter) SendJobErrorEvent(ctx context.Context, event httpinternal.JobErrorEvent) error
  • func (e *ReleaseManagerExporter) SendPodErrorEvent(ctx context.Context, event httpinternal.PodErrorEvent) error
  • func (e *ReleaseManagerExporter) SendSuccessfulReleaseEvent(ctx context.Context, event httpinternal.ReleaseEvent) error
• type ResourceEventHandlerFactory
• type ResourceEventHandlerFuncs
  • func (r ResourceEventHandlerFuncs) OnAdd(obj interface{})
  • func (r ResourceEventHandlerFuncs) OnDelete(obj interface{})
  • func (r ResourceEventHandlerFuncs) OnUpdate(oldObj, newObj interface{})
• type StatefulSetInformer

Variables

var (
	ErrWatcherClosed = errors.New("channel closed")
)

Functions

func RegisterDaemonSetInformer

func RegisterDaemonSetInformer(informerFactory informers.SharedInformerFactory, exporter Exporter, handlerFactory ResourceEventHandlerFactory, clientset *kubernetes.Clientset)

func RegisterDeploymentInformer

func RegisterDeploymentInformer(informerFactory informers.SharedInformerFactory, exporter Exporter, handlerFactory ResourceEventHandlerFactory, clientset *kubernetes.Clientset)

func RegisterJobInformer

func RegisterJobInformer(informerFactory informers.SharedInformerFactory, exporter Exporter, handlerFactory ResourceEventHandlerFactory, clientset *kubernetes.Clientset)

func RegisterPodInformer

func RegisterPodInformer(informerFactory informers.SharedInformerFactory, exporter Exporter, handlerFactory ResourceEventHandlerFactory, clientset *kubernetes.Clientset, moduloCrashReportNotif float64)

func RegisterStatefulSetInformer

func RegisterStatefulSetInformer(informerFactory informers.SharedInformerFactory, exporter Exporter, handlerFactory ResourceEventHandlerFactory, clientset *kubernetes.Clientset)

Types

type Client

type Client struct {
	Clientset       *kubernetes.Clientset
	InformerFactory informers.SharedInformerFactory
	// contains filtered or unexported fields
}

func NewClient

func NewClient(kubeConfigPath string) (*Client, error)

func (*Client) HasSynced

func (c *Client) HasSynced() bool

func (*Client) Start

func (c *Client) Start(stopCh chan struct{}) error

type ContainerLog

type ContainerLog struct {
	Level   string
	Message string
}

type DaemonSetInformer

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

type DeploymentInformer

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

type Exporter

type Exporter interface {
	// Send a message through the exporter.
	SendSuccessfulReleaseEvent(c context.Context, event httpinternal.ReleaseEvent) error
	SendPodErrorEvent(c context.Context, event httpinternal.PodErrorEvent) error
	SendJobErrorEvent(c context.Context, event httpinternal.JobErrorEvent) error
}

Exporter sends a formatted event to an upstream.

type JobInformer

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

type PodInformer

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

type ReleaseManagerExporter

type ReleaseManagerExporter struct {
	Log         *log.Logger
	Environment string
	Client      httpinternal.Client
}

func (*ReleaseManagerExporter) SendJobErrorEvent

func (e *ReleaseManagerExporter) SendJobErrorEvent(ctx context.Context, event httpinternal.JobErrorEvent) error

func (*ReleaseManagerExporter) SendPodErrorEvent

func (e *ReleaseManagerExporter) SendPodErrorEvent(ctx context.Context, event httpinternal.PodErrorEvent) error

func (*ReleaseManagerExporter) SendSuccessfulReleaseEvent

func (e *ReleaseManagerExporter) SendSuccessfulReleaseEvent(ctx context.Context, event httpinternal.ReleaseEvent) error

type ResourceEventHandlerFactory

type ResourceEventHandlerFactory func(cache.ResourceEventHandlerFuncs) cache.ResourceEventHandler

type ResourceEventHandlerFuncs

type ResourceEventHandlerFuncs struct {
	ShouldProcess func() bool
	cache.ResourceEventHandlerFuncs
}

ResourceEventHandlerFuncs is a cache.ResourceEventHandler that can be configured to skip event handlers based on a ShouldProcess func.

func (ResourceEventHandlerFuncs) OnAdd

func (r ResourceEventHandlerFuncs) OnAdd(obj interface{})

OnAdd calls AddFunc if it's not nil.

func (ResourceEventHandlerFuncs) OnDelete

func (r ResourceEventHandlerFuncs) OnDelete(obj interface{})

OnDelete calls DeleteFunc if it's not nil.

func (ResourceEventHandlerFuncs) OnUpdate

func (r ResourceEventHandlerFuncs) OnUpdate(oldObj, newObj interface{})

OnUpdate calls UpdateFunc if it's not nil.

type StatefulSetInformer

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