sourcedebugger

Documentation

Index

• Variables
• type EventUploadBatchT
• type EventUploadT
• type EventUploader
  • func NewEventUploader(log logger.Logger) *EventUploader
  • func (e *EventUploader) Transform(eventBuffer []*GatewayEventBatchT) ([]byte, error)
• type GatewayEventBatchT
• type Handle
  • func (h *Handle) RecordEvent(writeKey string, eventBatch []byte) bool
  • func (h *Handle) Stop()
• type Opt
• type SourceDebugger
  • func NewHandle(backendConfig backendconfig.BackendConfig, opts ...Opt) (SourceDebugger, error)
  • func NewNoOpService() SourceDebugger

Variables

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

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

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

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

func (*Handle) RecordEvent

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

func (h *Handle) Stop()

type Opt

type Opt func(*Handle)

type SourceDebugger

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

func NewHandle

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

func NewNoOpService

func NewNoOpService() SourceDebugger