ingester

Jan 6, 2021

Changes in this version

type Ingester

+ func (i *Ingester) SendEmptyIngestion()

Nov 27, 2020

Changes in this version

type IngestionDataRequest

+ ID string

Nov 20, 2020

Changes in this version

type GroupStrategy

+ func (gs *GroupStrategy) Activate()

type Ingester

+ func (i *Ingester) Activate()

Sep 1, 2020

Changes in this version

+ type GroupStrategy struct

+ func NewGroupStrategy(sdkInfo *core.SDKInfo, httpRequest HttpRequest) *GroupStrategy

+ func (gs *GroupStrategy) Publish(data *IngestionDataRequest)

+ func (gs *GroupStrategy) SetConfig(sdkConfig *core.SDKConfig)

+ func (gs *GroupStrategy) SetURL(ingestionURL string)

+ func (gs *GroupStrategy) ShutdownWithTimeout(timeout time.Duration) bool

+ type HttpRequest func(data []byte, ingestionURL string) error

+ type Ingester struct

+ func NewIngester(sdkInfo *core.SDKInfo) *Ingester

+ func (i *Ingester) Publish(entity *core.Entity)

+ func (i *Ingester) PublishExposure(exposure *core.Exposure, isNewFlag bool)

+ func (i *Ingester) SetConfig(v *core.SDKConfig)

+ func (i *Ingester) SetEntity(entity *core.Entity)

+ func (i *Ingester) SetURL(ingestionURL string)

+ func (i *Ingester) Shutdown(timeout time.Duration) bool

+ func (i *Ingester) Track(event *core.Event)

+ type IngestionDataRequest struct

+ DetectedFlags []string

+ Entities []*core.Entity

+ Events []*core.Event

+ Exposures []*core.Exposure

+ Id string

+ SDKInfo *core.SDKInfo

+ type QueueElement struct

+ type RetryPolicy struct

+ func NewRetryPolicy() *RetryPolicy

+ func (rt *RetryPolicy) SetMaxSize(maxMemorySizeInBytes int64)

+ type RetryPolicyCallback func(err error)

+ type RetryPolicyRequest struct