inmem

Documentation

Index

• Constants
• func AddStats(m map[string]string)
• func UpdateDestinationsConfig(m destination.Map)
• func Write(table string, data []byte, rowBinary bool) error

Constants

const (
	ErrCodeBufferOverflow = 200
)

Functions

func AddStats

func AddStats(m map[string]string)

AddStats fills stats keys for inmem storage

func UpdateDestinationsConfig

func UpdateDestinationsConfig(m destination.Map)

UpdateDestinationsConfig accepts destination.Map and starts new flushers if neccessary

func Write

func Write(table string, data []byte, rowBinary bool) error

Write adds data to per-table buffer if there is enough capacity. locks are taken in the following order:

• map.RLock()
• el = map[table]
• el.Lock()
• map.RUnlock()
• doSometing(el)
• el.Unlock()

It is done because map is periodically swapped to empty map and we need to ensure that we finished writing to el that was taken after map was unlocked.