k8s

Documentation

Index

• Constants
• Variables
• func Loader(ctx context.Context, config engines.Config) (engines.Engine, error)
• func NamedLoader() (string, engines.Loader)
• func NewTopologyLabeler() *topologyLabeler
• type K8sEngine
  • func New() (*K8sEngine, error)
  • func (eng *K8sEngine) AddNodeLabels(ctx context.Context, nodeName string, labels map[string]string) error
  • func (eng *K8sEngine) GenerateOutput(ctx context.Context, tree *topology.Vertex, params map[string]any) ([]byte, error)
  • func (eng *K8sEngine) GetComputeInstances(ctx context.Context, environment engines.Environment) ([]topology.ComputeInstances, error)
  • func (eng *K8sEngine) UpdateTopologyConfigmap(ctx context.Context, name, namespace string, data map[string]string) error
• type Labeler
• type Params

Constants

const NAME = "k8s"

Variables

var ErrEnvironmentUnsupported = std_errors.New("environment must implement k8sNodeInfo")

Functions

func Loader

func Loader(ctx context.Context, config engines.Config) (engines.Engine, error)

func NamedLoader

func NamedLoader() (string, engines.Loader)

func NewTopologyLabeler

func NewTopologyLabeler() *topologyLabeler

Types

type K8sEngine

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

func New

func New() (*K8sEngine, error)

func (*K8sEngine) AddNodeLabels

func (eng *K8sEngine) AddNodeLabels(ctx context.Context, nodeName string, labels map[string]string) error

func (*K8sEngine) GenerateOutput

func (eng *K8sEngine) GenerateOutput(ctx context.Context, tree *topology.Vertex, params map[string]any) ([]byte, error)

func (*K8sEngine) GetComputeInstances

func (eng *K8sEngine) GetComputeInstances(ctx context.Context, environment engines.Environment) ([]topology.ComputeInstances, error)

func (*K8sEngine) UpdateTopologyConfigmap

func (eng *K8sEngine) UpdateTopologyConfigmap(ctx context.Context, name, namespace string, data map[string]string) error

type Labeler

type Labeler interface {
	AddNodeLabels(context.Context, string, map[string]string) error
}

type Params

type Params struct {
	TopoConfigPath         string `mapstructure:"topology_config_path"`
	TopoConfigmapName      string `mapstructure:"topology_configmap_name"`
	TopoConfigmapNamespace string `mapstructure:"topology_configmap_namespace"`
}