workload

package

Go to main page

Versions in this module

v0

v0.0.8

Sep 14, 2025

v0.0.7

Sep 4, 2025

Changes in this version

type WorkLoad

+ func (w *WorkLoad) GetContaineByName(containerName string) *v1.Container

+ func (w *WorkLoad) GetContainerImageVersion(containerName string) string

v0.0.6

May 9, 2025

Changes in this version

type WORKLOAD_KIND

+ const WORKLOAD_KIND_REPLICASET

v0.0.5

May 7, 2025

v0.0.4

May 6, 2025

v0.0.3

May 6, 2025

Changes in this version

type Client

+ func (c *Client) SetImage(ctx context.Context, ...) (v any, err error)

v0.0.2

Apr 24, 2025

v0.0.1

Apr 6, 2025

Changes in this version

+ const ANNOTATION_CONFIGMAP_MOUNT

+ const ANNOTATION_SECRET_MOUNT

+ var WORKLOAD_KIND_NAME = map[int32]string

+ var WORKLOAD_KIND_VALUE = map[string]int32

+ func FormatContainerState(stage corev1.ContainerState) string

+ func GetContainerFromPodSpec(spec v1.PodSpec, name string) *v1.Container

+ func GetContainerFromPodTemplate(temp v1.PodTemplateSpec, name string) *v1.Container

+ func GetPodContainerStatusByName(pod *corev1.Pod, containerName string) *corev1.ContainerStatus

+ func GetPrimaryContainerName(spec v1.PodSpec) string

+ func HoldContaienrCmd(d time.Duration) []string

+ func InjectContainerEnvVars(c *v1.Container, envs []v1.EnvVar)

+ func InjectJobAnnotations(pod *v1.Job, annotations map[string]string)

+ func InjectJobLabels(pod *v1.Job, labels map[string]string)

+ func InjectPodConfigMapVolume(pod *v1.PodSpec, cs ...*v1.ConfigMap)

+ func InjectPodEnvVars(pod *v1.PodSpec, envs []v1.EnvVar)

+ func InjectPodSecretVolume(pod *v1.PodSpec, ss ...*v1.Secret)

+ func InjectPodTemplateSpecAnnotations(pod *v1.PodTemplateSpec, key, value string)

+ func InjectPodTemplateSpecLabel(pod *v1.PodTemplateSpec, key, value string)

+ func NewConfigMapVolume(cm *v1.ConfigMap) v1.Volume

+ func NewSecretVolume(secret *v1.Secret) v1.Volume

+ func NewVolumeMount(readonly bool, vs []MountVolume) []v1.VolumeMount

+ func WaitForContainerRunning(containerName string, printer terminal.Logger) watchtools.ConditionFunc

+ type Client struct

+ func NewWorkload(cs *kubernetes.Clientset, restconf *rest.Config) *Client

+ func (b *Client) CreateCronJob(ctx context.Context, job *v1.CronJob) (*v1.CronJob, error)

+ func (b *Client) CreateJob(ctx context.Context, job *v1.Job) (*v1.Job, error)

+ func (b *Client) DeleteCronJob(ctx context.Context, req *meta.DeleteRequest) error

+ func (b *Client) GetCronJob(ctx context.Context, req *meta.GetRequest) (*v1.CronJob, error)

+ func (b *Client) GetJob(ctx context.Context, req *meta.GetRequest) (*v1.Job, error)

+ func (b *Client) ListCronJob(ctx context.Context, req *meta.ListRequest) (*v1.CronJobList, error)

+ func (b *Client) ListJob(ctx context.Context, req *meta.ListRequest) (*v1.JobList, error)

+ func (b *Client) UpdateCronJob(ctx context.Context, job *v1.CronJob) (*v1.CronJob, error)

+ func (b *Client) UpdateJob(ctx context.Context, job *v1.Job) (*v1.Job, error)

+ func (c *Client) CopyPodRun(ctx context.Context, req *CopyPodRunRequest) (*v1.Pod, error)

+ func (c *Client) CreateDaemonSet(ctx context.Context, obj *appsv1.DaemonSet) (*appsv1.DaemonSet, error)

+ func (c *Client) CreateDeployment(ctx context.Context, req *appsv1.Deployment) (*appsv1.Deployment, error)

+ func (c *Client) CreatePod(ctx context.Context, pod *v1.Pod, req *meta.CreateRequest) (*v1.Pod, error)

+ func (c *Client) CreateStatefulSet(ctx context.Context, req *appsv1.StatefulSet) (*appsv1.StatefulSet, error)

+ func (c *Client) DebugPod(ctx context.Context, req *DebugPodRequest) error

+ func (c *Client) Delete(ctx context.Context, wl *WorkLoad) (*WorkLoad, error)

+ func (c *Client) DeleteDaemonSet(ctx context.Context, req *meta.DeleteRequest) error

+ func (c *Client) DeleteDeployment(ctx context.Context, req *meta.DeleteRequest) error

+ func (c *Client) DeleteJob(ctx context.Context, req *meta.DeleteRequest) error

+ func (c *Client) DeletePod(ctx context.Context, req *meta.DeleteRequest) error

+ func (c *Client) DeleteStatefulSet(ctx context.Context, req *meta.DeleteRequest) error

+ func (c *Client) Get(ctx context.Context, wl *WorkLoad, req *meta.GetRequest) error

+ func (c *Client) GetDaemonSet(ctx context.Context, req *meta.GetRequest) (*appsv1.DaemonSet, error)

+ func (c *Client) GetDeployment(ctx context.Context, req *meta.GetRequest) (*appsv1.Deployment, error)

+ func (c *Client) GetPod(ctx context.Context, req *meta.GetRequest) (*v1.Pod, error)

+ func (c *Client) GetStatefulSet(ctx context.Context, req *meta.GetRequest) (*appsv1.StatefulSet, error)

+ func (c *Client) ListDaemonSet(ctx context.Context, req *meta.ListRequest) (*appsv1.DaemonSetList, error)

+ func (c *Client) ListDeployment(ctx context.Context, req *meta.ListRequest) (*appsv1.DeploymentList, error)

+ func (c *Client) ListPod(ctx context.Context, req *meta.ListRequest) (*v1.PodList, error)

+ func (c *Client) ListStatefulSet(ctx context.Context, req *meta.ListRequest) (*appsv1.StatefulSetList, error)

+ func (c *Client) LoginContainer(ctx context.Context, req *LoginContainerRequest) error

+ func (c *Client) ReDeploy(ctx context.Context, req *meta.GetRequest) (*appsv1.Deployment, error)

+ func (c *Client) Run(ctx context.Context, wl *WorkLoad) (*WorkLoad, error)

+ func (c *Client) ScaleDeployment(ctx context.Context, req *meta.ScaleRequest) (*v1.Scale, error)

+ func (c *Client) Update(ctx context.Context, wl *WorkLoad) (*WorkLoad, error)

+ func (c *Client) UpdateDaemonSet(ctx context.Context, obj *appsv1.DaemonSet) (*appsv1.DaemonSet, error)

+ func (c *Client) UpdateDeployment(ctx context.Context, req *appsv1.Deployment) (*appsv1.Deployment, error)

+ func (c *Client) UpdateStatefulSet(ctx context.Context, req *appsv1.StatefulSet) (*appsv1.StatefulSet, error)

+ func (c *Client) WaitForPodCondition(ctx context.Context, req *WaitForContainerRequest) (*corev1.Pod, error)

+ func (c *Client) WatchContainerLog(ctx context.Context, req *WatchContainerLogRequest) (io.ReadCloser, error)

+ func (c *Client) WatchDeployment(ctx context.Context, req *appsv1.Deployment) (watch.Interface, error)

+ type ContainerTerminal interface

+ type CopyPodRunRequest struct

+ Attach bool

+ ExecContainer string

+ ExecHoldCmd []string

+ ExecRunCmd []string

+ Remove bool

+ SourcePod *meta.GetRequest

+ TargetPodMeta metav1.ObjectMeta

+ TargetPodOpts *meta.CreateRequest

+ Terminal *terminal.WebSocketTerminal

+ TerminationGracePeriodSeconds int64

+ func NewCopyPodRunRequest() *CopyPodRunRequest

+ func (r *CopyPodRunRequest) SetAttachTerminal(term *terminal.WebSocketTerminal)

+ func (r *CopyPodRunRequest) SetDefaultExecContainer(containerName string)

+ type DebugPodRequest struct

+ EphemeralContainer corev1.EphemeralContainer

+ Excutor *terminal.WebSocketTerminal

+ type EnvVarSet struct

+ Items []*v1.EnvVar

+ func NewEnvVarSet(envs []v1.EnvVar) *EnvVarSet

+ func (s *EnvVarSet) Add(item *v1.EnvVar)

+ func (s *EnvVarSet) EnvVars() (envs []v1.EnvVar)

+ func (s *EnvVarSet) GetOrNewEnv(name string) *v1.EnvVar

+ func (s *EnvVarSet) String() string

+ type EventNotifier func(textMsg string)

+ type LoginContainerRequest struct

+ Command []string

+ ContainerName string

+ Executor ContainerTerminal

+ Namespace string

+ PodName string

+ func NewLoginContainerRequest(ce ContainerTerminal) *LoginContainerRequest

+ func (req *LoginContainerRequest) String() string

+ func (req *LoginContainerRequest) Validate() error

+ type MountVolume struct

+ Path string

+ Volume v1.Volume

+ func NewMountVolume(v v1.Volume, path string) MountVolume

+ type POD_STATUS int

+ const POD_STATUS_CONTAINER_READY

+ const POD_STATUS_INITIALIZED

+ const POD_STATUS_PENDDING

+ const POD_STATUS_POD_READY

+ const POD_STATUS_SCHEDULED

+ func GetPodStatus(p *v1.Pod) POD_STATUS

+ func (s POD_STATUS) String() string

+ type SystemVaraible struct

+ Image string

+ WorkloadName string

+ func NewSystemVaraible() *SystemVaraible

+ func (v *SystemVaraible) ImageDetail() (addr, version string)

+ type WORKLOAD_KIND int32

+ const WORKLOAD_KIND_CRONJOB

+ const WORKLOAD_KIND_DAEMONSET

+ const WORKLOAD_KIND_DEPLOYMENT

+ const WORKLOAD_KIND_JOB

+ const WORKLOAD_KIND_STATEFULSET

+ func ParseWorkloadKindFromString(str string) (WORKLOAD_KIND, error)

+ func (t *WORKLOAD_KIND) UnmarshalJSON(b []byte) error

+ func (t WORKLOAD_KIND) Equal(target WORKLOAD_KIND) bool

+ func (t WORKLOAD_KIND) IsIn(targets ...WORKLOAD_KIND) bool

+ func (t WORKLOAD_KIND) MarshalJSON() ([]byte, error)

+ func (t WORKLOAD_KIND) String() string

+ type WORKLOAD_STAGE int32

+ const WORKLOAD_STAGE_ACTIVE

+ const WORKLOAD_STAGE_ERROR

+ const WORKLOAD_STAGE_PENDDING

+ const WORKLOAD_STAGE_PROGERESS

+ type WaitForContainerRequest struct

+ ContainerName string

+ ExitCondition watchtools.ConditionFunc

+ Namespace string

+ PodName string

+ TimoutSecond int

+ type WatchContainerLogRequest struct

+ Namespace string

+ PodName string

+ func NewWatchContainerLogRequest() *WatchContainerLogRequest

+ func (req *WatchContainerLogRequest) Validate() error

+ type WorkLoad struct

+ CronJob *batchv1.CronJob

+ DaemonSet *appsv1.DaemonSet

+ Deployment *appsv1.Deployment

+ Job *batchv1.Job

+ StatefulSet *appsv1.StatefulSet

+ WorkloadKind WORKLOAD_KIND

+ func NewWorkLoad() *WorkLoad

+ func ParseWorkloadFromYaml(kindStr string, workload string) (w *WorkLoad, err error)

+ func (w *WorkLoad) GetMainContainer() *v1.Container

+ func (w *WorkLoad) GetMainContainerVersion() string

+ func (w *WorkLoad) GetObjectMeta() *metav1.ObjectMeta

+ func (w *WorkLoad) GetPodTemplateSpec() (podSpec *v1.PodTemplateSpec)

+ func (w *WorkLoad) GetServiceContainer(serviceName string) *v1.Container

+ func (w *WorkLoad) MustToYaml() string

+ func (w *WorkLoad) SetAnnotations(key, value string)

+ func (w *WorkLoad) SetDefaultNamespace(ns string)

+ func (w *WorkLoad) SetMatchLabel(k, v string)

+ func (w *WorkLoad) Status() *WorkloadStatus

+ func (w *WorkLoad) SystemVaraible(serviceName string) *SystemVaraible

+ type WorkloadStatus struct

+ Message string

+ Reason string

+ Stage WORKLOAD_STAGE

+ func GetCronJobStatus(*v1.CronJob) *WorkloadStatus

+ func GetDaemonSetStatus(*appsv1.DaemonSet) *WorkloadStatus

+ func GetDeploymentStatus(obj *appsv1.Deployment) *WorkloadStatus

+ func GetJobStatus(*v1.Job) *WorkloadStatus

+ func GetStatefulSetStatus(obj *appsv1.StatefulSet) *WorkloadStatus

+ func NewWorklaodStatus() *WorkloadStatus

+ func (w *WorkloadStatus) UpdateDeploymentStatus(cond appsv1.DeploymentCondition)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL