Versions in this module Expand all Collapse all v8 v8.0.0 Nov 10, 2025 Changes in this version + func NewCleanFilterTask(filter storage.Filter, logger logging.LoggerInterface, period int) *asynctask.AsyncTask + func NewFetchLargeSegmentsTask(fetcher largesegment.Updater, splitStorage storage.SplitStorageConsumer, ...) *asynctask.AsyncTask + func NewFetchSegmentsTask(fetcher segment.Updater, period int, workerCount int, queueSize int, ...) *asynctask.AsyncTask + func NewFetchSplitsTask(fetcher split.Updater, period int, logger logging.LoggerInterface) *asynctask.AsyncTask + func NewRecordImpressionsCountTask(recorder impressionscount.ImpressionsCountRecorder, ...) *asynctask.AsyncTask + func NewRecordTelemetryTask(recorder telemetry.TelemetrySynchronizer, period int, ...) *asynctask.AsyncTask + func NewRecordUniqueKeysTask(recorder telemetry.TelemetrySynchronizer, ...) *asynctask.AsyncTask + type MultipleTask struct + func (m MultipleTask) IsRunning() bool + func (m MultipleTask) Start() + func (m MultipleTask) Stop(blocking bool) error + type SegmentWorker struct + func NewSegmentWorker(name string, failureTime int64, logger logging.LoggerInterface, ...) *SegmentWorker + func (w *SegmentWorker) Cleanup() error + func (w *SegmentWorker) DoWork(msg interface{}) error + func (w *SegmentWorker) FailureTime() int64 + func (w *SegmentWorker) Name() string + func (w *SegmentWorker) OnError(e error) + type Task interface + IsRunning func() bool + Start func() + Stop func(blocking bool) error + func NewRecordEventsTask(synchronizer event.EventRecorder, bulkSize int64, period int, ...) Task + func NewRecordEventsTasks(recorder event.EventRecorder, bulkSize int64, period int, ...) Task + func NewRecordImpressionsTask(recorder impression.ImpressionRecorder, period int, ...) Task + func NewRecordImpressionsTasks(recorder impression.ImpressionRecorder, period int, ...) Task Other modules containing this package github.com/splitio/go-split-commons/v2 github.com/splitio/go-split-commons/v3 github.com/splitio/go-split-commons/v4 github.com/splitio/go-split-commons/v5 github.com/splitio/go-split-commons/v6
Go to main page