environment

Documentation

Overview

The environment package contains probing functionality to detect information on the Kubernetes cluster environment.

Index

• type Manager
  • func NewManager(client client.Client, discoveryClient serverVersionDiscoverer) *Manager
  • func (m *Manager) Init(ctx context.Context, sinks []Sinker) error
  • func (m *Manager) Start(ctx context.Context) error
• type Sink
  • func (s *Sink) GetEnvironment() *manifestsv1alpha1.PackageEnvironment
  • func (s *Sink) SetEnvironment(env *manifestsv1alpha1.PackageEnvironment)
• type Sinker
  • func ImplementsSinker(i []interface{}) []Sinker

Types

type Manager

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

func NewManager

func NewManager(
	client client.Client,
	discoveryClient serverVersionDiscoverer,
) *Manager

func (*Manager) Init

func (m *Manager) Init(ctx context.Context, sinks []Sinker) error

func (*Manager) Start

func (m *Manager) Start(ctx context.Context) error

Continuously updates the environment information.

type Sink

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

func (*Sink) GetEnvironment

func (s *Sink) GetEnvironment() *manifestsv1alpha1.PackageEnvironment

func (*Sink) SetEnvironment

func (s *Sink) SetEnvironment(env *manifestsv1alpha1.PackageEnvironment)

type Sinker

type Sinker interface {
	SetEnvironment(env *manifestsv1alpha1.PackageEnvironment)
}

func ImplementsSinker

func ImplementsSinker(i []interface{}) []Sinker