whisk/shared.go

/*
 * Licensed to the Apache Software Foundation (ASF) under one or more
 * contributor license agreements.  See the NOTICE file distributed with
 * this work for additional information regarding copyright ownership.
 * The ASF licenses this file to You under the Apache License, Version 2.0
 * (the "License"); you may not use this file except in compliance with
 * the License.  You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * 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 whisk

import (
	"encoding/json"
	"strings"
)

type KeyValue struct {
	Key   string      `json:"key"`
	Value interface{} `json:"value"`
}

type KeyValueArr []KeyValue

/*
Retrieves a value associated with a given key from a KeyValueArr. A key of type string must be passed to the method.
An interface will be returned containing the found value. If a key could not be found, a nil value will be returned.
*/
func (keyValueArr KeyValueArr) GetValue(key string) (res interface{}) {
	for i := 0; i < len(keyValueArr); i++ {
		if keyValueArr[i].Key == key {
			res = keyValueArr[i].Value
			break
		}
	}

	Debug(DbgInfo, "Got value '%v' for key '%s' from '%v'\n", res, key, keyValueArr)

	return res
}

func (keyValueArr KeyValueArr) FindKeyValue(key string) int {
	for i := 0; i < len(keyValueArr); i++ {
		if strings.ToLower(keyValueArr[i].Key) == strings.ToLower(key) {
			return i
		}
	}

	return -1
}

/*
 * Adds the specified KeyValue to the key value array.  If the KeyValue's key
 * is already in the array, that entry is updated with the KeyValue's value.
 *
 * Returns a new key value array with the update
 */
func (keyValueArr KeyValueArr) AddOrReplace(kv *KeyValue) KeyValueArr {
	var replaced = false
	for i := 0; i < len(keyValueArr); i++ {
		if strings.ToLower(keyValueArr[i].Key) == strings.ToLower(kv.Key) {
			keyValueArr[i].Value = kv.Value
			replaced = true
		}
	}
	if !replaced {
		return append(keyValueArr, *kv)
	}
	return keyValueArr
}

/*
Appends items from appKeyValueArr to keyValueArr if the appKeyValueArr item does not exist in keyValueArr.
*/
func (keyValueArr KeyValueArr) AppendKeyValueArr(appKeyValueArr KeyValueArr) KeyValueArr {
	for i := 0; i < len(appKeyValueArr); i++ {
		if KeyValueArr.FindKeyValue(keyValueArr, appKeyValueArr[i].Key) == -1 {
			keyValueArr = append(keyValueArr, appKeyValueArr[i])
		}
	}

	return keyValueArr
}

type Annotations []map[string]interface{}

type Parameters *json.RawMessage

type Limits struct {
	Timeout     *int `json:"timeout,omitempty"`
	Memory      *int `json:"memory,omitempty"`
	Logsize     *int `json:"logs,omitempty"`
	Concurrency *int `json:"concurrency,omitempty"`
}