sourcedebugger

package
v1.8.0-rc.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 9, 2023 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var WithDisableEventUploads = func(disableEventUploads bool) func(h *Handle) {
	return func(h *Handle) {
		h.disableEventUploads = disableEventUploads
	}
}

Functions

This section is empty.

Types

type EventUploadBatchT

type EventUploadBatchT struct {
	WriteKey   string
	ReceivedAt string
	Batch      []EventUploadT
}

EventUploadBatchT is a structure to hold batch of events

type EventUploadT

type EventUploadT map[string]interface{}

EventUploadT is a structure to hold actual event data

type EventUploader

type EventUploader struct {
	// contains filtered or unexported fields
}

func NewEventUploader added in v1.6.0

func NewEventUploader(log logger.Logger) *EventUploader

func (*EventUploader) Transform

func (e *EventUploader) Transform(eventBuffer []*GatewayEventBatchT) ([]byte, error)

type GatewayEventBatchT

type GatewayEventBatchT struct {
	WriteKey   string
	EventBatch []byte
}

GatewayEventBatchT is a structure to hold batch of events

type Handle added in v1.6.0

type Handle struct {
	// contains filtered or unexported fields
}

func (*Handle) RecordEvent added in v1.6.0

func (h *Handle) RecordEvent(writeKey string, eventBatch []byte) bool

RecordEvent is used to put the event batch in the eventBatchChannel, which will be processed by handleEvents.

func (*Handle) Stop added in v1.6.0

func (h *Handle) Stop()

type Opt added in v1.6.0

type Opt func(*Handle)

type SourceDebugger added in v1.6.0

type SourceDebugger interface {
	RecordEvent(writeKey string, eventBatch []byte) bool
	Stop()
}

func NewHandle added in v1.6.0

func NewHandle(backendConfig backendconfig.BackendConfig, opts ...Opt) (SourceDebugger, error)

func NewNoOpService added in v1.6.0

func NewNoOpService() SourceDebugger

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL