memap

Documentation

Index

• type BoolMemConcurrentMap
  • func NewBool() BoolMemConcurrentMap
  • func (m BoolMemConcurrentMap) Clear()
  • func (m BoolMemConcurrentMap) Get(key string) (RmHisDbBoolItems, bool)
  • func (m BoolMemConcurrentMap) IterBuffered() <-chan BoolTuple
  • func (m BoolMemConcurrentMap) Remove(key string)
  • func (m BoolMemConcurrentMap) Set(key string, v RmHisDbBoolItems)
  • func (m BoolMemConcurrentMap) Upsert(key, groupName string, value RmHisDbBoolItem)
• type BoolMemConcurrentMapShared
• type BoolTuple
• type FloatMemConcurrentMap
  • func NewFloat() FloatMemConcurrentMap
  • func (m FloatMemConcurrentMap) Clear()
  • func (m FloatMemConcurrentMap) Get(key string) (RmHisDbFloatItems, bool)
  • func (m FloatMemConcurrentMap) IterBuffered() <-chan FloatTuple
  • func (m FloatMemConcurrentMap) Remove(key string)
  • func (m FloatMemConcurrentMap) Set(key string, v RmHisDbFloatItems)
  • func (m FloatMemConcurrentMap) Upsert(key, groupName string, value RmHisDbFloatItem)
• type FloatMemConcurrentMapShared
• type FloatTuple
• type IntMemConcurrentMap
  • func NewInt() IntMemConcurrentMap
  • func (m IntMemConcurrentMap) Clear()
  • func (m IntMemConcurrentMap) Get(key string) (RmHisDbIntItems, bool)
  • func (m IntMemConcurrentMap) IterBuffered() <-chan IntTuple
  • func (m IntMemConcurrentMap) Remove(key string)
  • func (m IntMemConcurrentMap) Set(key string, v RmHisDbIntItems)
  • func (m IntMemConcurrentMap) Upsert(key, groupName string, value RmHisDbIntItem)
• type IntMemConcurrentMapShared
• type IntTuple
• type RmHisDbBoolItem
• type RmHisDbBoolItems
• type RmHisDbFloatItem
• type RmHisDbFloatItems
• type RmHisDbIntItem
• type RmHisDbIntItems
• type RmHisDbStringItem
• type RmHisDbStringItems
• type StringMemConcurrentMap
  • func NewString() StringMemConcurrentMap
  • func (m StringMemConcurrentMap) Clear()
  • func (m StringMemConcurrentMap) Get(key string) (RmHisDbStringItems, bool)
  • func (m StringMemConcurrentMap) IterBuffered() <-chan StringTuple
  • func (m StringMemConcurrentMap) Remove(key string)
  • func (m StringMemConcurrentMap) Set(key string, v RmHisDbStringItems)
  • func (m StringMemConcurrentMap) Upsert(key, groupName string, value RmHisDbStringItem)
• type StringMemConcurrentMapShared
• type StringTuple

Types

type BoolMemConcurrentMap

type BoolMemConcurrentMap []*BoolMemConcurrentMapShared

func NewBool

func NewBool() BoolMemConcurrentMap

func (BoolMemConcurrentMap) Clear

func (m BoolMemConcurrentMap) Clear()

Clear removes all items from map.

func (BoolMemConcurrentMap) Get

func (m BoolMemConcurrentMap) Get(key string) (RmHisDbBoolItems, bool)

func (BoolMemConcurrentMap) IterBuffered

func (m BoolMemConcurrentMap) IterBuffered() <-chan BoolTuple

IterBuffered returns a buffered iterator which could be used in a for range loop.

func (BoolMemConcurrentMap) Remove

func (m BoolMemConcurrentMap) Remove(key string)

Remove removes an element from the map.

func (BoolMemConcurrentMap) Set

func (m BoolMemConcurrentMap) Set(key string, v RmHisDbBoolItems)

func (BoolMemConcurrentMap) Upsert

func (m BoolMemConcurrentMap) Upsert(key, groupName string, value RmHisDbBoolItem)

Upsert Insert or Update - updates existing element or inserts a new one using UpsertCb

type BoolMemConcurrentMapShared

type BoolMemConcurrentMapShared struct {
	sync.RWMutex // Read Write mutex, guards access to internal map.
	// contains filtered or unexported fields
}

BoolMemConcurrentMapShared A "thread" safe string to anything map.

type BoolTuple

type BoolTuple struct {
	Key string
	Val RmHisDbBoolItems
}

BoolTuple Used by the Iter & IterBuffered functions to wrap two variables together over a channel,

type FloatMemConcurrentMap

type FloatMemConcurrentMap []*FloatMemConcurrentMapShared

func NewFloat

func NewFloat() FloatMemConcurrentMap

func (FloatMemConcurrentMap) Clear

func (m FloatMemConcurrentMap) Clear()

Clear removes all items from map.

func (FloatMemConcurrentMap) Get

func (m FloatMemConcurrentMap) Get(key string) (RmHisDbFloatItems, bool)

func (FloatMemConcurrentMap) IterBuffered

func (m FloatMemConcurrentMap) IterBuffered() <-chan FloatTuple

IterBuffered returns a buffered iterator which could be used in a for range loop.

func (FloatMemConcurrentMap) Remove

func (m FloatMemConcurrentMap) Remove(key string)

Remove removes an element from the map.

func (FloatMemConcurrentMap) Set

func (m FloatMemConcurrentMap) Set(key string, v RmHisDbFloatItems)

func (FloatMemConcurrentMap) Upsert

func (m FloatMemConcurrentMap) Upsert(key, groupName string, value RmHisDbFloatItem)

Upsert Insert or Update - updates existing element or inserts a new one using UpsertCb

type FloatMemConcurrentMapShared

type FloatMemConcurrentMapShared struct {
	sync.RWMutex // Read Write mutex, guards access to internal map.
	// contains filtered or unexported fields
}

FloatMemConcurrentMapShared A "thread" safe string to anything map.

type FloatTuple

type FloatTuple struct {
	Key string
	Val RmHisDbFloatItems
}

FloatTuple Used by the Iter & IterBuffered functions to wrap two variables together over a channel,

type IntMemConcurrentMap

type IntMemConcurrentMap []*IntMemConcurrentMapShared

func NewInt

func NewInt() IntMemConcurrentMap

func (IntMemConcurrentMap) Clear

func (m IntMemConcurrentMap) Clear()

Clear removes all items from map.

func (IntMemConcurrentMap) Get

func (m IntMemConcurrentMap) Get(key string) (RmHisDbIntItems, bool)

func (IntMemConcurrentMap) IterBuffered

func (m IntMemConcurrentMap) IterBuffered() <-chan IntTuple

IterBuffered returns a buffered iterator which could be used in a for range loop.

func (IntMemConcurrentMap) Remove

func (m IntMemConcurrentMap) Remove(key string)

Remove removes an element from the map.

func (IntMemConcurrentMap) Set

func (m IntMemConcurrentMap) Set(key string, v RmHisDbIntItems)

func (IntMemConcurrentMap) Upsert

func (m IntMemConcurrentMap) Upsert(key, groupName string, value RmHisDbIntItem)

Upsert Insert or Update - updates existing element or inserts a new one using UpsertCb

type IntMemConcurrentMapShared

type IntMemConcurrentMapShared struct {
	sync.RWMutex // Read Write mutex, guards access to internal map.
	// contains filtered or unexported fields
}

IntMemConcurrentMapShared A "thread" safe string to anything map.

type IntTuple

type IntTuple struct {
	Key string
	Val RmHisDbIntItems
}

IntTuple Used by the Iter & IterBuffered functions to wrap two variables together over a channel,

type RmHisDbBoolItem

type RmHisDbBoolItem struct {
	TimeStamp int32
	Value     bool
}

type RmHisDbBoolItems

type RmHisDbBoolItems struct {
	GroupName  string
	TimeStamps []int32 // timeStamps
	Values     []bool  // values
}

type RmHisDbFloatItem

type RmHisDbFloatItem struct {
	TimeStamp int32
	Value     float32
}

type RmHisDbFloatItems

type RmHisDbFloatItems struct {
	GroupName  string
	TimeStamps []int32   // timeStamps
	Values     []float32 // values
}

type RmHisDbIntItem

type RmHisDbIntItem struct {
	TimeStamp int32
	Value     int32
}

type RmHisDbIntItems

type RmHisDbIntItems struct {
	GroupName  string
	TimeStamps []int32 // timeStamps
	Values     []int32 // values
}

type RmHisDbStringItem

type RmHisDbStringItem struct {
	TimeStamp int32
	Value     string
}

type RmHisDbStringItems

type RmHisDbStringItems struct {
	GroupName  string
	TimeStamps []int32  // timeStamps
	Values     []string // values
}

type StringMemConcurrentMap

type StringMemConcurrentMap []*StringMemConcurrentMapShared

func NewString

func NewString() StringMemConcurrentMap

func (StringMemConcurrentMap) Clear

func (m StringMemConcurrentMap) Clear()

Clear removes all items from map.

func (StringMemConcurrentMap) Get

func (m StringMemConcurrentMap) Get(key string) (RmHisDbStringItems, bool)

func (StringMemConcurrentMap) IterBuffered

func (m StringMemConcurrentMap) IterBuffered() <-chan StringTuple

IterBuffered returns a buffered iterator which could be used in a for range loop.

func (StringMemConcurrentMap) Remove

func (m StringMemConcurrentMap) Remove(key string)

Remove removes an element from the map.

func (StringMemConcurrentMap) Set

func (m StringMemConcurrentMap) Set(key string, v RmHisDbStringItems)

func (StringMemConcurrentMap) Upsert

func (m StringMemConcurrentMap) Upsert(key, groupName string, value RmHisDbStringItem)

Upsert Insert or Update - updates existing element or inserts a new one using UpsertCb

type StringMemConcurrentMapShared

type StringMemConcurrentMapShared struct {
	sync.RWMutex // Read Write mutex, guards access to internal map.
	// contains filtered or unexported fields
}

StringMemConcurrentMapShared A "thread" safe string to anything map.

type StringTuple

type StringTuple struct {
	Key string
	Val RmHisDbStringItems
}

StringTuple Used by the Iter & IterBuffered functions to wrap two variables together over a channel,