debugger

Documentation

Index

• Variables
• type Cache
  • func (cache *Cache[E]) ReadAndPopData(key string) []E
  • func (cache *Cache[E]) Update(key string, value E)
• type Transformer
• type TransformerAny
• type Uploader
  • func New[E any](url string, transformer Transformer[E]) Uploader[E]

Variables

var (
	Http sysUtils.HttpI = sysUtils.NewHttp()
)

Types

type Cache

type Cache[E any] 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[E]) ReadAndPopData

func (cache *Cache[E]) ReadAndPopData(key string) []E

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

func (*Cache[E]) Update

func (cache *Cache[E]) Update(key string, value E)

Update Inserts the data in the cache, This method expects a string as a key and []byte as the data

type Transformer

type Transformer[E any] interface {
	Transform(data []E) ([]byte, error)
}

type TransformerAny

type TransformerAny interface {
	Transformer[any]
}

type Uploader

type Uploader[E any] interface {
	Start()
	Stop()
	RecordEvent(data E)
}

func New

func New[E any](url string, transformer Transformer[E]) Uploader[E]