Versions in this module Expand all Collapse all v1 v1.0.1 Nov 9, 2023 v1.0.0 Nov 9, 2023 Changes in this version + const AnnotationMeshEnable + const AnnotationMeshHeaderKey + const AnnotationMeshHeaderValue + const AnnotationMeshPort + const AnnotationMeshType + const AnnotationMeshTypeDev + const AnnotationMeshTypeOrigin + const AnnotationMeshUuid + const EnvoyMeshSidecarName + const EnvoySidecarImage + const IdentifierKey + const MeshControlPlaneImage + const MeshManager + const OriginSpecJson + const OriginWorkloadNameKey + const OriginWorkloadTypeKey + func AddEnvoySidecarForMesh(spec *v1.PodTemplateSpec) (exist bool) + func GetAnnotationFromUnstructured(u *unstructured.Unstructured, key string) (string, error) + func GetDefaultPodName(ctx context.Context, p *Controller) (string, error) + func GetOriginalContainers(client *clientgoutils.ClientGoUtils, workloadType base.SvcType, ...) ([]v1.Container, error) + func GetPodTemplateFromSpecPath(path string, unstructuredObj map[string]interface{}) (*corev1.PodTemplateSpec, error) + func GetSvcConfig(ns, appName, svcName, kubeconfig string, svcType base.SvcType) (*profile.ServiceConfigV2, error) + func GetUnstructuredMapByPath(path string, u map[string]interface{}) (map[string]interface{}, error) + func IsResourcesLimitTooLow(r *corev1.ResourceRequirements) bool + func RemoveUselessInfo(u *unstructured.Unstructured) + func StopPortForward(ns, nid, app, svc string, portForward *profile.DevPortForward) error + func UpdateSvcConfig(ns, appName, kubeconfig string, config *profile.ServiceConfigV2) error + type ContainerDevEnv struct + DevEnv []*profile.Env + type Controller struct + AppMeta *appmeta.ApplicationMeta + AppName string + Client *clientgoutils.ClientGoUtils + DevModeAction base.DevModeAction + DevModeType profile.DevModeType + Identifier string + Name string + NameSpace string + Type base.SvcType + func NewController(ns, name, appName, identifier string, svcType base.SvcType, ...) (*Controller, error) + func (c *Controller) AddPortForwardToDB(port *profile.DevPortForward) error + func (c *Controller) BuildPodController() pod_controller.PodController + func (c *Controller) CheckDevModePodIsRunning() (string, error) + func (c *Controller) CheckIfExist() error + func (c *Controller) CheckIfPortForwardExists(localPort, remotePort int) (bool, error) + func (c *Controller) Config() *profile.ServiceConfigV2 + func (c *Controller) CreateSyncThingSecret(container string, localSyncDir []string, duplicateDevMode bool) error + func (c *Controller) DecreaseDevModeCount() error + func (c *Controller) DeletePortForwardFromDB(localPort, remotePort int) error + func (c *Controller) DevEnd(reset bool) error + func (c *Controller) DuplicateModeRollBack() error + func (c *Controller) EndDevPortForward(localPort int, remotePort int) error + func (c *Controller) EnterPodTerminal(podName, container, shell, banner string) error + func (c *Controller) FindOutSyncthingProcess(whileProcessFound func(int) error) error + func (c *Controller) GetAppConfig() *profile.NocalHostAppConfigV2 + func (c *Controller) GetAppProfile() (*profile.AppProfileV2, error) + func (c *Controller) GetContainerImage(container string) (string, error) + func (c *Controller) GetContainers() ([]v1.Container, error) + func (c *Controller) GetCurrentDevModeType() profile.DevModeType + func (c *Controller) GetDescription() *profile.SvcProfileV2 + func (c *Controller) GetDevContainerEnv(container string) *ContainerDevEnv + func (c *Controller) GetDevContainerName(container string) string + func (c *Controller) GetDevImage(container string) string + func (c *Controller) GetDevModePodName() (string, error) + func (c *Controller) GetDevSidecarImage(container string) string + func (c *Controller) GetDevSidecarLanguage(container string) string + func (c *Controller) GetDuplicateModePodList() ([]v1.Pod, error) + func (c *Controller) GetImagePullPolicy(container string) corev1.PullPolicy + func (c *Controller) GetOriginalContainers() ([]v1.Container, error) + func (c *Controller) GetPVCsBySvc() ([]v1.PersistentVolumeClaim, error) + func (c *Controller) GetPersistentVolumeDirs(container string) []*profile.PersistentVolumeDir + func (c *Controller) GetPodList() ([]corev1.Pod, error) + func (c *Controller) GetPodTemplate() (*corev1.PodTemplateSpec, error) + func (c *Controller) GetPortForward(localPort, remotePort int) (*profile.DevPortForward, error) + func (c *Controller) GetPortForwardForSync() (*profile.DevPortForward, error) + func (c *Controller) GetProfile() (*profile.SvcProfileV2, error) + func (c *Controller) GetProfileForUpdate() (*profile.AppProfileV2, error) + func (c *Controller) GetStorageClass(container string) string + func (c *Controller) GetSyncDir() string + func (c *Controller) GetSyncThingPid() (int, error) + func (c *Controller) GetSyncThingPidFile() string + func (c *Controller) GetSyncThingSecretName() string + func (c *Controller) GetTypeMeta() (metav1.TypeMeta, error) + func (c *Controller) GetUnstructured() (unstructuredMap *unstructured.Unstructured, err error) + func (c *Controller) GetWorkDir(container string) string + func (c *Controller) IncreaseDevModeCount() error + func (c *Controller) IsInDevMode() bool + func (c *Controller) IsInDevModeStarting() bool + func (c *Controller) IsInDuplicateDevMode() bool + func (c *Controller) IsInDuplicateDevModeStarting() bool + func (c *Controller) IsInReplaceDevMode() bool + func (c *Controller) IsInReplaceDevModeStarting() bool + func (c *Controller) IsPortForwarding() bool + func (c *Controller) IsProcessor() bool + func (c *Controller) ListHPA() ([]autoscalingv1.HorizontalPodAutoscaler, error) + func (c *Controller) ListPodOfGeneratedDeployment() ([]corev1.Pod, error) + func (c *Controller) LoadConfigFromHub() error + func (c *Controller) LoadConfigFromHubC(container string) error + func (c *Controller) NewSyncthing(container string, localSyncDir []string, syncDouble bool) (*syncthing.Syncthing, error) + func (c *Controller) NewSyncthingHttpClient(reqTimeoutSecond int) *req.SyncthingHttpClient + func (c *Controller) PatchDevModeManifest(ctx context.Context, ops *model.DevStartOptions) error + func (c *Controller) PortForward(podName string, localPort, remotePort int, role string) error + func (c *Controller) PortForwardAfterDevStart(podName, containerName string) error + func (c *Controller) ReloadConfig() profile.ServiceConfigV2 + func (c *Controller) ReplaceDuplicateModeImage(ctx context.Context, ops *model.DevStartOptions) error + func (c *Controller) ReplaceImage(ctx context.Context, ops *model.DevStartOptions) error + func (c *Controller) RollBack(reset bool) error + func (c *Controller) RollbackFromAnnotation(reset bool) error + func (c *Controller) SetPortForwardedStatus(is bool) error + func (c *Controller) SetSyncingStatus(is bool) error + func (c *Controller) SetSyncthingPort(remotePort, remoteGUIPort, localPort, localGUIPort int) error + func (c *Controller) StopAllPortForward() error + func (c *Controller) StopFileSyncOnly() error + func (c *Controller) StopPortForwardByPort(port string) error + func (c *Controller) StopSyncAndPortForwardProcess(cleanRemoteSecret bool) error + func (c *Controller) UpdateConfig(config profile.ServiceConfigV2) error + func (c *Controller) UpdatePortForwardStatus(localPort int, remotePort int, portStatus string, reason string) error + func (c *Controller) UpdateSvcProfile(modify func(*profile.SvcProfileV2) error) error + type DefaultController struct + func (j *DefaultController) ReplaceImage(ctx context.Context, ops *model.DevStartOptions) error + func (j *DefaultController) RollBack(reset bool) error + type DuplicateRawPodController struct + func (r *DuplicateRawPodController) ReplaceImage(ctx context.Context, ops *model.DevStartOptions) error + func (r *DuplicateRawPodController) RollBack(reset bool) error + type RawPodController struct + func (r *RawPodController) ReplaceImage(ctx context.Context, ops *model.DevStartOptions) error + func (r *RawPodController) RollBack(reset bool) error