mocks

Documentation

Index

• type K8sApplicationService
  • func NewK8sApplicationService(t mockConstructorTestingTNewK8sApplicationService) *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)

Types

type K8sApplicationService

type K8sApplicationService struct {
	mock.Mock
}

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