Documentation
¶
Index ¶
- Variables
- func RegisterTSDSDBEngine(name string, nsDbEngine TSDSDBEngine)
- type Namespace
- func (namespace *Namespace) Configure(namespaceType golkeyvalNS.NSDBEngine)
- func (namespace *Namespace) DelKey(key string) bool
- func (namespace *Namespace) DeleteNSRecursive(key string) bool
- func (namespace *Namespace) DeleteTSDS(key string) bool
- func (namespace *Namespace) GetVal(key string) string
- func (namespace *Namespace) KeyAndTimeBothNameSpace(key string, key_time goltime.Timestamp) (string, string)
- func (namespace *Namespace) KeyNameSpaceWithTime(key string, key_time goltime.Timestamp) string
- func (namespace *Namespace) PushKeyVal(key string, val string) bool
- func (namespace *Namespace) PushNS(key string, val string) bool
- func (namespace *Namespace) PushNowTSDS(key string, val string) bool
- func (namespace *Namespace) PushNowTSDS_BaseBoth(key string, val string) (status bool)
- func (namespace *Namespace) PushNowTSDS_BaseKey(key string, val string) bool
- func (namespace *Namespace) PushNowTSDS_BaseTime(key string, val string) bool
- func (namespace *Namespace) PushTSDS(key string, val string, key_time goltime.Timestamp) bool
- func (namespace *Namespace) PushTSDS_BaseBoth(key string, val string, key_time goltime.Timestamp) (status bool)
- func (namespace *Namespace) PushTSDS_BaseKey(key string, val string, key_time goltime.Timestamp) bool
- func (namespace *Namespace) PushTSDS_BaseTime(key string, val string, key_time goltime.Timestamp) bool
- func (namespace *Namespace) ReadNSRecursive(key string) golhashmap.HashMap
- func (namespace *Namespace) ReadTSDS(key string) golhashmap.HashMap
- func (namespace *Namespace) TimeKeyPart(key_time goltime.Timestamp) string
- func (namespace *Namespace) TimeNameSpaceWithKey(key string, key_time goltime.Timestamp) string
- type TSDSDBEngine
Constants ¶
This section is empty.
Variables ¶
var TSDSDBEngines = make(map[string]TSDSDBEngine)
DBEngines acts as map for all available db-engines.
Functions ¶
func RegisterTSDSDBEngine ¶
func RegisterTSDSDBEngine(name string, nsDbEngine TSDSDBEngine)
RegisterDBEngine gets used by adapters to register themselves.
Types ¶
type Namespace ¶
type Namespace struct {
// contains filtered or unexported fields
}
func (*Namespace) Configure ¶
func (namespace *Namespace) Configure(namespaceType golkeyvalNS.NSDBEngine)
func (*Namespace) DeleteNSRecursive ¶
func (*Namespace) DeleteTSDS ¶
Returns status to delete Recursive-Namespaced data under given key, Proxy TSDS The desried Time-frame shall be as namespace-d key
func (*Namespace) KeyAndTimeBothNameSpace ¶
func (namespace *Namespace) KeyAndTimeBothNameSpace(key string, key_time goltime.Timestamp) (string, string)
Return KeyNameSpaceWithTime and TimeNameSpaceWithKey as multi-return set
func (*Namespace) KeyNameSpaceWithTime ¶
Return string of Namespace-d Key with Time-Namespace under it
func (*Namespace) PushNowTSDS ¶
Returns Push status for TimeSeries data-store for a key-val for time of key-creation Default is Key Namespace-d with Time-Namespace under it
func (*Namespace) PushNowTSDS_BaseBoth ¶
Returns Push status for TimeSeries data-store for a key-val for time of key-creation Both Key and Timestamp base key-vals are creaed
func (*Namespace) PushNowTSDS_BaseKey ¶
Returns Push status for Key Namespace-d with Time-Namespace under it for time of key-creation
func (*Namespace) PushNowTSDS_BaseTime ¶
Returns Push status for Time-Namespace with Key Namespace-d under it for time of key-creation
func (*Namespace) PushTSDS ¶
Returns Push status for TimeSeries data-store for a key-val for given timestamp Default is Key Namespace-d with Time-Namespace under it
func (*Namespace) PushTSDS_BaseBoth ¶
func (namespace *Namespace) PushTSDS_BaseBoth(key string, val string, key_time goltime.Timestamp) (status bool)
Returns Push status for TimeSeries data-store for a key-val for given timestamp Both Key and Timestamp base key-vals are creaed
func (*Namespace) PushTSDS_BaseKey ¶
func (namespace *Namespace) PushTSDS_BaseKey(key string, val string, key_time goltime.Timestamp) bool
Returns Push status for Key Namespace-d with Time-Namespace under it for given Timestamp
func (*Namespace) PushTSDS_BaseTime ¶
func (namespace *Namespace) PushTSDS_BaseTime(key string, val string, key_time goltime.Timestamp) bool
Returns Push status for Time-Namespace with Key Namespace-d under it for given Timestamp
func (*Namespace) ReadNSRecursive ¶
func (namespace *Namespace) ReadNSRecursive(key string) golhashmap.HashMap
func (*Namespace) ReadTSDS ¶
func (namespace *Namespace) ReadTSDS(key string) golhashmap.HashMap
Returns Recursive-Namespaced data under given key, Proxy TSDS The desried Time-frame shall be as namespace-d key
func (*Namespace) TimeKeyPart ¶
Return string of Namespace-d Time-Value for NS-Key
type TSDSDBEngine ¶
type TSDSDBEngine interface {
Configure(namespaceType golkeyvalNS.NSDBEngine)
PushTSDS(key string, val string, tyme goltime.Timestamp) bool
PushNowTSDS(key string, val string) bool
ReadTSDS(key string) golhashmap.HashMap
DeleteTSDS(key string) bool
// golkeyval proxy func
PushNS(key string, val string) bool
ReadNSRecursive(key string) golhashmap.HashMap
DeleteNSRecursive(key string) bool
PushKeyVal(key string, val string) bool
GetVal(key string) string
DelKey(key string) bool
}
DBEngine interface enables adapter feature for a key-val oriented DB.
func GetNamespaceEngine ¶
func GetNamespaceEngine(config map[string]string) TSDSDBEngine
GetDBEngine gets used by client to fetch a 'namespace' db-engine. parameter: Config with DBEngine, NSEngine, DBPath
func GetTSDSDBEngine ¶
func GetTSDSDBEngine(name string) TSDSDBEngine
GetDBEngine gets used by client to fetch a required db-engine.
Source Files