kineticaotelexporter

package module
v0.0.36 Latest Latest
Warning

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

 Go to latest Published: Jun 16, 2023 License: MIT Imports: 28 Imported by: 0

README

Kinetica Logo

Website | Docs | Community Slack

Kinetica OpenTelemetry Collector Exporter Plug-In

Overview

The Kinetica OpenTelemetry Collector Exporter plug-in allows easy export of OpenTelemetry data from the Collector to the Kinetica database.

Documentation

Support

For support, you can post on stackoverflow under the kinetica tag or Slack.

Contact Us

Documentation

Index

Constants

View Source 
const (
	MeasurementSpans     = "spans"
	MeasurementSpanLinks = "span-links"
	MeasurementLogs      = "logs"

	// These attribute key names are influenced by the proto message keys.
	AttributeTime                   = "time"
	AttributeStartTimeUnixNano      = "start_time_unix_nano"
	AttributeTraceID                = "trace_id"
	AttributeSpanID                 = "span_id"
	AttributeTraceState             = "trace_state"
	AttributeParentSpanID           = "parent_span_id"
	AttributeParentServiceName      = "parent_service_name"
	AttributeChildServiceName       = "child_service_name"
	AttributeCallCount              = "call_count"
	AttributeSpansQueueDepth        = "spans_queue_depth"
	AttributeSpansDropped           = "spans_dropped"
	AttributeName                   = "name"
	AttributeSpanKind               = "kind"
	AttributeEndTimeUnixNano        = "end_time_unix_nano"
	AttributeDurationNano           = "duration_nano"
	AttributeDroppedAttributesCount = "dropped_attributes_count"
	AttributeDroppedEventsCount     = "dropped_events_count"
	AttributeDroppedLinksCount      = "dropped_links_count"
	AttributeAttributes             = "attributes"
	AttributeLinkedTraceID          = "linked_trace_id"
	AttributeLinkedSpanID           = "linked_span_id"
	AttributeSeverityNumber         = "severity_number"
	AttributeSeverityText           = "severity_text"
	AttributeBody                   = "body"

	LogTable                  = "log"
	LogAttributeTable         = "log_attribute"
	LogResourceAttributeTable = "log_resource_attribute"
	LogScopeAttributeTable    = "log_scope_attribute"

	TraceSpanTable              = "trace_span"
	TraceSpanAttributeTable     = "trace_span_attribute"
	TraceResourceAttributeTable = "trace_resource_attribute"
	TraceScopeAttributeTable    = "trace_scope_attribute"
	TraceEventAttributeTable    = "trace_event_attribute"
	TraceLinkAttributeTable     = "trace_link_attribute"

	GaugeTable                           = "metric_gauge"
	GaugeDatapointTable                  = "metric_gauge_datapoint"
	GaugeDatapointAttributeTable         = "metric_gauge_datapoint_attribute"
	GaugeDatapointExemplarTable          = "metric_gauge_datapoint_exemplar"
	GaugeDatapointExemplarAttributeTable = "metric_gauge_datapoint_exemplar_attribute"
	GaugeResourceAttributeTable          = "metric_gauge_resource_attribute"
	GaugeScopeAttributeTable             = "metric_gauge_scope_attribute"

	SumTable                           = "metric_sum"
	SumResourceAttributeTable          = "metric_sum_resource_attribute"
	SumScopeAttributeTable             = "metric_sum_scope_attribute"
	SumDatapointTable                  = "metric_sum_datapoint"
	SumDatapointAttributeTable         = "metric_sum_datapoint_attribute"
	SumDatapointExemplarTable          = "metric_sum_datapoint_exemplar"
	SumDataPointExemplarAttributeTable = "metric_sum_datapoint_exemplar_attribute"

	HistogramTable = "metric_histogram"
	// HistogramAttributeTable                  = "metric_histogram_attribute"
	HistogramResourceAttributeTable          = "metric_histogram_resource_attribute"
	HistogramScopeAttributeTable             = "metric_histogram_scope_attribute"
	HistogramDatapointTable                  = "metric_histogram_datapoint"
	HistogramDatapointAttributeTable         = "metric_histogram_datapoint_attribute"
	HistogramBucketCountsTable               = "metric_histogram_datapoint_bucket_count"
	HistogramExplicitBoundsTable             = "metric_histogram_datapoint_explicit_bound"
	HistogramDatapointExemplarTable          = "metric_histogram_datapoint_exemplar"
	HistogramDataPointExemplarAttributeTable = "metric_histogram_datapoint_exemplar_attribute"

	ExpHistogramTable = "metric_exp_histogram"
	// ExpHistogramAttributeTable                  = "metric_exp_histogram_attribute"
	ExpHistogramResourceAttributeTable          = "metric_exp_histogram_resource_attribute"
	ExpHistogramScopeAttributeTable             = "metric_exp_histogram_scope_attribute"
	ExpHistogramDatapointTable                  = "metric_exp_histogram_datapoint"
	ExpHistogramDatapointAttributeTable         = "metric_exp_histogram_datapoint_attribute"
	ExpHistogramPositiveBucketCountsTable       = "metric_exp_histogram_datapoint_bucket_positive_count"
	ExpHistogramNegativeBucketCountsTable       = "metric_exp_histogram_datapoint_bucket_negative_count"
	ExpHistogramDatapointExemplarTable          = "metric_exp_histogram_datapoint_exemplar"
	ExpHistogramDataPointExemplarAttributeTable = "metric_exp_histogram_datapoint_exemplar_attribute"

	SummaryTable = "metric_summary"
	// SummaryAttributeTable              = "metric_summary_attribute"
	SummaryResourceAttributeTable      = "metric_summary_resource_attribute"
	SummaryScopeAttributeTable         = "metric_summary_scope_attribute"
	SummaryDatapointTable              = "metric_summary_datapoint"
	SummaryDatapointAttributeTable     = "metric_summary_datapoint_attribute"
	SummaryDatapointQuantileValueTable = "metric_summary_datapoint_quantile_values"

	ChunkSize = 10000
)
View Source 
const (
	InsertLog string = `` /* 215-byte string literal not displayed */

	InsertLogAttribute string = `` /* 151-byte string literal not displayed */

	InsertLogResourceAttribute string = `` /* 165-byte string literal not displayed */

	InsertLogScopeAttribute string = `` /* 194-byte string literal not displayed */

)

SQL statements to insert log data

View Source 
const (
	InsertTraceSpan string = `` /* 375-byte string literal not displayed */

	InsertTraceSpanAttribute string = `` /* 161-byte string literal not displayed */

	InsertTraceResourceAttribute string = `` /* 169-byte string literal not displayed */

	InsertTraceScopeAttribute string = `` /* 190-byte string literal not displayed */

	InsertTraceEventAttribute string = `` /* 181-byte string literal not displayed */

	InsertTraceLinkAttribute string = `` /* 192-byte string literal not displayed */

)

SQL statements to insert trace data

Variables

This section is empty.

Functions

func AttributeValueToKineticaTagValue 

func AttributeValueToKineticaTagValue(value pcommon.Value) (string, error)

AttributeValueToKineticaTagValue 

@param value
@return string
@return error

func ChunkBySize 

func ChunkBySize[T any](items []T, chunkSize int) [][]T

ChunkBySize - Splits a slice into multiple slices of the given size 

@param items
@param chunkSize
@return [][]T

func ConvertToInterfaceSlice 

func ConvertToInterfaceSlice[T any](items []T) []interface{}

ConvertToInterfaceSlice 

@param items
@return []interface{}

func CreateDefaultConfig 

func CreateDefaultConfig() component.Config

CreateDefaultConfig - function to create a default configuration 

@return component.Config

func GetGpuDbInst 

func GetGpuDbInst(cfg *Config) *gpudb.Gpudb

GetGpuDbInst 

@param cfg
@return *gpudb.Gpudb

func NewFactory 

func NewFactory() exporter.Factory

NewFactory creates a factory for Kinetica exporter. 

@return exporter.Factory

func ValidateStruct 

func ValidateStruct(s interface{}) (err error)

ValidateStruct 

@param s
@return err

Types

type AggregationTemporality 

type AggregationTemporality int

AggregationTemporality - Metrics 

const (
	AggregationTemporalityUnspecified AggregationTemporality = iota
	AggregationTemporalityDelta
	AggregationTemporalityCumulative
)

const - Metrics 

@param AggregationTemporalityUnspecified

type AttributeValue 

type AttributeValue struct {
	IntValue    int     `avro:"int_value"`
	StringValue string  `avro:"string_value"`
	BoolValue   int8    `avro:"bool_value"`
	DoubleValue float64 `avro:"double_value"`
	BytesValue  []byte  `avro:"bytes_value"`
}

AttributeValue

func NewAttributeValue 

func NewAttributeValue(intValue int, stringValue string, boolValue int8, doubleValue float64, bytesValue []byte) *AttributeValue

NewAttributeValue Constructor for AttributeValue 

@param intValue
@param stringValue
@param boolValue
@param doubleValue
@param bytesValue
@return *AttributeValue

func (*AttributeValue) GetBoolValue 

func (attributevalue *AttributeValue) GetBoolValue() int8

GetBoolValue 

@receiver attributevalue
@return int8

func (*AttributeValue) GetBytesValue 

func (attributevalue *AttributeValue) GetBytesValue() []byte

GetBytesValue 

@receiver attributevalue
@return []byte

func (*AttributeValue) GetDoubleValue 

func (attributevalue *AttributeValue) GetDoubleValue() float64

GetDoubleValue 

@receiver attributevalue
@return float64

func (*AttributeValue) GetIntValue 

func (attributevalue *AttributeValue) GetIntValue() int

GetIntValue 

@receiver attributevalue
@return int

func (*AttributeValue) GetStringValue 

func (attributevalue *AttributeValue) GetStringValue() string

GetStringValue 

@receiver attributevalue
@return string

func (*AttributeValue) SetBoolValue 

func (attributevalue *AttributeValue) SetBoolValue(BoolValue int8) *AttributeValue

SetBoolValue 

@receiver attributevalue
@param BoolValue
@return *AttributeValue

func (*AttributeValue) SetBytesValue 

func (attributevalue *AttributeValue) SetBytesValue(BytesValue []byte) *AttributeValue

SetBytesValue 

@receiver attributevalue
@param BytesValue
@return *AttributeValue

func (*AttributeValue) SetDoubleValue 

func (attributevalue *AttributeValue) SetDoubleValue(DoubleValue float64) *AttributeValue

SetDoubleValue 

@receiver attributevalue
@param DoubleValue
@return *AttributeValue

func (*AttributeValue) SetIntValue 

func (attributevalue *AttributeValue) SetIntValue(IntValue int) *AttributeValue

SetIntValue 

@receiver attributevalue
@param IntValue
@return *AttributeValue

func (*AttributeValue) SetStringValue 

func (attributevalue *AttributeValue) SetStringValue(StringValue string) *AttributeValue

SetStringValue 

@receiver attributevalue
@param StringValue
@return *AttributeValue

type Config 

type Config struct {
	Host               string `mapstructure:"host"`
	Schema             string `mapstructure:"schema"`
	Username           string `mapstructure:"username"`
	Password           string `mapstructure:"password"`
	BypassSslCertCheck bool   `mapstructure:"bypasssslcertcheck"`
}

Config defines configuration for the Kinetica exporter.

func (*Config) Validate 

func (cfg *Config) Validate() error

Validate the config 

@receiver cfg
@return error

type EventAttribute 

type EventAttribute struct {
	SpanID         string `avro:"span_id"`
	EventName      string `avro:"event_name"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

EventAttribute

func NewEventAttribute 

func NewEventAttribute(spanID string, eventName string, key string, attributes AttributeValue) *EventAttribute

NewEventAttribute Constructor for TraceEventAttribute 

@param key
@param eventName
@param attributes
@return *TraceEventAttribute

type ExponentialHistogram 

type ExponentialHistogram struct {
	HistogramID            string `avro:"histogram_id"`
	MetricName             string `avro:"metric_name"`
	Description            string `avro:"metric_description"`
	Unit                   string `avro:"metric_unit"`
	AggregationTemporality int8   `avro:"aggregation_temporality"`
}

ExponentialHistogram

type ExponentialHistogramBucketNegativeCount 

type ExponentialHistogramBucketNegativeCount struct {
	HistogramID string `avro:"histogram_id"`
	DatapointID string `avro:"datapoint_id"`
	CountID     string `avro:"count_id"`
	Count       uint64 `avro:"count"`
}

type ExponentialHistogramBucketPositiveCount 

type ExponentialHistogramBucketPositiveCount struct {
	HistogramID string `avro:"histogram_id"`
	DatapointID string `avro:"datapoint_id"`
	CountID     string `avro:"count_id"`
	Count       int64  `avro:"count"`
}

type ExponentialHistogramDataPointAttribute 

type ExponentialHistogramDataPointAttribute struct {
	HistogramID    string `avro:"histogram_id"`
	DatapointID    string `avro:"datapoint_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

type ExponentialHistogramDataPointExemplarAttribute 

type ExponentialHistogramDataPointExemplarAttribute struct {
	HistogramID    string `avro:"histogram_id"`
	DatapointID    string `avro:"datapoint_id"`
	ExemplarID     string `avro:"exemplar_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

HistogramDataPointExemplarAttribute

type ExponentialHistogramDatapoint 

type ExponentialHistogramDatapoint struct {
	HistogramID           string  `avro:"histogram_id"`
	ID                    string  `avro:"id"`
	StartTimeUnix         int64   `avro:"start_time_unix"`
	TimeUnix              int64   `avro:"time_unix"`
	Count                 int64   `avro:"count"`
	Sum                   float64 `avro:"data_sum"`
	Min                   float64 `avro:"data_min"`
	Max                   float64 `avro:"data_max"`
	Flags                 int     `avro:"flags"`
	Scale                 int     `avro:"scale"`
	ZeroCount             int64   `avro:"zero_count"`
	BucketsPositiveOffset int     `avro:"buckets_positive_offset"`
	BucketsNegativeOffset int     `avro:"buckets_negative_offset"`
}

type ExponentialHistogramDatapointExemplar 

type ExponentialHistogramDatapointExemplar struct {
	HistogramID    string  `avro:"histogram_id"`
	DatapointID    string  `avro:"datapoint_id"`
	ExemplarID     string  `avro:"exemplar_id"`
	TimeUnix       int64   `avro:"time_unix"`
	HistogramValue float64 `avro:"histogram_value"`
	TraceID        string  `mapstructure:"trace_id" avro:"trace_id"`
	SpanID         string  `mapstructure:"span_id" avro:"span_id"`
}

type ExponentialHistogramResourceAttribute 

type ExponentialHistogramResourceAttribute struct {
	HistogramID    string `avro:"histogram_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

HistogramResourceAttribute

type ExponentialHistogramScopeAttribute 

type ExponentialHistogramScopeAttribute struct {
	HistogramID    string `avro:"histogram_id"`
	ScopeName      string `avro:"name"`
	ScopeVersion   string `avro:"version"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

HistogramScopeAttribute

type Gauge 

type Gauge struct {
	GaugeID     string `avro:"gauge_id"`
	MetricName  string `avro:"metric_name"`
	Description string `avro:"metric_description"`
	Unit        string `avro:"metric_unit"`
}

Gauge

type GaugeDataPointExemplarAttribute 

type GaugeDataPointExemplarAttribute struct {
	GaugeID        string `avro:"gauge_id"`
	DatapointID    string `avro:"datapoint_id"`
	ExemplarID     string `avro:"exemplar_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

GaugeDataPointExemplarAttribute

type GaugeDatapoint 

type GaugeDatapoint struct {
	GaugeID       string  `avro:"gauge_id"`
	ID            string  `avro:"id"`
	StartTimeUnix int64   `mapstructure:"start_time_unix" avro:"start_time_unix"`
	TimeUnix      int64   `mapstructure:"time_unix" avro:"time_unix"`
	GaugeValue    float64 `mapstructure:"gauge_value" avro:"gauge_value"`
	Flags         int     `mapstructure:"flags" avro:"flags"`
}

GaugeDatapoint

type GaugeDatapointAttribute 

type GaugeDatapointAttribute struct {
	GaugeID        string `avro:"gauge_id"`
	DatapointID    string `avro:"datapoint_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

GaugeDatapointAttribute

type GaugeDatapointExemplar 

type GaugeDatapointExemplar struct {
	GaugeID     string  `avro:"gauge_id"`
	DatapointID string  `avro:"datapoint_id"`
	ExemplarID  string  `avro:"exemplar_id"`
	TimeUnix    int64   `mapstructure:"time_unix" avro:"time_unix"`
	GaugeValue  float64 `mapstructure:"gauge_value" avro:"gauge_value"`
	TraceID     string  `mapstructure:"trace_id" avro:"trace_id"`
	SpanID      string  `mapstructure:"span_id" avro:"span_id"`
}

GaugeDatapointExemplar

type GaugeResourceAttribute 

type GaugeResourceAttribute struct {
	GaugeID        string `avro:"gauge_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

GaugeResourceAttribute

type GaugeScopeAttribute 

type GaugeScopeAttribute struct {
	GaugeID        string `avro:"gauge_id"`
	ScopeName      string `avro:"name"`
	ScopeVersion   string `avro:"version"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

GaugeScopeAttribute

type Histogram 

type Histogram struct {
	HistogramID            string `avro:"histogram_id"`
	MetricName             string `avro:"metric_name"`
	Description            string `avro:"metric_description"`
	Unit                   string `avro:"metric_unit"`
	AggregationTemporality int8   `avro:"aggregation_temporality"`
}

Histogram

type HistogramDataPointAttribute 

type HistogramDataPointAttribute struct {
	HistogramID    string `avro:"histogram_id"`
	DatapointID    string `avro:"datapoint_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

HistogramDataPointAttribute

type HistogramDataPointExemplarAttribute 

type HistogramDataPointExemplarAttribute struct {
	HistogramID    string `avro:"histogram_id"`
	DatapointID    string `avro:"datapoint_id"`
	ExemplarID     string `avro:"exemplar_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

HistogramDataPointExemplarAttribute

type HistogramDatapoint 

type HistogramDatapoint struct {
	HistogramID   string  `avro:"histogram_id"`
	ID            string  `avro:"id"`
	StartTimeUnix int64   `avro:"start_time_unix"`
	TimeUnix      int64   `avro:"time_unix"`
	Count         int64   `avro:"count"`
	Sum           float64 `avro:"data_sum"`
	Min           float64 `avro:"data_min"`
	Max           float64 `avro:"data_max"`
	Flags         int     `avro:"flags"`
}

HistogramDatapoint

type HistogramDatapointBucketCount 

type HistogramDatapointBucketCount struct {
	HistogramID string `avro:"histogram_id"`
	DatapointID string `avro:"datapoint_id"`
	CountID     string `avro:"count_id"`
	Count       int64  `avro:"count"`
}

type HistogramDatapointExemplar 

type HistogramDatapointExemplar struct {
	HistogramID    string  `avro:"histogram_id"`
	DatapointID    string  `avro:"datapoint_id"`
	ExemplarID     string  `avro:"exemplar_id"`
	TimeUnix       int64   `avro:"time_unix"`
	HistogramValue float64 `avro:"histogram_value"`
	TraceID        string  `mapstructure:"trace_id" avro:"trace_id"`
	SpanID         string  `mapstructure:"span_id" avro:"span_id"`
}

HistogramDatapointExemplar

type HistogramDatapointExplicitBound 

type HistogramDatapointExplicitBound struct {
	HistogramID   string  `avro:"histogram_id"`
	DatapointID   string  `avro:"datapoint_id"`
	BoundID       string  `avro:"bound_id"`
	ExplicitBound float64 `avro:"explicit_bound"`
}

type HistogramResourceAttribute 

type HistogramResourceAttribute struct {
	HistogramID    string `avro:"histogram_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

HistogramResourceAttribute

type HistogramScopeAttribute 

type HistogramScopeAttribute struct {
	HistogramID    string `avro:"histogram_id"`
	ScopeName      string `avro:"name"`
	ScopeVersion   string `avro:"version"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

HistogramScopeAttribute

type KiWriter 

type KiWriter struct {
	Db      gpudb.Gpudb
	Options gpudb.GpudbOptions
	// contains filtered or unexported fields
}

KiWriter 

var Writer *KiWriter

Writer - global pointer to kiwriter struct initialized in the init func

func NewKiWriter 

func NewKiWriter(ctx context.Context, cfg Config, logger *zap.Logger) *KiWriter

NewKiWriter 

@param ctx
@param cfg
@return *KiWriter

func (*KiWriter) GetCfg 

func (kiwriter *KiWriter) GetCfg() Config

GetCfg 

@receiver kiwriter
@return Config

func (*KiWriter) GetDb 

func (kiwriter *KiWriter) GetDb() gpudb.Gpudb

GetDb 

@receiver kiwriter
@return gpudb.Gpudb

func (*KiWriter) GetOptions 

func (kiwriter *KiWriter) GetOptions() gpudb.GpudbOptions

GetOptions 

@receiver kiwriter
@return gpudb.GpudbOptions

func (*KiWriter) SetCfg 

func (kiwriter *KiWriter) SetCfg(cfg Config) *KiWriter

SetCfg 

@receiver kiwriter
@param cfg
@return *kiwriter

func (*KiWriter) SetDb 

func (kiwriter *KiWriter) SetDb(Db gpudb.Gpudb) *KiWriter

SetDb 

@receiver kiwriter
@param Db
@return *kiwriter

func (*KiWriter) SetOptions 

func (kiwriter *KiWriter) SetOptions(Options gpudb.GpudbOptions) *KiWriter

SetOptions 

@receiver kiwriter
@param Options
@return *kiwriter

type LinkAttribute 

type LinkAttribute struct {
	LinkSpanID     string `avro:"link_span_id"`
	TraceID        string `avro:"trace_id"`
	SpanID         string `avro:"span_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

LinkAttribute

func NewLinkAttribute 

func NewLinkAttribute(linkSpanID string, key string, traceID string, spanID string, attributes AttributeValue) *LinkAttribute

NewLinkAttribute Constructor for LinkAttribute 

@param linkID
@param key
@param traceID
@param spanID
@param attributes
@return *LinkAttribute

type Log 

type Log struct {
	LogID                string `mapstructure:"log_id" avro:"log_id"`
	TraceID              string `mapstructure:"trace_id" avro:"trace_id"`
	SpanID               string `mapstructure:"span_id" avro:"span_id"`
	TimeUnixNano         int64  `mapstructure:"time_unix_nano" avro:"time_unix_nano"`
	ObservedTimeUnixNano int64  `mapstructure:"observed_time_unix_nano" avro:"observed_time_unix_nano"`
	SeverityID           int8   `mapstructure:"severity_id" avro:"severity_id"`
	SeverityText         string `mapstructure:"severity_text" avro:"severity_text"`
	Body                 string `mapstructure:"body" avro:"body"`
	Flags                int    `mapstructure:"flags" avro:"flags"`
}

Log

func NewLog 

func NewLog(LogID string, TraceID string, SpanID string, TimeUnixNano int64, ObservedTimeUnixNano int64, SeverityID int8, SeverityText string, Body string, Flags int) *Log

NewLog Constructor for Logs 

@param LogID
@param ResourceID
@param ScopeID
@param TraceID
@param SpanID
@param TimeUnixNano
@param ObservedTimeUnixNano
@param SeverityID
@param SeverityText
@param Body
@param Flags
@return *Logs

func (*Log) GetBody 

func (logs *Log) GetBody() string

GetBody 

@receiver logs
@return string

func (*Log) GetFlags 

func (logs *Log) GetFlags() int

GetFlags 

@receiver logs
@return int

func (*Log) GetLogID 

func (logs *Log) GetLogID() string

GetLogID 

@receiver logs
@return uuid.UUID

func (*Log) GetObservedTimeUnixNano 

func (logs *Log) GetObservedTimeUnixNano() int64

GetObservedTimeUnixNano 

@receiver logs
@return uint64

func (*Log) GetSeverityID 

func (logs *Log) GetSeverityID() int8

GetSeverityID 

@receiver logs
@return int8

func (*Log) GetSeverityText 

func (logs *Log) GetSeverityText() string

GetSeverityText 

@receiver logs
@return string

func (*Log) GetSpanID 

func (logs *Log) GetSpanID() string

GetSpanID 

@receiver logs
@return string

func (*Log) GetTimeUnixNano 

func (logs *Log) GetTimeUnixNano() int64

GetTimeUnixNano 

@receiver logs
@return uint64

func (*Log) GetTraceID 

func (logs *Log) GetTraceID() string

GetTraceID 

@receiver logs
@return string

func (*Log) SetBody 

func (logs *Log) SetBody(Body string) *Log

SetBody 

@receiver logs
@param Body
@return *Logs

func (*Log) SetFlags 

func (logs *Log) SetFlags(Flags int) *Log

SetFlags 

@receiver logs
@param Flags
@return *Logs

func (*Log) SetLogID 

func (logs *Log) SetLogID(LogID string) *Log

SetLogID 

@receiver logs
@param LogID
@return *Logs

func (*Log) SetObservedTimeUnixNano 

func (logs *Log) SetObservedTimeUnixNano(ObservedTimeUnixNano int64) *Log

SetObservedTimeUnixNano 

@receiver logs
@param ObservedTimeUnixNano
@return *Logs

func (*Log) SetSeverityID 

func (logs *Log) SetSeverityID(SeverityID int8) *Log

SetSeverityID 

@receiver logs
@param SeverityID
@return *Logs

func (*Log) SetSeverityText 

func (logs *Log) SetSeverityText(SeverityText string) *Log

SetSeverityText 

@receiver logs
@param SeverityText
@return *Logs

func (*Log) SetSpanID 

func (logs *Log) SetSpanID(SpanID string) *Log

SetSpanID 

@receiver logs
@param SpanID
@return *Logs

func (*Log) SetTimeUnixNano 

func (logs *Log) SetTimeUnixNano(TimeUnixNano int64) *Log

SetTimeUnixNano 

@receiver logs
@param TimeUnixNano
@return *Logs

func (*Log) SetTraceID 

func (logs *Log) SetTraceID(TraceID string) *Log

SetTraceID 

@receiver logs
@param TraceID
@return *Logs

type LogAttribute 

type LogAttribute struct {
	LogID          string `avro:"log_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

LogAttribute

func NewLogAttribute 

func NewLogAttribute(logID string, key string, attributes AttributeValue) *LogAttribute

NewLogAttribute Constructor for LogsAttribute 

@param key
@param attributes
@return *LogsAttribute

type ResourceAttribute 

type ResourceAttribute struct {
	LogID          string `avro:"log_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

ResourceAttribute

func NewResourceAttribute 

func NewResourceAttribute(logID string, key string, attributes AttributeValue) *ResourceAttribute

NewResourceAttribute Constructor for LogsResourceAttribute 

@param resourceID
@param key
@param attributes
@return *LogsResourceAttribute

type ScopeAttribute 

type ScopeAttribute struct {
	LogID          string `avro:"log_id"`
	ScopeName      string `avro:"scope_name"`
	ScopeVersion   string `avro:"scope_version"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

ScopeAttribute

func NewScopeAttribute 

func NewScopeAttribute(logID string, key string, scopeName string, scopeVersion string, attributes AttributeValue) *ScopeAttribute

NewScopeAttribute Constructor for LogsScopeAttribute 

@param scopeID
@param key
@param scopeName
@param scopeVersion
@param attributes
@return *LogsScopeAttribute

type Span 

type Span struct {
	ID                     string `mapstructure:"id" avro:"id" `
	TraceID                string `mapstructure:"trace_id" avro:"trace_id"`
	SpanID                 string `mapstructure:"span_id" avro:"span_id"`
	ParentSpanID           string `mapstructure:"parent_span_id" avro:"parent_span_id"`
	TraceState             string `mapstructure:"trace_state" avro:"trace_state"`
	Name                   string `mapstructure:"name" avro:"name"`
	SpanKind               int8   `mapstructure:"span_kind" avro:"span_kind"`
	StartTimeUnixNano      int64  `mapstructure:"start_time_unix_nano" avro:"start_time_unix_nano"`
	EndTimeUnixNano        int64  `mapstructure:"end_time_unix_nano" avro:"end_time_unix_nano"`
	DroppedAttributesCount int    `mapstructure:"dropped_attributes_count" avro:"dropped_attributes_count"`
	DroppedEventsCount     int    `mapstructure:"dropped_events_count" avro:"dropped_events_count"`
	DroppedLinksCount      int    `mapstructure:"dropped_links_count" avro:"dropped_links_count"`
	Message                string `mapstructure:"message" avro:"message"`
	StatusCode             int8   `mapstructure:"status_code" avro:"status_code"`
}

Span

func NewSpan 

func NewSpan(traceID string, spanID string, parentSpanID string, traceState string, name string, spanKind int8, startTimeUnixNano int64, endTimeUnixNano int64, droppedAttributeCount int, droppedEventCount int, droppedLinkCount int, message string, statusCode int8) *Span

NewSpan Constructor for Span 

@param resourceID
@param scopeID
@param eventID
@param linkID
@param traceID
@param spanID
@param parentSpanID
@param traceState
@param name
@param spanKind
@param startTimeUnixNano
@param endTimeUnixNano
@param droppedAttributeCount
@param droppedEventCount
@param droppedLinkCount
@param message
@param statusCode
@return *Span

func (*Span) GetDroppedAttributeCount 

func (span *Span) GetDroppedAttributeCount() int

GetDroppedAttributeCount 

@receiver span
@return int

func (*Span) GetDroppedEventCount 

func (span *Span) GetDroppedEventCount() int

GetDroppedEventCount 

@receiver span
@return int

func (*Span) GetDroppedLinkCount 

func (span *Span) GetDroppedLinkCount() int

GetDroppedLinkCount 

@receiver span
@return int

func (*Span) GetEndTimeUnixNano 

func (span *Span) GetEndTimeUnixNano() int64

GetEndTimeUnixNano 

@receiver span
@return uint64

func (*Span) GetID 

func (span *Span) GetID() string

GetID 

@receiver span
@return uuid.UUID

func (*Span) GetMessage 

func (span *Span) GetMessage() string

GetMessage 

@receiver span
@return string

func (*Span) GetName 

func (span *Span) GetName() string

GetName 

@receiver span
@return string

func (*Span) GetParentSpanID 

func (span *Span) GetParentSpanID() string

GetParentSpanID 

@receiver span
@return string

func (*Span) GetSpanID 

func (span *Span) GetSpanID() string

GetSpanID 

@receiver span
@return string

func (*Span) GetSpanKind 

func (span *Span) GetSpanKind() int8

GetSpanKind 

@receiver span
@return int8

func (*Span) GetStartTimeUnixNano 

func (span *Span) GetStartTimeUnixNano() int64

GetStartTimeUnixNano 

@receiver span
@return uint64

func (*Span) GetStatusCode 

func (span *Span) GetStatusCode() int8

GetStatusCode 

@receiver span
@return int8

func (*Span) GetTraceID 

func (span *Span) GetTraceID() string

GetTraceID 

@receiver span
@return string

func (*Span) GetTraceState 

func (span *Span) GetTraceState() string

GetTraceState 

@receiver span
@return string

func (*Span) SetDroppedAttributeCount 

func (span *Span) SetDroppedAttributeCount(droppedAttributeCount int) *Span

SetDroppedAttributeCount 

@receiver span
@param droppedAttributeCount
@return *Span

func (*Span) SetDroppedEventCount 

func (span *Span) SetDroppedEventCount(droppedEventCount int) *Span

SetDroppedEventCount 

@receiver span
@param droppedEventCount
@return *Span

func (*Span) SetDroppedLinkCount 

func (span *Span) SetDroppedLinkCount(droppedLinkCount int) *Span

SetDroppedLinkCount 

@receiver span
@param droppedLinkCount
@return *Span

func (*Span) SetEndTimeUnixNano 

func (span *Span) SetEndTimeUnixNano(endTimeUnixNano int64) *Span

SetEndTimeUnixNano 

@receiver span
@param endTimeUnixNano
@return *Span

func (*Span) SetID 

func (span *Span) SetID(ID string) *Span

SetID 

@receiver span
@param ID
@return *Span

func (*Span) SetMessage 

func (span *Span) SetMessage(message string) *Span

SetMessage 

@receiver span
@param message
@return *Span

func (*Span) SetName 

func (span *Span) SetName(name string) *Span

SetName 

@receiver span
@param name
@return *Span

func (*Span) SetParentSpanID 

func (span *Span) SetParentSpanID(parentSpanID string) *Span

SetParentSpanID 

@receiver span
@param parentSpanID
@return *Span

func (*Span) SetSpanID 

func (span *Span) SetSpanID(spanID string) *Span

SetSpanID 

@receiver span
@param spanID
@return *Span

func (*Span) SetSpanKind 

func (span *Span) SetSpanKind(spanKind int8) *Span

SetSpanKind 

@receiver span
@param spanKind
@return *Span

func (*Span) SetStartTimeUnixNano 

func (span *Span) SetStartTimeUnixNano(startTimeUnixNano int64) *Span

SetStartTimeUnixNano 

@receiver span
@param startTimeUnixNano
@return *Span

func (*Span) SetStatusCode 

func (span *Span) SetStatusCode(statusCode int8) *Span

SetStatusCode 

@receiver span
@param statusCode
@return *Span

func (*Span) SetTraceID 

func (span *Span) SetTraceID(traceID string) *Span

SetTraceID 

@receiver span
@param traceID
@return *Span

func (*Span) SetTraceState 

func (span *Span) SetTraceState(traceState string) *Span

SetTraceState 

@receiver span
@param traceState
@return *Span

type SpanAttribute 

type SpanAttribute struct {
	SpanID         string `avro:"span_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

SpanAttribute

func NewSpanAttribute 

func NewSpanAttribute(spanID string, key string, attributeValue AttributeValue) *SpanAttribute

NewSpanAttribute Constructor for SpanAttribute 

@param spanID
@param key
@param atributeValue
@return *SpanAttribute

type Sum 

type Sum struct {
	SumID                  string `avro:"sum_id"`
	MetricName             string `avro:"metric_name"`
	Description            string `avro:"metric_description"`
	Unit                   string `avro:"metric_unit"`
	AggregationTemporality int8   `avro:"aggregation_temporality"`
	IsMonotonic            int8   `avro:"is_monotonic"`
}

Sum

type SumDataPointAttribute 

type SumDataPointAttribute struct {
	SumID          string `avro:"sum_id"`
	DatapointID    string `avro:"datapoint_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

SumDataPointAttribute

type SumDataPointExemplarAttribute 

type SumDataPointExemplarAttribute struct {
	SumID          string `avro:"sum_id"`
	DatapointID    string `avro:"datapoint_id"`
	ExemplarID     string `avro:"exemplar_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

type SumDatapoint 

type SumDatapoint struct {
	SumID         string  `avro:"sum_id"`
	ID            string  `avro:"id"`
	StartTimeUnix int64   `mapstructure:"start_time_unix" avro:"start_time_unix"`
	TimeUnix      int64   `mapstructure:"time_unix" avro:"time_unix"`
	SumValue      float64 `mapstructure:"sum_value" avro:"sum_value"`
	Flags         int     `mapstructure:"flags" avro:"flags"`
}

SumDatapoint

type SumDatapointExemplar 

type SumDatapointExemplar struct {
	SumID       string  `avro:"sum_id"`
	DatapointID string  `avro:"datapoint_id"`
	ExemplarID  string  `avro:"exemplar_id"`
	TimeUnix    int64   `mapstructure:"time_unix" avro:"time_unix"`
	SumValue    float64 `mapstructure:"sum_value" avro:"sum_value"`
	TraceID     string  `mapstructure:"trace_id" avro:"trace_id"`
	SpanID      string  `mapstructure:"span_id" avro:"span_id"`
}

SumDatapointExemplar

type SumResourceAttribute 

type SumResourceAttribute struct {
	SumID          string `avro:"sum_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

SumResourceAttribute

type SumScopeAttribute 

type SumScopeAttribute struct {
	SumID          string `avro:"sum_id"`
	ScopeName      string `avro:"name"`
	ScopeVersion   string `avro:"version"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

SumScopeAttribute

type Summary 

type Summary struct {
	SummaryID   string `avro:"summary_id"`
	MetricName  string `avro:"metric_name"`
	Description string `avro:"metric_description"`
	Unit        string `avro:"metric_unit"`
}

type SummaryDataPointAttribute 

type SummaryDataPointAttribute struct {
	SummaryID      string `avro:"summary_id"`
	DatapointID    string `avro:"datapoint_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

SummaryDataPointAttribute

type SummaryDatapoint 

type SummaryDatapoint struct {
	SummaryID     string  `avro:"summary_id"`
	ID            string  `avro:"id"`
	StartTimeUnix int64   `avro:"start_time_unix"`
	TimeUnix      int64   `avro:"time_unix"`
	Count         int64   `avro:"count"`
	Sum           float64 `avro:"data_sum"`
	Flags         int     `avro:"flags"`
}

SummaryDatapoint

type SummaryDatapointQuantileValues 

type SummaryDatapointQuantileValues struct {
	SummaryID   string  `avro:"summary_id"`
	DatapointID string  `avro:"datapoint_id"`
	QuantileID  string  `avro:"quantile_id"`
	Quantile    float64 `avro:"quantile"`
	Value       float64 `avro:"value"`
}

type SummaryResourceAttribute 

type SummaryResourceAttribute struct {
	SummaryID      string `avro:"summary_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

SummaryResourceAttribute

type SummaryScopeAttribute 

type SummaryScopeAttribute struct {
	SummaryID      string `avro:"summary_id"`
	ScopeName      string `avro:"name"`
	ScopeVersion   string `avro:"version"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

SummaryScopeAttribute

type TraceResourceAttribute 

type TraceResourceAttribute struct {
	SpanID         string `avro:"span_id"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:"",squash`
}

TraceResourceAttribute

func NewTraceResourceAttribute 

func NewTraceResourceAttribute(SpanID string, key string, attributes AttributeValue) *TraceResourceAttribute

NewTraceResourceAttribute Constructor for TraceResourceAttribute 

@param SpanID
@param key
@param attributes
@return *TraceResourceAttribute

type TraceScopeAttribute 

type TraceScopeAttribute struct {
	SpanID         string `avro:"span_id"`
	ScopeName      string `avro:"scope_name"`
	ScopeVersion   string `avro:"scope_version"`
	Key            string `avro:"key"`
	AttributeValue `mapstructure:",squash"`
}

TraceScopeAttribute

func NewtraceScopeAttribute 

func NewtraceScopeAttribute(SpanID string, key string, scopeName string, scopeVersion string, attributes AttributeValue) *TraceScopeAttribute

NewtraceScopeAttribute Constructor for TraceScopeAttribute 

@param key
@param scopeName
@param scopeVersion
@param attributes
@return *TraceScopeAttribute

type ValueTypePair 

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

ValueTypePair

func AttributeValueToKineticaFieldValue 

func AttributeValueToKineticaFieldValue(value pcommon.Value) (ValueTypePair, error)

AttributeValueToKineticaFieldValue // 

@param value
@return ValueTypePair
@return error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.