kubernetes

Nov 27, 2024

Changes in this version

+ const HubbleNamespace

+ const HubbleRelayApp

+ const HubbleUIApp

+ const RequestTimeout

+ const ResourceTypePod

+ const ResourceTypeService

+ type ResourceTypes string

+ type UninstallHelmChart struct

+ KubeConfigFilePath string

+ Namespace string

+ ReleaseName string

+ func (i *UninstallHelmChart) Prevalidate() error

+ func (i *UninstallHelmChart) Run() error

+ func (i *UninstallHelmChart) Stop() error

+ type ValidateHTTPResponse struct

+ ExpectedStatus int

+ URL string

+ func (v *ValidateHTTPResponse) Prevalidate() error

+ func (v *ValidateHTTPResponse) Run() error

+ func (v *ValidateHTTPResponse) Stop() error

+ type ValidateHubbleStep struct

+ ChartPath string

+ KubeConfigFilePath string

+ Namespace string

+ ReleaseName string

+ TagEnv string

+ func (v *ValidateHubbleStep) Prevalidate() error

+ func (v *ValidateHubbleStep) Run() error

+ func (v *ValidateHubbleStep) Stop() error

+ type ValidateResource struct

+ KubeConfigFilePath string

+ Labels string

+ ResourceName string

+ ResourceNamespace string

+ ResourceType string

+ func (v *ValidateResource) Prevalidate() error

+ func (v *ValidateResource) Run() error

+ func (v *ValidateResource) Stop() error

Nov 13, 2024

Changes in this version

+ func CreateNamespaceFn(kubeconfigpath, namespace string) error

type CreateNamespace

+ KubeConfigFilePath string

+ Namespace string

+ func (c *CreateNamespace) Prevalidate() error

+ func (c *CreateNamespace) Run() error

+ func (c *CreateNamespace) Stop() error

+ type DeleteNamespace struct

+ KubeConfigFilePath string

+ Namespace string

+ func (d *DeleteNamespace) Prevalidate() error

+ func (d *DeleteNamespace) Run() error

+ func (d *DeleteNamespace) Stop() error

+ type WaitPodsReady struct

+ KubeConfigFilePath string

+ LabelSelector string

+ Namespace string

+ func (w *WaitPodsReady) Prevalidate() error

+ func (w *WaitPodsReady) Run() error

+ func (w *WaitPodsReady) Stop() error

Nov 12, 2024

Changes in this version

+ var ErrPodCrashed = fmt.Errorf("pod has crashes")

+ func CheckContainerRestart(ctx context.Context, clientset *kubernetes.Clientset, ...) error

+ func CreateNamespace(kubeconfigpath, namespace string) error

type CreateAgnhostStatefulSet

+ ScheduleOnSameNode bool

+ type EnsureStableComponent struct

+ IgnoreContainerRestart bool

+ KubeConfigFilePath string

+ LabelSelector string

+ PodNamespace string

+ func (n *EnsureStableComponent) Prevalidate() error

+ func (n *EnsureStableComponent) Run() error

+ func (n *EnsureStableComponent) Stop() error

+ type GetPodLogs struct

+ KubeConfigFilePath string

+ LabelSelector string

+ Namespace string

+ func (p *GetPodLogs) Run() error

Jun 5, 2024

Changes in this version

+ func GetPodIP(kubeConfigFilePath, namespace, podName string) (string, error)

type PortForward

+ Endpoint string

+ type UpgradeRetinaHelmChart struct

+ ChartPath string

+ KubeConfigFilePath string

+ Namespace string

+ ReleaseName string

+ TagEnv string

+ ValuesFile string

+ func (u *UpgradeRetinaHelmChart) Prevalidate() error

+ func (u *UpgradeRetinaHelmChart) Run() error

+ func (u *UpgradeRetinaHelmChart) Stop() error

Mar 25, 2024

Changes in this version

+ const AgnhostHTTPPort

+ const AgnhostReplicas

+ const Egress

+ const ExecSubResources

+ const Ingress

+ const KapingerHTTPPort

+ const KapingerTCPPort

+ const KapingerUDPPort

+ const MaxAffinityWeight

+ const RetryIntervalPodsReady

+ const RetryTimeoutPodsReady

+ var ErrCreateNilResource = fmt.Errorf("cannot create nil resource")

+ var ErrDeleteNilResource = fmt.Errorf("cannot create nil resource")

+ var ErrLabelMissingFromPod = fmt.Errorf("label missing from pod")

+ var ErrNoPodWithLabelFound = fmt.Errorf("no pod with label found with matching pod affinity")

+ var ErrUnknownResourceType = fmt.Errorf("unknown resource type")

+ func CreateResource(ctx context.Context, obj runtime.Object, clientset *kubernetes.Clientset) error

+ func DeleteResource(ctx context.Context, obj runtime.Object, clientset *kubernetes.Clientset) error

+ func ExecPod(ctx context.Context, kubeConfigFilePath, namespace, podName, command string) error

+ func PrintPodLogs(kubeconfigpath, namespace, labelSelector string)

+ func TypeString(resourceType ResourceType) string

+ func WaitForPodReady(ctx context.Context, clientset *kubernetes.Clientset, ...) error

+ type CreateAgnhostStatefulSet struct

+ AgnhostName string

+ AgnhostNamespace string

+ KubeConfigFilePath string

+ func (c *CreateAgnhostStatefulSet) Prevalidate() error

+ func (c *CreateAgnhostStatefulSet) Run() error

+ func (c *CreateAgnhostStatefulSet) Stop() error

+ type CreateDenyAllNetworkPolicy struct

+ DenyAllLabelSelector string

+ KubeConfigFilePath string

+ NetworkPolicyNamespace string

+ func (c *CreateDenyAllNetworkPolicy) Prevalidate() error

+ func (c *CreateDenyAllNetworkPolicy) Run() error

+ func (c *CreateDenyAllNetworkPolicy) Stop() error

+ type CreateKapingerDeployment struct

+ KapingerNamespace string

+ KapingerReplicas string

+ KubeConfigFilePath string

+ func (c *CreateKapingerDeployment) GetKapingerClusterRole() *rbacv1.ClusterRole

+ func (c *CreateKapingerDeployment) GetKapingerClusterRoleBinding() *rbacv1.ClusterRoleBinding

+ func (c *CreateKapingerDeployment) GetKapingerDeployment() *appsv1.Deployment

+ func (c *CreateKapingerDeployment) GetKapingerService() *v1.Service

+ func (c *CreateKapingerDeployment) GetKapingerServiceAccount() *v1.ServiceAccount

+ func (c *CreateKapingerDeployment) Prevalidate() error

+ func (c *CreateKapingerDeployment) Run() error

+ func (c *CreateKapingerDeployment) Stop() error

+ type DeleteDenyAllNetworkPolicy struct

+ DenyAllLabelSelector string

+ KubeConfigFilePath string

+ NetworkPolicyNamespace string

+ func (d *DeleteDenyAllNetworkPolicy) Prevalidate() error

+ func (d *DeleteDenyAllNetworkPolicy) Run() error

+ type DeleteKubernetesResource struct

+ KubeConfigFilePath string

+ ResourceName string

+ ResourceNamespace string

+ ResourceType string

+ func (d *DeleteKubernetesResource) Prevalidate() error

+ func (d *DeleteKubernetesResource) Run() error

+ func (d *DeleteKubernetesResource) Stop() error

+ type ExecInPod struct

+ Command string

+ KubeConfigFilePath string

+ PodName string

+ PodNamespace string

+ func (e *ExecInPod) Prevalidate() error

+ func (e *ExecInPod) Run() error

+ func (e *ExecInPod) Stop() error

+ type InstallHelmChart struct

+ ChartPath string

+ KubeConfigFilePath string

+ Namespace string

+ ReleaseName string

+ TagEnv string

+ func (i *InstallHelmChart) Prevalidate() error

+ func (i *InstallHelmChart) Run() error

+ func (i *InstallHelmChart) Stop() error

+ type PortForward struct

+ KubeConfigFilePath string

+ LabelSelector string

+ LocalPort string

+ Namespace string

+ OptionalLabelAffinity string

+ RemotePort string

+ func (p *PortForward) Prevalidate() error

+ func (p *PortForward) Run() error

+ func (p *PortForward) Stop() error

+ type PortForwarder struct

+ func NewPortForwarder(restConfig *rest.Config, logger logger, opts PortForwardingOpts) (*PortForwarder, error)

+ func (p *PortForwarder) Address() string

+ func (p *PortForwarder) Forward(ctx context.Context) error

+ func (p *PortForwarder) KeepAlive(ctx context.Context)

+ func (p *PortForwarder) Stop()

+ type PortForwardingOpts struct

+ DestPort int

+ LabelSelector string

+ LocalPort int

+ Namespace string

+ PodName string

+ type ResourceType string

+ const ClusterRole

+ const ClusterRoleBinding

+ const ConfigMap

+ const DaemonSet

+ const Deployment

+ const NetworkPolicy

+ const Role

+ const RoleBinding

+ const Secret

+ const Service

+ const ServiceAccount

+ const StatefulSet

+ const Unknown