Used by admin worker

************************************************** * Function to get record and do needed validation ***********************************************

func (m *OperationalMessage) SetValue(value []byte) { m.value = value } func (m *OperationalMessage) GetValue() []byte { return m.value }

Merge merges the properties from another Config When merging the properties, the keys are considered as case insensitive. The value for the same key w

Return true if it has completed all the SS requests and can be cached

Note: read timeout is set at conn level

ReadFrom reads configuration properties i, which pointing to a struct or a map

ReadFromTomlBytes reads configuration properties from byte array in TOML format

called by processors, in different go routines/threads

* func TestRingSameRateSync(t *testing.T) { N := 10000 idCh := make(chan uint32, N) rb := NewSyncRingBuffer(1023) var wg sync.WaitGroup wg.Add(2

Keys expired before this are skipped. Keys modified after modTimeEnd are skipped.

Modified after this are skipped.

write redistribution info

WriteTo writes the configuration properties to a struct or map

This method creates the Juno operation protocol message object @param junoMsg - Juno Message object @param opaque - To identify a request @return Oper