batched

Documentation

Index

• type Data
  • func NewData(defaultTimeWindowInHours int) *Data
  • func (d *Data) AddSourceEvent(in SourceEvent)
  • func (d *Data) HeartbeatProperties() HeartbeatProperties
  • func (d *Data) IncrementTimeWindowInHours()
  • func (d *Data) Reset()
• type HeartbeatProperties
• type SourceEvent
• type SourceProperties

Types

type Data

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

Data is a struct that holds data for batched reporting

func NewData

func NewData(defaultTimeWindowInHours int) *Data

func (*Data) AddSourceEvent

func (d *Data) AddSourceEvent(in SourceEvent)

func (*Data) HeartbeatProperties

func (d *Data) HeartbeatProperties() HeartbeatProperties

func (*Data) IncrementTimeWindowInHours

func (d *Data) IncrementTimeWindowInHours()

func (*Data) Reset

func (d *Data) Reset()

type HeartbeatProperties

type HeartbeatProperties struct {
	TimeWindowInHours int                         `json:"timeWindowInHours"`
	EventsCount       int                         `json:"eventsCount"`
	Sources           map[string]SourceProperties `json:"sources"`
}

type SourceEvent

type SourceEvent struct {
	IntegrationType       config.IntegrationType         `json:"integrationType"`
	Platform              config.CommPlatformIntegration `json:"platform"`
	PluginName            string                         `json:"pluginName"`
	AnonymizedEventFields map[string]any                 `json:"anonymizedEventFields"`
	Success               bool                           `json:"success"`
	Error                 *string                        `json:"error"`
}

type SourceProperties

type SourceProperties struct {
	EventsCount int           `json:"eventsCount"`
	Events      []SourceEvent `json:"events"`
}