package kubernetes

import "k8s.io/heapster/events/sources/kubernetes"

Index ¶

• Constants
• type KubernetesEventSource
• func NewKubernetesSource(uri *url.URL) (*KubernetesEventSource, error)
• func (this *KubernetesEventSource) GetNewEvents() *core.EventBatch

Constants ¶

const (
	// Number of object pointers. Big enough so it won't be hit anytime soon with resonable GetNewEvents frequency.
	LocalEventsBufferSize = 100000
)

Types ¶

type KubernetesEventSource ¶

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

Implements core.EventSource interface.

func NewKubernetesSource ¶

func NewKubernetesSource(uri *url.URL) (*KubernetesEventSource, error)

func (*KubernetesEventSource) GetNewEvents ¶

func (this *KubernetesEventSource) GetNewEvents() *core.EventBatch

Source Files ¶

kubernetes_source.go