dbtasks_push.go

package goshare

import "strings"

/*
PushKeyVal pushes a given set of Key-Val.
*/
func PushKeyVal(key string, val string) bool {
	return tsds.PushKeyVal(key, val)
}

/*
PushKeyValNS pushes a given Namespace-Key and its value.
*/
func PushKeyValNS(key string, val string) bool {
	return tsds.PushNS(key, val)
}

/*
PushKeyValNowTSDS pushes a key namespace-d with current time.
*/
func PushKeyValNowTSDS(key string, val string) bool {
	return tsds.PushNowTSDS(key, val)
}

/*
PushKeyValTSDS pushes a key namespace-d with goltime.Timestamp.
*/
func PushKeyValTSDS(packet Packet) bool {
	status := true
	for _key, _val := range packet.HashMap {
		_val = strings.Replace(_val, "\n", " ", -1)
		status = status && tsds.PushTSDS(_key, _val, packet.TimeDot)
	}
	return status
}

/*
PushFuncByKeyType returns func handle according to KeyType.
*/
func PushFuncByKeyType(keyType string) FunkAxnParamKeyVal {
	switch keyType {
	case "now":
		return PushKeyValNowTSDS

	case "ns":
		return PushKeyValNS

	default:
		return PushKeyVal

	}
}

/*
PushFromPacket handles push task based on provided Packet.
*/
func PushFromPacket(packet Packet) bool {
	status := true
	switch packet.KeyType {
	case "tsds":
		PushKeyValTSDS(packet)

	default:
		axnFunk := PushFuncByKeyType(packet.KeyType)
		for _key, _val := range packet.HashMap {
			_val = strings.Replace(_val, "\n", " ", -1)
			status = status && axnFunk(_key, _val)
		}
	}

	return status
}