k8s

Aug 26, 2024

Changes in this version

+ func GetClientErrorMessage(err error) string

+ func IsBadRequestErr(err error) bool

+ func IsClusterStringContainsFluxField(str string) bool

+ func IsServerTimeoutErr(err error) bool

+ func ParseK8sClientErrorToApiError(err error) *util.ApiError

+ type CmCsRequestBean struct

+ func NewCmCsRequestBean(clusterId int, namespace string) *CmCsRequestBean

+ func (req *CmCsRequestBean) GetClusterId() int

+ func (req *CmCsRequestBean) GetExternalCmList() []string

+ func (req *CmCsRequestBean) GetExternalCsList() []string

+ func (req *CmCsRequestBean) GetNamespace() string

+ func (req *CmCsRequestBean) SetClusterId(clusterId int) *CmCsRequestBean

+ func (req *CmCsRequestBean) SetExternalCmList(externalCmList ...string) *CmCsRequestBean

+ func (req *CmCsRequestBean) SetExternalCsList(externalCsList ...string) *CmCsRequestBean

+ func (req *CmCsRequestBean) SetNamespace(namespace string) *CmCsRequestBean

type K8sCommonService

+ GetDataFromConfigMaps func(ctx context.Context, request *CmCsRequestBean) (map[string]*apiV1.ConfigMap, error)

+ GetDataFromSecrets func(ctx context.Context, request *CmCsRequestBean) (map[string]*apiV1.Secret, error)

+ GetK8sConfigAndClients func(ctx context.Context, cluster *cluster.ClusterBean) (*rest.Config, *http.Client, *kubernetes.Clientset, error)

+ GetK8sConfigAndClientsByClusterId func(ctx context.Context, clusterId int) (*rest.Config, *http.Client, *kubernetes.Clientset, error)

+ GetPreferredVersionForAPIGroup func(ctx context.Context, clusterId int, groupName string) (string, error)

+ GetRestConfigOfCluster func(ctx context.Context, request *ResourceRequestBean) (*rest.Config, error)

type K8sCommonServiceImpl

+ func (impl *K8sCommonServiceImpl) GetDataFromConfigMaps(ctx context.Context, request *CmCsRequestBean) (map[string]*apiV1.ConfigMap, error)

+ func (impl *K8sCommonServiceImpl) GetDataFromSecrets(ctx context.Context, request *CmCsRequestBean) (map[string]*apiV1.Secret, error)

+ func (impl *K8sCommonServiceImpl) GetK8sConfigAndClients(ctx context.Context, cluster *cluster.ClusterBean) (*rest.Config, *http.Client, *kubernetes.Clientset, error)

+ func (impl *K8sCommonServiceImpl) GetK8sConfigAndClientsByClusterId(ctx context.Context, clusterId int) (*rest.Config, *http.Client, *kubernetes.Clientset, error)

+ func (impl *K8sCommonServiceImpl) GetPreferredVersionForAPIGroup(ctx context.Context, clusterId int, groupName string) (string, error)

+ func (impl *K8sCommonServiceImpl) GetRestConfigOfCluster(ctx context.Context, request *ResourceRequestBean) (*rest.Config, error)

type ResourceRequestBean

+ ExternalFluxAppIdentifier *bean2.FluxAppIdentifier

+ func (r *ResourceRequestBean) IsValidAppType() bool

+ func (r *ResourceRequestBean) IsValidDeploymentType() bool

Jul 11, 2024 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jul 10, 2024 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Jun 7, 2024 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ func StripPrereleaseFromK8sVersion(k8sVersion string) string

Apr 13, 2024 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ var ResourceNotFoundErr = "Unable to locate Kubernetes resource."

+ func IsResourceNotFoundErr(err error) bool

type K8sCommonService

+ GetCoreClientByClusterIdForExternalArgoApps func(req *cluster.EphemeralContainerRequest) (*kubernetes.Clientset, *v1.CoreV1Client, error)

type K8sCommonServiceImpl

+ func (impl *K8sCommonServiceImpl) GetCoreClientByClusterIdForExternalArgoApps(req *cluster.EphemeralContainerRequest) (*kubernetes.Clientset, *v1.CoreV1Client, error)

+ type LogsDownloadBean struct

+ FileName string

+ LogsData string

type ResourceRequestBean

+ ExternalArgoApplicationName string

Mar 13, 2024 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ type ResourceGetResponse struct

+ ManifestResponse *k8s.ManifestResponse

+ SecretViewAccess bool

Jan 30, 2024 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 15, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 14, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Dec 7, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Oct 30, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Oct 29, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Oct 20, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ const EndPointsSlice

+ const Kind

+ const Nodes

+ const Port

+ const Ports

+ const Spec

+ const Subsets

type K8sCommonService

+ PortNumberExtraction func(resp []BatchResourceResponse, resourceTree map[string]interface{}) map[string]interface{}

type K8sCommonServiceImpl

+ func (impl K8sCommonServiceImpl) PortNumberExtraction(resp []BatchResourceResponse, resourceTree map[string]interface{}) map[string]interface{}

Sep 15, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Sep 14, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Aug 23, 2023 GO-2024-3260

  GO-2024-3260: Devtron has SQL Injection in CreateUser API in github.com/devtron-labs/devtron

Changes in this version

+ const APIServiceKind

+ const CustomResourceDefinitionKind

+ const DaemonSetKind

+ const DeploymentKind

+ const EndpointsKind

+ const Group

+ const HorizontalPodAutoscalerKind

+ const IngressKind

+ const JobKind

+ const NamespaceKind

+ const PersistentVolumeClaimKind

+ const PodKind

+ const ReplicaSetKind

+ const SecretKind

+ const ServiceAccountKind

+ const ServiceKind

+ const StatefulSetKind

+ const Version

+ type BatchResourceResponse struct

+ Err error

+ ManifestResponse *k8s.ManifestResponse

+ type K8sApplicationServiceConfig struct

+ BatchSize int

+ TimeOutInSeconds int

+ type K8sCommonService interface

+ DeleteResource func(ctx context.Context, request *ResourceRequestBean) (resp *k8s.ManifestResponse, err error)

+ FilterK8sResources func(ctx context.Context, resourceTreeInf map[string]interface{}, ...) []ResourceRequestBean

+ GetCoreClientByClusterId func(clusterId int) (*kubernetes.Clientset, *v1.CoreV1Client, error)

+ GetK8sServerVersion func(clusterId int) (*version.Info, error)

+ GetManifestsByBatch func(ctx context.Context, request []ResourceRequestBean) ([]BatchResourceResponse, error)

+ GetResource func(ctx context.Context, request *ResourceRequestBean) (resp *k8s.ManifestResponse, err error)

+ GetRestConfigByClusterId func(ctx context.Context, clusterId int) (*rest.Config, error, *cluster.ClusterBean)

+ ListEvents func(ctx context.Context, request *ResourceRequestBean) (*k8s.EventsResponse, error)

+ RotatePods func(ctx context.Context, request *RotatePodRequest) (*RotatePodResponse, error)

+ UpdateResource func(ctx context.Context, request *ResourceRequestBean) (resp *k8s.ManifestResponse, err error)

+ type K8sCommonServiceImpl struct

+ K8sApplicationServiceConfig *K8sApplicationServiceConfig

+ K8sUtil *k8s.K8sUtil

+ func NewK8sCommonServiceImpl(Logger *zap.SugaredLogger, k8sUtils *k8s.K8sUtil, ...) *K8sCommonServiceImpl

+ func (impl *K8sCommonServiceImpl) DeleteResource(ctx context.Context, request *ResourceRequestBean) (*k8s.ManifestResponse, error)

+ func (impl *K8sCommonServiceImpl) FilterK8sResources(ctx context.Context, resourceTree map[string]interface{}, ...) []ResourceRequestBean

+ func (impl *K8sCommonServiceImpl) GetCoreClientByClusterId(clusterId int) (*kubernetes.Clientset, *v1.CoreV1Client, error)

+ func (impl *K8sCommonServiceImpl) GetK8sServerVersion(clusterId int) (*version.Info, error)

+ func (impl *K8sCommonServiceImpl) GetManifestsByBatch(ctx context.Context, requests []ResourceRequestBean) ([]BatchResourceResponse, error)

+ func (impl *K8sCommonServiceImpl) GetResource(ctx context.Context, request *ResourceRequestBean) (*k8s.ManifestResponse, error)

+ func (impl *K8sCommonServiceImpl) GetRestConfigByClusterId(ctx context.Context, clusterId int) (*rest.Config, error, *cluster.ClusterBean)

+ func (impl *K8sCommonServiceImpl) ListEvents(ctx context.Context, request *ResourceRequestBean) (*k8s.EventsResponse, error)

+ func (impl *K8sCommonServiceImpl) RotatePods(ctx context.Context, request *RotatePodRequest) (*RotatePodResponse, error)

+ func (impl *K8sCommonServiceImpl) UpdateResource(ctx context.Context, request *ResourceRequestBean) (*k8s.ManifestResponse, error)

+ type PodContainerList struct

+ Containers []string

+ EphemeralContainers []string

+ InitContainers []string

+ type ResourceRequestBean struct

+ AppId string

+ AppIdentifier *client.AppIdentifier

+ AppType int

+ ClusterId int

+ DeploymentType int

+ DevtronAppIdentifier *bean.DevtronAppIdentifier

+ K8sRequest *k8s.K8sRequestBean

+ type RotatePodRequest struct

+ ClusterId int

+ Resources []k8s.ResourceIdentifier

+ type RotatePodResponse struct

+ ContainsError bool

+ Responses []*bean.RotatePodResourceResponse