mocks

Jul 17, 2023

Changes in this version

type K8sApplicationService

+ func (_m *K8sApplicationService) DecodeDevtronAppId(applicationId string) (*k8s.DevtronAppIdentifier, error)

+ func (_m *K8sApplicationService) FetchConnectionStatusForCluster(k8sClientSet *kubernetes.Clientset, clusterId int) error

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

+ func (_m *K8sApplicationService) ValidateClusterResourceBean(ctx context.Context, clusterId int, manifest unstructured.Unstructured, ...) bool

+ func (_m *K8sApplicationService) ValidateClusterResourceRequest(ctx context.Context, clusterResourceRequest *k8s.ResourceRequestBean, ...) (bool, error)

+ func (_m *K8sApplicationService) ValidatePodLogsRequestQuery(r *http.Request) (*k8s.ResourceRequestBean, error)

+ func (_m *K8sApplicationService) ValidateTerminalRequestQuery(r *http.Request) (*terminal.TerminalSessionRequest, *k8s.ResourceRequestBean, error)

Feb 28, 2023

Changes in this version

type K8sApplicationService

+ func (_m *K8sApplicationService) ApplyResources(token string, request *application.ApplyResourcesRequest, ...) ([]*application.ApplyResourcesResponse, error)

+ func (_m *K8sApplicationService) GetAllApiResources(clusterId int, isSuperAdmin bool, userId int32) (*application.GetAllApiResourcesResponse, error)

+ func (_m *K8sApplicationService) GetResourceList(token string, request *k8s.ResourceRequestBean, ...) (*application.ClusterResourceListMap, error)

Jan 9, 2023

Changes in this version

+ type K8sApplicationService struct

+ func NewK8sApplicationService(t mockConstructorTestingTNewK8sApplicationService) *K8sApplicationService

+ func (_m *K8sApplicationService) CreateResource(request *k8s.ResourceRequestBean) (*application.ManifestResponse, error)

+ func (_m *K8sApplicationService) DeleteResource(request *k8s.ResourceRequestBean) (*application.ManifestResponse, error)

+ func (_m *K8sApplicationService) FilterServiceAndIngress(resourceTreeInf map[string]interface{}, ...) []k8s.ResourceRequestBean

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

+ func (_m *K8sApplicationService) GetPodLogs(request *k8s.ResourceRequestBean) (io.ReadCloser, error)

+ func (_m *K8sApplicationService) GetResource(request *k8s.ResourceRequestBean) (*application.ManifestResponse, error)

+ func (_m *K8sApplicationService) GetResourceInfo() (*k8s.ResourceInfo, error)

+ func (_m *K8sApplicationService) GetRestConfigByCluster(_a0 *cluster.ClusterBean) (*rest.Config, error)

+ func (_m *K8sApplicationService) GetRestConfigByClusterId(clusterId int) (*rest.Config, error)

+ func (_m *K8sApplicationService) GetUrlsByBatch(resp []k8s.BatchResourceResponse) []interface{}

+ func (_m *K8sApplicationService) ListEvents(request *k8s.ResourceRequestBean) (*application.EventsResponse, error)

+ func (_m *K8sApplicationService) UpdateResource(request *k8s.ResourceRequestBean) (*application.ManifestResponse, error)

+ func (_m *K8sApplicationService) ValidateResourceRequest(appIdentifier *client.AppIdentifier, request *application.K8sRequestBean) (bool, error)