k8s

package

v1.51.2 Latest Latest Go to latest Published: Aug 11, 2025 License: MIT Imports: 21 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func NewDeploymentHelper(client *kubernetes.Clientset, cfg *rest.Config, svc *appsv1.Deployment) *DeploymentHelper

func (s *DeploymentHelper) WaitForCondition(ctx context.Context, fn func(*appsv1.Deployment) (bool, error), timeout time.Duration) error

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

func NewPodHelper(client *kubernetes.Clientset, cfg *rest.Config, pod *corev1.Pod) *PodHelper

func (p *PodHelper) Attach(ctx context.Context, container string, stdin io.Reader) (string, string, error)

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

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

func (p *PodHelper) Exec(ctx context.Context, container string, cmd []string) (string, string, error)

func (p *PodHelper) GetLogs(ctx context.Context, container string) (string, error)

func (p *PodHelper) WaitForContainerReady(ctx context.Context, timeout time.Duration, container string) error

func (p *PodHelper) WaitForContainerStarted(ctx context.Context, timeout time.Duration, container string) error

func (p *PodHelper) WaitForInitContainerRunning(ctx context.Context, container string, timeout time.Duration) error

func (p *PodHelper) WaitForPodDeleted(ctx context.Context, timeout time.Duration) error

func (p *PodHelper) WaitForPodPhase(ctx context.Context, timeout time.Duration, phase corev1.PodPhase) error

func (p *PodHelper) WaitForPodRunning(ctx context.Context, timeout time.Duration) error

func (p *PodHelper) WaitForPodSucceeded(ctx context.Context, timeout time.Duration) error

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

func NewPvcHelper(client *kubernetes.Clientset, cfg *rest.Config, pvc *corev1.PersistentVolumeClaim) *PvcHelper

func (h *PvcHelper) DownloadGenesis(ctx context.Context, url, path, pc string, af *corev1.Affinity, ns map[string]string) error

func (h *PvcHelper) WriteToFile(ctx context.Context, content, path, pc string, af *corev1.Affinity, ns map[string]string) error

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

func NewServiceHelper(client *kubernetes.Clientset, cfg *rest.Config, svc *corev1.Service) *ServiceHelper

func (s *ServiceHelper) WaitForCondition(ctx context.Context, fn func(service *corev1.Service) (bool, error), timeout time.Duration) error