| 127 | } |
| 128 | |
| 129 | type IKubernetesClient interface { |
| 130 | GetStreamedPodLogs(ctx context.Context, namespace, container, name string, logCount *int64, logChan chan<- string) error |
| 131 | GetPodLogs(namespace, container, name string, numLogs *int64) ([]string, error) |
| 132 | GetDeploymentLogs(namespace, container, deployment string, numLogs *int64) ([]string, error) |
| 133 | GetStatefulSetsLogs(namespace, container, name string, numLogs *int64) ([]string, error) |
| 134 | ListModules() ([]cyclopsv1alpha1.Module, error) |
| 135 | CreateModule(module cyclopsv1alpha1.Module) error |
| 136 | UpdateModule(module *cyclopsv1alpha1.Module) error |
| 137 | UpdateModuleStatus(module *cyclopsv1alpha1.Module) (*cyclopsv1alpha1.Module, error) |
| 138 | DeleteModule(name string) error |
| 139 | GetModule(name string) (*cyclopsv1alpha1.Module, error) |
| 140 | GetResourcesForModule(name string) ([]*dto.Resource, error) |
| 141 | MapUnstructuredResource(u unstructured.Unstructured) (*dto.Resource, error) |
| 142 | GetWorkloadsForModule(name string) ([]*dto.Resource, error) |
| 143 | GetDeletedResources([]*dto.Resource, string, string) ([]*dto.Resource, error) |
| 144 | GetModuleResourcesHealth(name string) (string, error) |
| 145 | GVKtoAPIResourceName(gv schema.GroupVersion, kind string) (string, error) |
| 146 | VersionInfo() (*version.Info, error) |
| 147 | RestartDeployment(name, namespace string) error |
| 148 | RestartStatefulSet(name, namespace string) error |
| 149 | RestartDaemonSet(name, namespace string) error |
| 150 | GetManifest(group, version, kind, name, namespace string, includeManagedFields bool) (string, error) |
| 151 | Restart(group, version, kind, name, namespace string) error |
| 152 | GetResource(group, version, kind, name, namespace string) (any, error) |
| 153 | Delete(resource *dto.Resource) error |
| 154 | CreateDynamic(cyclopsv1alpha1.GroupVersionResource, *unstructured.Unstructured, string) error |
| 155 | ApplyCRD(obj *unstructured.Unstructured) error |
| 156 | ListNodes() ([]apiv1.Node, error) |
| 157 | GetNode(name string) (*apiv1.Node, error) |
| 158 | GetPodsForNode(nodeName string) ([]apiv1.Pod, error) |
| 159 | ListNamespaces() ([]string, error) |
| 160 | WatchResource(group, version, resource, name, namespace string) (watch.Interface, error) |
| 161 | WatchKubernetesResources(gvrs []ResourceWatchSpec, stopCh chan struct{}) (chan *unstructured.Unstructured, error) |
| 162 | ListTemplateAuthRules() ([]cyclopsv1alpha1.TemplateAuthRule, error) |
| 163 | GetTemplateAuthRuleSecret(name, key string) (string, error) |
| 164 | ListTemplateStore() ([]cyclopsv1alpha1.TemplateStore, error) |
| 165 | GetTemplateStore(name string) (*cyclopsv1alpha1.TemplateStore, error) |
| 166 | CreateTemplateStore(ts *cyclopsv1alpha1.TemplateStore) error |
| 167 | UpdateTemplateStore(ts *cyclopsv1alpha1.TemplateStore) error |
| 168 | DeleteTemplateStore(name string) error |
| 169 | GetResourcesForRelease(release string) ([]*dto.Resource, error) |
| 170 | GetWorkloadsForRelease(name string) ([]*dto.Resource, error) |
| 171 | DeleteReleaseSecret(releaseName, releaseNamespace string) error |
| 172 | CommandExecutor(namespace, podName, container string) (remotecommand.Executor, error) |
| 173 | } |
no outgoing calls
no test coverage detected
searching dependent graphs…