telemetry

Jul 29, 2021

Changes in this version

type Count

+ ForceIntervalValid bool

type Summary

+ ForceIntervalValid bool

May 7, 2021

Changes in this version

+ func BuildSplitRequests(batches []Batch, factory RequestFactory) ([]*http.Request, error)

type MapEntry

+ func NewEventGroup(events []Event) MapEntry

Apr 2, 2021

Changes in this version

+ type Batch = []MapEntry

type ClientOption

+ func WithLicenseKey(licenseKey string) ClientOption

+ type LogCommonBlockOption func(*logCommonBlock) error

+ func WithLogAttributes(commonAttributes map[string]interface{}) LogCommonBlockOption

+ type MapEntry interface

+ DataTypeKey func() string

+ WriteDataEntry func(*bytes.Buffer) *bytes.Buffer

+ func NewLogCommonBlock(options ...LogCommonBlockOption) (MapEntry, error)

+ func NewLogGroup(logs []Log) MapEntry

+ func NewMetricCommonBlock(options ...MetricCommonBlockOption) (MapEntry, error)

+ func NewMetricGroup(metrics []Metric) MapEntry

+ func NewSpanCommonBlock(options ...SpanCommonBlockOption) (MapEntry, error)

+ func NewSpanGroup(spans []Span) MapEntry

+ type MetricCommonBlockOption func(block *metricCommonBlock) error

+ func WithMetricAttributes(commonAttributes map[string]interface{}) MetricCommonBlockOption

+ func WithMetricInterval(interval time.Duration) MetricCommonBlockOption

+ func WithMetricTimestamp(startTime time.Time) MetricCommonBlockOption

+ type SpanCommonBlockOption func(scb *spanCommonBlock) error

+ func WithSpanAttributes(commonAttributes map[string]interface{}) SpanCommonBlockOption

Mar 18, 2021

Changes in this version

+ func ConfigLogsURLOverride(url string) func(*Config)

type ClientOption

+ func WithGzipCompressionLevel(level int) ClientOption

type Config

+ LogsURLOverride string

type Harvester

+ func (h *Harvester) RecordLog(l Log) error

+ type Log struct

+ Attributes map[string]interface{}

+ Message string

+ Timestamp time.Time

+ type LogBatch struct

+ Logs []Log

+ func (batch *LogBatch) Bytes() []byte

+ func (batch *LogBatch) Type() string

type RequestFactory

+ func NewLogRequestFactory(options ...ClientOption) (RequestFactory, error)

Mar 2, 2021

Changes in this version

+ func ConfigMetricsURLOverride(url string) func(*Config)

+ type ClientOption func(o *requestFactory)

+ func WithEndpoint(endpoint string) ClientOption

+ func WithInsecure() ClientOption

+ func WithInsertKey(insertKey string) ClientOption

+ func WithNoDefaultKey() ClientOption

+ func WithUserAgent(userAgent string) ClientOption

+ type PayloadEntry interface

+ Bytes func() []byte

+ Type func() string

+ type RequestFactory interface

+ BuildRequest func([]PayloadEntry, ...ClientOption) (*http.Request, error)

+ func NewEventRequestFactory(options ...ClientOption) (RequestFactory, error)

+ func NewMetricRequestFactory(options ...ClientOption) (RequestFactory, error)

+ func NewSpanRequestFactory(options ...ClientOption) (RequestFactory, error)

+ type SpanBatch struct

+ Spans []Span

+ func (batch *SpanBatch) Bytes() []byte

+ func (batch *SpanBatch) Type() string

Nov 19, 2020

Changes in this version

+ func ConfigEventsURLOverride(url string) func(*Config)

type Config

+ EventsURLOverride string

+ type Event struct

+ Attributes map[string]interface{}

+ AttributesJSON json.RawMessage

+ EventType string

+ Timestamp time.Time

type Harvester

+ func (h *Harvester) RecordEvent(e Event) error

type Span

+ Events []Event

Jun 12, 2020

Changes in this version

+ func ConfigSpansURLOverride(url string) func(*Config)

Dec 26, 2019

Changes in this version

type Config

+ Product string

+ ProductVersion string

Sep 18, 2019

Changes in this version

+ func ConfigAPIKey(key string) func(*Config)

+ func ConfigBasicAuditLogger(w io.Writer) func(*Config)

+ func ConfigBasicDebugLogger(w io.Writer) func(*Config)

+ func ConfigBasicErrorLogger(w io.Writer) func(*Config)

+ func ConfigCommonAttributes(attributes map[string]interface{}) func(*Config)

+ func ConfigHarvestPeriod(period time.Duration) func(*Config)

+ type AggregatedCount struct

+ func (c *AggregatedCount) Increase(val float64)

+ func (c *AggregatedCount) Increment()

+ type AggregatedGauge struct

+ func (g *AggregatedGauge) Value(val float64)

+ type AggregatedSummary struct

+ func (s *AggregatedSummary) Record(val float64)

+ func (s *AggregatedSummary) RecordDuration(val time.Duration)

+ type Config struct

+ APIKey string

+ AuditLogger func(map[string]interface{})

+ Client *http.Client

+ CommonAttributes map[string]interface{}

+ DebugLogger func(map[string]interface{})

+ ErrorLogger func(map[string]interface{})

+ HarvestPeriod time.Duration

+ HarvestTimeout time.Duration

+ MetricsURLOverride string

+ SpansURLOverride string

+ type Count struct

+ Attributes map[string]interface{}

+ AttributesJSON json.RawMessage

+ Interval time.Duration

+ Name string

+ Timestamp time.Time

+ Value float64

+ type Gauge struct

+ Attributes map[string]interface{}

+ AttributesJSON json.RawMessage

+ Name string

+ Timestamp time.Time

+ Value float64

+ type Harvester struct

+ func NewHarvester(options ...func(*Config)) (*Harvester, error)

+ func (h *Harvester) HarvestNow(ct context.Context)

+ func (h *Harvester) MetricAggregator() *MetricAggregator

+ func (h *Harvester) RecordMetric(m Metric)

+ func (h *Harvester) RecordSpan(s Span) error

+ type Metric interface

+ type MetricAggregator struct

+ func (ag *MetricAggregator) Count(name string, attributes map[string]interface{}) *AggregatedCount

+ func (ag *MetricAggregator) Gauge(name string, attributes map[string]interface{}) *AggregatedGauge

+ func (ag *MetricAggregator) Summary(name string, attributes map[string]interface{}) *AggregatedSummary

+ type Span struct

+ Attributes map[string]interface{}

+ AttributesJSON json.RawMessage

+ Duration time.Duration

+ ID string

+ Name string

+ ParentID string

+ ServiceName string

+ Timestamp time.Time

+ TraceID string

+ type Summary struct

+ Attributes map[string]interface{}

+ AttributesJSON json.RawMessage

+ Count float64

+ Interval time.Duration

+ Max float64

+ Min float64

+ Name string

+ Sum float64

+ Timestamp time.Time