kubernetes

Documentation

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