MCPcopy
hub / github.com/rook/rook / mockNewCmdReporter

Function mockNewCmdReporter

pkg/operator/ceph/controller/network_test.go:57–67  ·  view source on GitHub ↗

returns a newCmdReporter function that returns the given mockCmdReporter and error

(m *mockCmdReporter, err error)

Source from the content-addressed store, hash-verified

55
56// returns a newCmdReporter function that returns the given mockCmdReporter and error
57func 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
69func newTestConfigsWithNetworkSpec(n cephv1.NetworkSpec) (*clusterd.Context, *cephv1.ClusterSpec, *client.ClusterInfo) {
70 clusterdCtx := &clusterd.Context{}

Callers 1

Calls 1

MockCmdReporterJobFunction · 0.92

Tested by

no test coverage detected