Versions in this module Expand all Collapse all v3 v3.1.0 Apr 14, 2021 Changes in this version + const MaxAccumulatedBytes + var ErrorMaxSizeReached = errors.New("Queue max size has been reached") + type MQEventsStorage struct + func NewMQEventsStorage(queueSize int, isFull chan string, logger logging.LoggerInterface, ...) *MQEventsStorage + func (s *MQEventsStorage) Count() int64 + func (s *MQEventsStorage) Drop(size *int64) error + func (s *MQEventsStorage) Empty() bool + func (s *MQEventsStorage) PopN(n int64) ([]dtos.EventDTO, error) + func (s *MQEventsStorage) PopNWithMetadata(n int64) ([]dtos.QueueStoredEventDTO, error) + func (s *MQEventsStorage) Push(event dtos.EventDTO, size int) error + type MQImpressionsStorage struct + func NewMQImpressionsStorage(queueSize int, isFull chan<- string, logger logging.LoggerInterface, ...) *MQImpressionsStorage + func (s *MQImpressionsStorage) Count() int64 + func (s *MQImpressionsStorage) Drop(size *int64) error + func (s *MQImpressionsStorage) Empty() bool + func (s *MQImpressionsStorage) LogImpressions(impressions []dtos.Impression) error + func (s *MQImpressionsStorage) PopN(n int64) ([]dtos.Impression, error) + func (s *MQImpressionsStorage) PopNWithMetadata(n int64) ([]dtos.ImpressionQueueObject, error) Other modules containing this package github.com/splitio/go-split-commons/v4 github.com/splitio/go-split-commons/v5 github.com/splitio/go-split-commons/v6 github.com/splitio/go-split-commons/v7 github.com/splitio/go-split-commons/v8
Go to main page