Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var (
Http sysUtils.HttpI = sysUtils.NewHttp()
)
Functions ¶
This section is empty.
Types ¶
type Cache ¶
type Cache struct {
KeyTTL time.Duration // Time after which the data will be expired and removed from the cache
CleanupFreq time.Duration // This is the time at which a cleaner goroutines checks whether the data is expired in cache
Size int // This is the size upto which this cache can store a value corresponding to any key
// contains filtered or unexported fields
}
Cache is an in-memory cache. Each key-value pair stored in this cache have a TTL and one goroutine removes the
key-value pair form the cache which is older than TTL time.
func (*Cache) ReadAndPopData ¶
ReadAndPopData reads the data by taking a string key,
if there is any data available corresponding to the given key then it removes the data from the cache and returns it in the form of []byte
type Transformer ¶
type Uploader ¶
type Uploader struct {
Client sysUtils.HTTPClientI
// contains filtered or unexported fields
}
func (*Uploader) RecordEvent ¶
func (uploader *Uploader) RecordEvent(data interface{})
RecordEvent is used to put the event batch in the eventBatchChannel, which will be processed by handleEvents.
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.