Affected by 
Documentation
¶
Index ¶
- type K8sApplicationService
- func (_m *K8sApplicationService) ApplyResources(ctx context.Context, token string, request *k8s.ApplyResourcesRequest, ...) ([]*k8s.ApplyResourcesResponse, error)
- func (_m *K8sApplicationService) CreatePodEphemeralContainers(req *cluster.EphemeralContainerRequest) error
- func (_m *K8sApplicationService) CreateResource(ctx context.Context, request *k8s2.ResourceRequestBean) (*k8s.ManifestResponse, error)
- func (_m *K8sApplicationService) DecodeDevtronAppId(applicationId string) (*bean2.DevtronAppIdentifier, error)
- func (_m *K8sApplicationService) DeleteResource(ctx context.Context, request *k8s2.ResourceRequestBean, userId int32) (*k8s.ManifestResponse, error)
- func (_m *K8sApplicationService) FetchConnectionStatusForCluster(k8sClientSet *kubernetes.Clientset, clusterId int) error
- func (_m *K8sApplicationService) FilterServiceAndIngress(ctx context.Context, resourceTreeInf map[string]interface{}, ...) []k8s2.ResourceRequestBean
- func (_m *K8sApplicationService) GetAllApiResources(ctx context.Context, clusterId int, isSuperAdmin bool, userId int32) (*k8s.GetAllApiResourcesResponse, error)
- func (_m *K8sApplicationService) GetK8sServerVersion(clusterId int) (*version.Info, error)
- func (_m *K8sApplicationService) GetManifestsByBatch(ctx context.Context, request []k8s2.ResourceRequestBean) ([]k8s2.BatchResourceResponse, error)
- func (_m *K8sApplicationService) GetPodContainersList(clusterId int, namespace string, podName string) (*k8s2.PodContainerList, error)
- func (_m *K8sApplicationService) GetPodLogs(ctx context.Context, request *k8s2.ResourceRequestBean) (io.ReadCloser, error)
- func (_m *K8sApplicationService) GetResource(ctx context.Context, request *k8s2.ResourceRequestBean) (*k8s.ManifestResponse, error)
- func (_m *K8sApplicationService) GetResourceInfo(ctx context.Context) (*bean2.ResourceInfo, error)
- func (_m *K8sApplicationService) GetResourceList(ctx context.Context, token string, request *k8s2.ResourceRequestBean, ...) (*k8s.ClusterResourceListMap, error)
- func (_m *K8sApplicationService) GetRestConfigByClusterId(ctx context.Context, clusterId int) (*rest.Config, error, *cluster.ClusterBean)
- func (_m *K8sApplicationService) GetUrlsByBatch(ctx context.Context, resp []k8s2.BatchResourceResponse) []interface{}
- func (_m *K8sApplicationService) ListEvents(ctx context.Context, request *k8s2.ResourceRequestBean) (*k8s.EventsResponse, error)
- func (_m *K8sApplicationService) RotatePods(ctx context.Context, request *k8s2.RotatePodRequest) (*k8s2.RotatePodResponse, error)
- func (_m *K8sApplicationService) TerminatePodEphemeralContainer(req cluster.EphemeralContainerRequest) (bool, error)
- func (_m *K8sApplicationService) UpdateResource(ctx context.Context, request *k8s2.ResourceRequestBean) (*k8s.ManifestResponse, error)
- func (_m *K8sApplicationService) ValidateClusterResourceBean(ctx context.Context, clusterId int, manifest unstructured.Unstructured, ...) bool
- func (_m *K8sApplicationService) ValidateClusterResourceRequest(ctx context.Context, clusterResourceRequest *k8s2.ResourceRequestBean, ...) (bool, error)
- func (_m *K8sApplicationService) ValidatePodLogsRequestQuery(r *http.Request) (*k8s2.ResourceRequestBean, error)
- func (_m *K8sApplicationService) ValidateResourceRequest(ctx context.Context, appIdentifier *client.AppIdentifier, ...) (bool, error)
- func (_m *K8sApplicationService) ValidateTerminalRequestQuery(r *http.Request) (*terminal.TerminalSessionRequest, *k8s2.ResourceRequestBean, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type K8sApplicationService ¶
K8sApplicationService is an autogenerated mock type for the K8sApplicationService type
func NewK8sApplicationService ¶
func NewK8sApplicationService(t mockConstructorTestingTNewK8sApplicationService) *K8sApplicationService
NewK8sApplicationService creates a new instance of K8sApplicationService. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations.
func (*K8sApplicationService) ApplyResources ¶
func (_m *K8sApplicationService) ApplyResources(ctx context.Context, token string, request *k8s.ApplyResourcesRequest, resourceRbacHandler func(string, string, k8s2.ResourceRequestBean, string) bool) ([]*k8s.ApplyResourcesResponse, error)
ApplyResources provides a mock function with given fields: ctx, token, request, resourceRbacHandler
func (*K8sApplicationService) CreatePodEphemeralContainers ¶
func (_m *K8sApplicationService) CreatePodEphemeralContainers(req *cluster.EphemeralContainerRequest) error
CreatePodEphemeralContainers provides a mock function with given fields: req
func (*K8sApplicationService) CreateResource ¶
func (_m *K8sApplicationService) CreateResource(ctx context.Context, request *k8s2.ResourceRequestBean) (*k8s.ManifestResponse, error)
CreateResource provides a mock function with given fields: ctx, request
func (*K8sApplicationService) DecodeDevtronAppId ¶
func (_m *K8sApplicationService) DecodeDevtronAppId(applicationId string) (*bean2.DevtronAppIdentifier, error)
DecodeDevtronAppId provides a mock function with given fields: applicationId
func (*K8sApplicationService) DeleteResource ¶
func (_m *K8sApplicationService) DeleteResource(ctx context.Context, request *k8s2.ResourceRequestBean, userId int32) (*k8s.ManifestResponse, error)
DeleteResource provides a mock function with given fields: ctx, request, userId
func (*K8sApplicationService) FetchConnectionStatusForCluster ¶
func (_m *K8sApplicationService) FetchConnectionStatusForCluster(k8sClientSet *kubernetes.Clientset, clusterId int) error
FetchConnectionStatusForCluster provides a mock function with given fields: k8sClientSet, clusterId
func (*K8sApplicationService) FilterServiceAndIngress ¶
func (_m *K8sApplicationService) FilterServiceAndIngress(ctx context.Context, resourceTreeInf map[string]interface{}, validRequests []k8s2.ResourceRequestBean, appDetail bean.AppDetailContainer, appId string) []k8s2.ResourceRequestBean
FilterServiceAndIngress provides a mock function with given fields: ctx, resourceTreeInf, validRequests, appDetail, appId
func (*K8sApplicationService) GetAllApiResources ¶
func (_m *K8sApplicationService) GetAllApiResources(ctx context.Context, clusterId int, isSuperAdmin bool, userId int32) (*k8s.GetAllApiResourcesResponse, error)
GetAllApiResources provides a mock function with given fields: ctx, clusterId, isSuperAdmin, userId
func (*K8sApplicationService) GetK8sServerVersion ¶
func (_m *K8sApplicationService) GetK8sServerVersion(clusterId int) (*version.Info, error)
GetK8sServerVersion provides a mock function with given fields: clusterId
func (*K8sApplicationService) GetManifestsByBatch ¶
func (_m *K8sApplicationService) GetManifestsByBatch(ctx context.Context, request []k8s2.ResourceRequestBean) ([]k8s2.BatchResourceResponse, error)
GetManifestsByBatch provides a mock function with given fields: ctx, request
func (*K8sApplicationService) GetPodContainersList ¶
func (_m *K8sApplicationService) GetPodContainersList(clusterId int, namespace string, podName string) (*k8s2.PodContainerList, error)
GetPodContainersList provides a mock function with given fields: clusterId, namespace, podName
func (*K8sApplicationService) GetPodLogs ¶
func (_m *K8sApplicationService) GetPodLogs(ctx context.Context, request *k8s2.ResourceRequestBean) (io.ReadCloser, error)
GetPodLogs provides a mock function with given fields: ctx, request
func (*K8sApplicationService) GetResource ¶
func (_m *K8sApplicationService) GetResource(ctx context.Context, request *k8s2.ResourceRequestBean) (*k8s.ManifestResponse, error)
GetResource provides a mock function with given fields: ctx, request
func (*K8sApplicationService) GetResourceInfo ¶
func (_m *K8sApplicationService) GetResourceInfo(ctx context.Context) (*bean2.ResourceInfo, error)
GetResourceInfo provides a mock function with given fields: ctx
func (*K8sApplicationService) GetResourceList ¶
func (_m *K8sApplicationService) GetResourceList(ctx context.Context, token string, request *k8s2.ResourceRequestBean, validateResourceAccess func(string, string, k8s2.ResourceRequestBean, string) bool) (*k8s.ClusterResourceListMap, error)
GetResourceList provides a mock function with given fields: ctx, token, request, validateResourceAccess
func (*K8sApplicationService) GetRestConfigByClusterId ¶
func (_m *K8sApplicationService) GetRestConfigByClusterId(ctx context.Context, clusterId int) (*rest.Config, error, *cluster.ClusterBean)
GetRestConfigByClusterId provides a mock function with given fields: ctx, clusterId
func (*K8sApplicationService) GetUrlsByBatch ¶
func (_m *K8sApplicationService) GetUrlsByBatch(ctx context.Context, resp []k8s2.BatchResourceResponse) []interface{}
GetUrlsByBatch provides a mock function with given fields: ctx, resp
func (*K8sApplicationService) ListEvents ¶
func (_m *K8sApplicationService) ListEvents(ctx context.Context, request *k8s2.ResourceRequestBean) (*k8s.EventsResponse, error)
ListEvents provides a mock function with given fields: ctx, request
func (*K8sApplicationService) RotatePods ¶
func (_m *K8sApplicationService) RotatePods(ctx context.Context, request *k8s2.RotatePodRequest) (*k8s2.RotatePodResponse, error)
RotatePods provides a mock function with given fields: ctx, request
func (*K8sApplicationService) TerminatePodEphemeralContainer ¶
func (_m *K8sApplicationService) TerminatePodEphemeralContainer(req cluster.EphemeralContainerRequest) (bool, error)
TerminatePodEphemeralContainer provides a mock function with given fields: req
func (*K8sApplicationService) UpdateResource ¶
func (_m *K8sApplicationService) UpdateResource(ctx context.Context, request *k8s2.ResourceRequestBean) (*k8s.ManifestResponse, error)
UpdateResource provides a mock function with given fields: ctx, request
func (*K8sApplicationService) ValidateClusterResourceBean ¶
func (_m *K8sApplicationService) ValidateClusterResourceBean(ctx context.Context, clusterId int, manifest unstructured.Unstructured, gvk schema.GroupVersionKind, rbacCallback func(string, k8s.ResourceIdentifier) bool) bool
ValidateClusterResourceBean provides a mock function with given fields: ctx, clusterId, manifest, gvk, rbacCallback
func (*K8sApplicationService) ValidateClusterResourceRequest ¶
func (_m *K8sApplicationService) ValidateClusterResourceRequest(ctx context.Context, clusterResourceRequest *k8s2.ResourceRequestBean, rbacCallback func(string, k8s.ResourceIdentifier) bool) (bool, error)
ValidateClusterResourceRequest provides a mock function with given fields: ctx, clusterResourceRequest, rbacCallback
func (*K8sApplicationService) ValidatePodLogsRequestQuery ¶
func (_m *K8sApplicationService) ValidatePodLogsRequestQuery(r *http.Request) (*k8s2.ResourceRequestBean, error)
ValidatePodLogsRequestQuery provides a mock function with given fields: r
func (*K8sApplicationService) ValidateResourceRequest ¶
func (_m *K8sApplicationService) ValidateResourceRequest(ctx context.Context, appIdentifier *client.AppIdentifier, request *k8s.K8sRequestBean) (bool, error)
ValidateResourceRequest provides a mock function with given fields: ctx, appIdentifier, request
func (*K8sApplicationService) ValidateTerminalRequestQuery ¶
func (_m *K8sApplicationService) ValidateTerminalRequestQuery(r *http.Request) (*terminal.TerminalSessionRequest, *k8s2.ResourceRequestBean, error)
ValidateTerminalRequestQuery provides a mock function with given fields: r
Source Files