distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

package cacher

import (
	"errors"
	"fmt"
	"reflect"
	"sync"
	"testing"

	v1 "k8s.io/api/core/v1"
	"k8s.io/apimachinery/pkg/fields"

			// To avoid rewriting all tests, we wait for watchcache to initialize.
			if err := cacher.Wait(context.Background()); err != nil {
				t.Fatal(err)
			}
		}
		d := destroyFunc
		s = cacher
		destroyFunc = func() {
			cacher.Stop()
			d()
		}
	}

	return destroyFunc, &Store{

}

// Represents a cinder volume resource in Openstack.
// A Cinder volume must exist before mounting to a container.
// The volume must also be in the same region as the kubelet.
// Cinder volumes support ownership management and SELinux relabeling.
message CinderVolumeSource {
  // volumeID used to identify the volume in cinder.
  // More info: https://examples.k8s.io/mysql-cinder-pd/README.md
  optional string volumeID = 1;

	FlexVolume *FlexVolumeSource `json:"flexVolume,omitempty" protobuf:"bytes,12,opt,name=flexVolume"`
	// cinder represents a cinder volume attached and mounted on kubelets host machine.
	// More info: https://examples.k8s.io/mysql-cinder-pd/README.md
	// +optional
	Cinder *CinderVolumeSource `json:"cinder,omitempty" protobuf:"bytes,13,opt,name=cinder"`
	// cephFS represents a Ceph FS mount on the host that shares a pod's lifetime
	// +optional

distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

package cacher

import (
	"context"
	"fmt"
	"math"
	"sort"
	"sync"
	"time"

	"k8s.io/apimachinery/pkg/api/errors"

distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/

package cacher

import (
	"context"
	"fmt"
	"strconv"
	"strings"
	"testing"
	"time"

	v1 "k8s.io/api/core/v1"

                "name": "nameValue"
              },
              "readOnly": true,
              "options": {
                "optionsKey": "optionsValue"
              }
            },
            "cinder": {
              "volumeID": "volumeIDValue",
              "fsType": "fsTypeValue",
              "readOnly": true,
              "secretRef": {
                "name": "nameValue"
              }

          - monitorsValue
          path: pathValue
          readOnly: true
          secretFile: secretFileValue
          secretRef:
            name: nameValue
          user: userValue
        cinder:
          fsType: fsTypeValue
          readOnly: true
          secretRef:
            name: nameValue
          volumeID: volumeIDValue
        configMap:
          defaultMode: 3
          items:

                "name": "nameValue"
              },
              "readOnly": true,
              "options": {
                "optionsKey": "optionsValue"
              }
            },
            "cinder": {
              "volumeID": "volumeIDValue",
              "fsType": "fsTypeValue",
              "readOnly": true,
              "secretRef": {
                "name": "nameValue"
              }

          - monitorsValue
          path: pathValue
          readOnly: true
          secretFile: secretFileValue
          secretRef:
            name: nameValue
          user: userValue
        cinder:
          fsType: fsTypeValue
          readOnly: true
          secretRef:
            name: nameValue
          volumeID: volumeIDValue
        configMap:
          defaultMode: 3
          items: