returns a newCmdReporter function that returns the given mockCmdReporter and error
(m *mockCmdReporter, err error)
| 55 | |
| 56 | // returns a newCmdReporter function that returns the given mockCmdReporter and error |
| 57 | func mockNewCmdReporter(m *mockCmdReporter, err error) func(clientset kubernetes.Interface, ownerInfo *k8sutil.OwnerInfo, appName string, jobName string, jobNamespace string, cmd []string, args []string, rookImage string, runImage string, imagePullPolicy v1.PullPolicy, resources cephv1.ResourceSpec) (cmdreporter.CmdReporterInterface, error) { |
| 58 | return func(clientset kubernetes.Interface, ownerInfo *k8sutil.OwnerInfo, appName, jobName, jobNamespace string, cmd, args []string, rookImage, runImage string, imagePullPolicy v1.PullPolicy, resources cephv1.ResourceSpec) (cmdreporter.CmdReporterInterface, error) { |
| 59 | job, err := cmdreporter.MockCmdReporterJob(clientset, ownerInfo, appName, jobName, jobNamespace, cmd, args, rookImage, runImage, imagePullPolicy, resources) |
| 60 | if err != nil { |
| 61 | // okay to panic here because this is a unit test setup failure, not part of code testing |
| 62 | panic(fmt.Sprintf("error setting up mock CmdReporter job: %v", err)) |
| 63 | } |
| 64 | m.job = job |
| 65 | return m, err |
| 66 | } |
| 67 | } |
| 68 | |
| 69 | func newTestConfigsWithNetworkSpec(n cephv1.NetworkSpec) (*clusterd.Context, *cephv1.ClusterSpec, *client.ClusterInfo) { |
| 70 | clusterdCtx := &clusterd.Context{} |
no test coverage detected