inmem

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.