addon

package
v1.0.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jun 19, 2025 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	PodIdentityS3BucketPrefix = "podid"
)

Variables

View Source 
var ErrPodIdentityBucketNotFound = errors.New("pod identity bucket not found")

Functions

func PodIdentityBucket added in v1.0.4 

func PodIdentityBucket(ctx context.Context, client *s3.Client, cluster string) (string, error)

PodIdentityBucket returns the pod identity bucket for the given cluster.

Types

type Addon 

type Addon struct {
	Name          string
	Namespace     string
	Cluster       string
	Configuration string
}

func (Addon) Create 

func (a Addon) Create(ctx context.Context, client *eks.Client, logger logr.Logger) error

func (Addon) CreateAndWaitForActive added in v1.0.6 

func (a Addon) CreateAndWaitForActive(ctx context.Context, eksClient *eks.Client, k8s clientgo.Interface, logger logr.Logger) error

func (Addon) Delete added in v1.0.6 

func (a Addon) Delete(ctx context.Context, client *eks.Client, logger logr.Logger) error

func (Addon) WaitUntilActive added in v1.0.6 

func (a Addon) WaitUntilActive(ctx context.Context, client *eks.Client, logger logr.Logger) error

type CertManagerTest added in v1.0.8 

type CertManagerTest struct {
	Cluster string

	K8S        clientgo.Interface
	EKSClient  *eks.Client
	K8SConfig  *rest.Config
	Logger     logr.Logger
	CertClient certmanagerclientset.Interface
	// contains filtered or unexported fields
}

CertManagerTest tests the cert-manager addon

func (*CertManagerTest) Create added in v1.0.8 

func (c *CertManagerTest) Create(ctx context.Context) error

Create installs the cert-manager addon

func (*CertManagerTest) Delete added in v1.0.8 

func (c *CertManagerTest) Delete(ctx context.Context) error

Delete removes the addon and cleans up test resources

func (*CertManagerTest) PrintLogs added in v1.0.8 

func (c *CertManagerTest) PrintLogs(ctx context.Context) error

PrintLogs collects and prints logs for debugging

func (*CertManagerTest) Validate added in v1.0.8 

func (c *CertManagerTest) Validate(ctx context.Context) error

Validate tests cert-manager functionality by creating and validating a self-signed certificate

type KubeStateMetricsTest added in v1.0.7 

type KubeStateMetricsTest struct {
	Cluster string

	K8S       clientgo.Interface
	EKSClient *eks.Client
	K8SConfig *rest.Config
	Logger    logr.Logger
	// contains filtered or unexported fields
}

KubeStateMetricsTest tests the kube-state-metrics addon

func (*KubeStateMetricsTest) Create added in v1.0.7 

func (k *KubeStateMetricsTest) Create(ctx context.Context) error

Create installs the kube-state-metrics addon

func (*KubeStateMetricsTest) Delete added in v1.0.7 

func (k *KubeStateMetricsTest) Delete(ctx context.Context) error

Delete removes the addon

func (*KubeStateMetricsTest) PrintLogs added in v1.0.7 

func (k *KubeStateMetricsTest) PrintLogs(ctx context.Context) error

PrintLogs collects and prints logs for debugging

func (*KubeStateMetricsTest) Validate added in v1.0.7 

func (k *KubeStateMetricsTest) Validate(ctx context.Context) error

Validate checks if kube-state-metrics is providing metrics

type MetricsServerTest added in v1.0.7 

type MetricsServerTest struct {
	Cluster string

	K8S           clientgo.Interface
	EKSClient     *eks.Client
	K8SConfig     *rest.Config
	MetricsClient metricsv1beta1.Interface
	Logger        logr.Logger
	// contains filtered or unexported fields
}

MetricsServerTest tests the metrics-server addon

func (*MetricsServerTest) Create added in v1.0.7 

func (m *MetricsServerTest) Create(ctx context.Context) error

Create installs the metrics-server addon

func (*MetricsServerTest) Delete added in v1.0.7 

func (m *MetricsServerTest) Delete(ctx context.Context) error

Delete removes the addon

func (*MetricsServerTest) PrintLogs added in v1.0.7 

func (m *MetricsServerTest) PrintLogs(ctx context.Context) error

PrintLogs collects and prints logs for debugging

func (*MetricsServerTest) Validate added in v1.0.7 

func (m *MetricsServerTest) Validate(ctx context.Context) error

Validate checks if metrics-server is providing metrics

type NodeMonitoringAgentTest added in v1.0.6 

type NodeMonitoringAgentTest struct {
	Cluster string

	K8S           clientgo.Interface
	EKSClient     *eks.Client
	K8SConfig     *rest.Config
	Logger        logr.Logger
	CommandRunner commands.RemoteCommandRunner
	// contains filtered or unexported fields
}

func (*NodeMonitoringAgentTest) Create added in v1.0.6 

func (n *NodeMonitoringAgentTest) Create(ctx context.Context) error

func (*NodeMonitoringAgentTest) Delete added in v1.0.6 

func (n *NodeMonitoringAgentTest) Delete(ctx context.Context) error

func (*NodeMonitoringAgentTest) PrintLogs added in v1.0.6 

func (n *NodeMonitoringAgentTest) PrintLogs(ctx context.Context) error

func (*NodeMonitoringAgentTest) Validate added in v1.0.6 

func (n *NodeMonitoringAgentTest) Validate(ctx context.Context) error

type NvidiaDevicePluginTest added in v1.0.8 

type NvidiaDevicePluginTest struct {
	Cluster       string
	K8S           clientgo.Interface
	EKSClient     *eks.Client
	K8SConfig     *rest.Config
	Logger        logr.Logger
	CommandRunner commands.RemoteCommandRunner

	NodeName string
}

func (*NvidiaDevicePluginTest) WaitForNvidiaDriverReady added in v1.0.8 

func (n *NvidiaDevicePluginTest) WaitForNvidiaDriverReady(ctx context.Context) error

WaitForNvidiaDrivers checks if nvidia-smi command succeeds on the node

type PodIdentityAddon added in v1.0.3 

type PodIdentityAddon struct {
	Addon
	// contains filtered or unexported fields
}

func NewPodIdentityAddon added in v1.0.3 

func NewPodIdentityAddon(cluster, roleArn string) PodIdentityAddon

func (PodIdentityAddon) Create added in v1.0.3 

func (p PodIdentityAddon) Create(ctx context.Context, logger logr.Logger, eksClient *eks.Client, k8sClient clientgo.Interface) error

func (PodIdentityAddon) UploadFileForVerification added in v1.0.4 

func (p PodIdentityAddon) UploadFileForVerification(ctx context.Context, logger logr.Logger, client *s3.Client, bucket string) error

type PolicyDocument added in v1.0.4 

type PolicyDocument struct {
	Version   string
	Statement []StatementEntry
}

type PrometheusNodeExporterTest added in v1.0.8 

type PrometheusNodeExporterTest struct {
	Cluster string

	K8S       clientgo.Interface
	EKSClient *eks.Client
	K8SConfig *rest.Config
	Logger    logr.Logger
	// contains filtered or unexported fields
}

PrometheusNodeExporterTest tests the Prometheus Node Exporter addon

func (*PrometheusNodeExporterTest) Create added in v1.0.8 

func (p *PrometheusNodeExporterTest) Create(ctx context.Context) error

Create installs the node exporter addon

func (*PrometheusNodeExporterTest) Delete added in v1.0.8 

func (p *PrometheusNodeExporterTest) Delete(ctx context.Context) error

Delete removes the addon

func (*PrometheusNodeExporterTest) PrintLogs added in v1.0.8 

func (p *PrometheusNodeExporterTest) PrintLogs(ctx context.Context) error

PrintLogs collects and prints logs for debugging

func (*PrometheusNodeExporterTest) Validate added in v1.0.8 

func (p *PrometheusNodeExporterTest) Validate(ctx context.Context) error

Validate checks if Prometheus is scraping node exporter metrics

type StatementEntry added in v1.0.4 

type StatementEntry struct {
	Effect   string
	Action   []string
	Resource []string
}

type VerifyPodIdentityAddon 

type VerifyPodIdentityAddon struct {
	Cluster             string
	NodeName            string
	PodIdentityS3Bucket string
	K8S                 clientgo.Interface
	EKSClient           *eks.Client
	IAMClient           *iam.Client
	S3Client            *s3.Client
	Logger              logr.Logger
	K8SConfig           *rest.Config
	Region              string
}

func (VerifyPodIdentityAddon) Run 

func (v VerifyPodIdentityAddon) Run(ctx context.Context) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.