Function TestGetRegistryHandler

pkg/webhook/plugins/plugins_impl_test.go:214–372

(t *testing.T)

}

func TestGetRegistryHandler(t *testing.T) {
	type want struct {
		podWithDatasetHandlerNames []string
		nodeWithCacheArgs          *nodeaffinitywithcache.TieredLocality

		podWithoutDatasetHandlerSize           int
		serverlessPodWithDatasetHandlerSize    int
		serverlessPodWithoutDatasetHandlerSize int
	}

	tests := []struct {
		name          string
		want          want
		newPluginErr  bool
		pluginProfile string
	}{
		{
			name: "existing correct configmap",
			pluginProfile: `
plugins:
  serverful:
    withDataset:
    - RequireNodeWithFuse
    - NodeAffinityWithCache
    - MountPropagationInjector
    withoutDataset:
    - PreferNodesWithoutCache
  serverless:
    withDataset:
    - FuseSidecar
    withoutDataset:
    - PreferNodesWithoutCache
pluginConfig:
  - name: NodeAffinityWithCache
    args: |
      preferred:
      # fluid existed node affinity, the name can not be modified.
      - name: fluid.io/node
        weight: 100
      # runtime worker's zone label name, can be changed according to k8s environment.
      - name: topology.kubernetes.io/zone
        weight: 50
      # runtime worker's region label name, can be changed according to k8s environment.
      - name: topology.kubernetes.io/region
        weight: 10
      required:
      - fluid.io/node
`,
			want: want{
				podWithDatasetHandlerNames: []string{
					"RequireNodeWithFuse", "NodeAffinityWithCache", "MountPropagationInjector",
				},
				nodeWithCacheArgs: &nodeaffinitywithcache.TieredLocality{
					Preferred: []nodeaffinitywithcache.Preferred{
						{
							Name:   "fluid.io/node",
							Weight: 100,
						},