memap

package
v1.0.8 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 2, 2021 License: Apache-2.0 Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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,

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.