addon

package
v1.0.10 Latest Latest
Warning

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

 Go to latest Published: Aug 6, 2025 License: Apache-2.0 Imports: 38 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.

func PodIdentityRole added in v1.0.10 

func PodIdentityRole(ctx context.Context, client *iam.Client, cluster string) (string, error)

PodIdentityRole returns the pod identity role ARN 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
	PCAIssuer                                           *PCAIssuerTest
	CertName, CertNamespace, CertSecretName, IssuerName string
	// 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 FlexibleStringSlice added in v1.0.10 

type FlexibleStringSlice []string

FlexibleStringSlice handles JSON unmarshaling for fields that can be either a string or []string

func (*FlexibleStringSlice) UnmarshalJSON added in v1.0.10 

func (f *FlexibleStringSlice) UnmarshalJSON(data []byte) error

UnmarshalJSON implements custom unmarshaling to handle both string and []string

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
	Command       string
	CommandRunner commands.RemoteCommandRunner
	NodeFilter    labels.Selector
	// 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           peeredtypes.K8s
	EKSClient     *eks.Client
	K8SConfig     *rest.Config
	Logger        logr.Logger
	Command       string
	CommandRunner commands.RemoteCommandRunner

	NodeName string
}

func (*NvidiaDevicePluginTest) Create added in v1.0.10 

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

func (*NvidiaDevicePluginTest) Delete added in v1.0.10 

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

func (*NvidiaDevicePluginTest) Validate added in v1.0.10 

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

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 PCAIssuerTest added in v1.0.10 

type PCAIssuerTest struct {
	Cluster            string
	Namespace          string
	K8S                clientgo.Interface
	EKSClient          *eks.Client
	CertClient         certmanagerclientset.Interface
	K8sPcaClient       awspcaclientset.Interface
	PCAClient          *acmpca.Client
	Region             string
	PCAArn             *string
	PodIdentityRoleArn string
	Logger             logr.Logger
	// contains filtered or unexported fields
}

PCAIssuerTest tests the AWS PCA Issuer functionality as a plugin for cert-manager

func (*PCAIssuerTest) Cleanup added in v1.0.10 

func (p *PCAIssuerTest) Cleanup(ctx context.Context) error

Cleanup removes all the AWS PCA Issuer resources

func (*PCAIssuerTest) PrintLogs added in v1.0.10 

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

PrintLogs collects and prints logs for debugging

func (*PCAIssuerTest) Setup added in v1.0.10 

func (p *PCAIssuerTest) Setup(ctx context.Context) error

Setup installs the AWS PCA Issuer add-on

func (*PCAIssuerTest) Validate added in v1.0.10 

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

Validate tests the AWS PCA Issuer by creating and validating certificates

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    FlexibleStringSlice          `json:"Action"`
	Resource  *string                      `json:"Resource,omitempty"`
	Principal map[string]string            `json:"Principal,omitempty"`
	Condition map[string]map[string]string `json:"Condition,omitempty"`
}

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.