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 NewSink(c client.Client) *Sink
  • func (s *Sink) GetEnvironment(ctx context.Context, namespace string) (*manifests.PackageEnvironment, error)
  • func (s *Sink) SetEnvironment(env *manifests.PackageEnvironment)
• type Sinker
  • func ImplementsSinker(i []any) []Sinker

Types

type Manager

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

func NewManager

func NewManager(
	client client.Client,
	discoveryClient serverVersionDiscoverer,
	restMapper restMapper,
) *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 NewSink

func NewSink(c client.Client) *Sink

func (*Sink) GetEnvironment

func (s *Sink) GetEnvironment(ctx context.Context, namespace string) (*manifests.PackageEnvironment, error)

func (*Sink) SetEnvironment

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

type Sinker

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

func ImplementsSinker

func ImplementsSinker(i []any) []Sinker