Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataCollectProcessor ¶
type DataCollectProcessor struct {
// contains filtered or unexported fields
}
func NewDataCollectProcessor ¶
func NewDataCollectProcessor(opts ...DatacollectOptionBuilder) *DataCollectProcessor
func (*DataCollectProcessor) Shutdown ¶ added in v0.0.7
func (d *DataCollectProcessor) Shutdown(ctx context.Context) error
func (*DataCollectProcessor) TrackHits ¶
func (d *DataCollectProcessor) TrackHits(hits connectors.TrackingHits) error
type DatacollectOptionBuilder ¶
type DatacollectOptionBuilder func(*DataCollectProcessor)
func WithBatchOptions ¶
func WithBatchOptions(batchSize int, batchingWindow time.Duration) DatacollectOptionBuilder
func WithHTTPClient ¶
func WithHTTPClient(client *http.Client) DatacollectOptionBuilder
func WithLogLevel ¶
func WithLogLevel(lvl string) DatacollectOptionBuilder
func WithTrackingURL ¶
func WithTrackingURL(url string) DatacollectOptionBuilder
type EmptyHitProcessor ¶
type EmptyHitProcessor struct {
}
func (*EmptyHitProcessor) TrackHits ¶
func (d *EmptyHitProcessor) TrackHits(hits connectors.TrackingHits) error
type MockHitProcessor ¶
type MockHitProcessor struct {
TrackedHits connectors.TrackingHits
}
func (*MockHitProcessor) Shutdown ¶ added in v0.0.7
func (d *MockHitProcessor) Shutdown(context.Context) error
func (*MockHitProcessor) TrackHits ¶
func (d *MockHitProcessor) TrackHits(hits connectors.TrackingHits) error
Source Files
Click to show internal directories.
Click to hide internal directories.