Function checkSourceCompatability

pindex_bleve.go:3208–3254

----------------------------------------------------------------------------- This API determines if the sourceName provided within the index definition is compatible for FTS indexes by obtaining bucket information from the /pools/default/bucket/{bucketName} endpoint.

(mgr *cbgt.Manager, sourceName string)

// definition is compatible for FTS indexes by obtaining bucket
// information from the /pools/default/bucket/{bucketName} endpoint.
func checkSourceCompatability(mgr *cbgt.Manager, sourceName string) error {
	if mgr == nil {
		return nil
	}

	if len(sourceName) == 0 {
		return fmt.Errorf("source name not provided")
	}

	url := mgr.Server() + "/pools/default/buckets/" + url.QueryEscape(sourceName)
	u, err := cbgt.CBAuthURL(url)
	if err != nil {
		return err
	}

	resp, err := HttpGet(cbgt.HttpClient(), u)
	if err != nil {
		return err
	}
	defer resp.Body.Close()

	respBuf, err := ioutil.ReadAll(resp.Body)
	if err != nil {
		return err
	}

	rv := struct {
		BucketType     string `json:"bucketType"`
		StorageBackend string `json:"storageBackend"`
	}{}

	err = UnmarshalJSON(respBuf, &rv)
	if err != nil {
		return err
	}

	if rv.BucketType != "membase" && rv.BucketType != "ephemeral" {
		return fmt.Errorf("unsupported bucket type")
	}

	if rv.BucketType == "membase" && rv.StorageBackend != "couchstore" {
		return fmt.Errorf("unsupported storage/backend for bucket: %v",
			rv.StorageBackend)
	}

	return nil
}