Documentation ¶
Index ¶
- Constants
- func AttributeValueToKineticaTagValue(value pcommon.Value) (string, error)
- func ChunkBySize[T any](items []T, chunkSize int) [][]T
- func ConvertToInterfaceSlice[T any](items []T) []interface{}
- func CreateDefaultConfig() component.Config
- func GetGpuDbInst(cfg *Config) *gpudb.Gpudb
- func NewFactory() exporter.Factory
- func ValidateStruct(s interface{}) (err error)
- type AggregationTemporality
- type AttributeValue
- func (attributevalue *AttributeValue) GetBoolValue() int8
- func (attributevalue *AttributeValue) GetBytesValue() []byte
- func (attributevalue *AttributeValue) GetDoubleValue() float64
- func (attributevalue *AttributeValue) GetIntValue() int
- func (attributevalue *AttributeValue) GetStringValue() string
- func (attributevalue *AttributeValue) SetBoolValue(BoolValue int8) *AttributeValue
- func (attributevalue *AttributeValue) SetBytesValue(BytesValue []byte) *AttributeValue
- func (attributevalue *AttributeValue) SetDoubleValue(DoubleValue float64) *AttributeValue
- func (attributevalue *AttributeValue) SetIntValue(IntValue int) *AttributeValue
- func (attributevalue *AttributeValue) SetStringValue(StringValue string) *AttributeValue
- type Config
- type EventAttribute
- type ExponentialHistogram
- type ExponentialHistogramBucketNegativeCount
- type ExponentialHistogramBucketPositiveCount
- type ExponentialHistogramDataPointAttribute
- type ExponentialHistogramDataPointExemplarAttribute
- type ExponentialHistogramDatapoint
- type ExponentialHistogramDatapointExemplar
- type ExponentialHistogramResourceAttribute
- type ExponentialHistogramScopeAttribute
- type Gauge
- type GaugeDataPointExemplarAttribute
- type GaugeDatapoint
- type GaugeDatapointAttribute
- type GaugeDatapointExemplar
- type GaugeResourceAttribute
- type GaugeScopeAttribute
- type Histogram
- type HistogramDataPointAttribute
- type HistogramDataPointExemplarAttribute
- type HistogramDatapoint
- type HistogramDatapointBucketCount
- type HistogramDatapointExemplar
- type HistogramDatapointExplicitBound
- type HistogramResourceAttribute
- type HistogramScopeAttribute
- type KiWriter
- func (kiwriter *KiWriter) GetCfg() Config
- func (kiwriter *KiWriter) GetDb() gpudb.Gpudb
- func (kiwriter *KiWriter) GetOptions() gpudb.GpudbOptions
- func (kiwriter *KiWriter) SetCfg(cfg Config) *KiWriter
- func (kiwriter *KiWriter) SetDb(Db gpudb.Gpudb) *KiWriter
- func (kiwriter *KiWriter) SetOptions(Options gpudb.GpudbOptions) *KiWriter
- type LinkAttribute
- type Log
- func (logs *Log) GetBody() string
- func (logs *Log) GetFlags() int
- func (logs *Log) GetLogID() string
- func (logs *Log) GetObservedTimeUnixNano() string
- func (logs *Log) GetResourceID() string
- func (logs *Log) GetScopeID() string
- func (logs *Log) GetSeverityID() int8
- func (logs *Log) GetSeverityText() string
- func (logs *Log) GetSpanID() string
- func (logs *Log) GetTimeUnixNano() string
- func (logs *Log) GetTraceID() string
- func (logs *Log) SetBody(Body string) *Log
- func (logs *Log) SetFlags(Flags int) *Log
- func (logs *Log) SetLogID(LogID string) *Log
- func (logs *Log) SetObservedTimeUnixNano(ObservedTimeUnixNano string) *Log
- func (logs *Log) SetResourceID(ResourceID string) *Log
- func (logs *Log) SetScopeID(ScopeID string) *Log
- func (logs *Log) SetSeverityID(SeverityID int8) *Log
- func (logs *Log) SetSeverityText(SeverityText string) *Log
- func (logs *Log) SetSpanID(SpanID string) *Log
- func (logs *Log) SetTimeUnixNano(TimeUnixNano string) *Log
- func (logs *Log) SetTraceID(TraceID string) *Log
- type LogAttribute
- type ResourceAttribute
- type ScopeAttribute
- type Span
- func (span *Span) GetDroppedAttributeCount() int
- func (span *Span) GetDroppedEventCount() int
- func (span *Span) GetDroppedLinkCount() int
- func (span *Span) GetEndTimeUnixNano() string
- func (span *Span) GetEventID() string
- func (span *Span) GetID() string
- func (span *Span) GetLinkID() string
- func (span *Span) GetMessage() string
- func (span *Span) GetName() string
- func (span *Span) GetParentSpanID() string
- func (span *Span) GetResourceID() string
- func (span *Span) GetScopeID() string
- func (span *Span) GetSpanID() string
- func (span *Span) GetSpanKind() int8
- func (span *Span) GetStartTimeUnixNano() string
- func (span *Span) GetStatusCode() int8
- func (span *Span) GetTraceID() string
- func (span *Span) GetTraceState() string
- func (span *Span) SetDroppedAttributeCount(droppedAttributeCount int) *Span
- func (span *Span) SetDroppedEventCount(droppedEventCount int) *Span
- func (span *Span) SetDroppedLinkCount(droppedLinkCount int) *Span
- func (span *Span) SetEndTimeUnixNano(endTimeUnixNano string) *Span
- func (span *Span) SetEventID(eventID string) *Span
- func (span *Span) SetID(ID string) *Span
- func (span *Span) SetLinkID(linkID string) *Span
- func (span *Span) SetMessage(message string) *Span
- func (span *Span) SetName(name string) *Span
- func (span *Span) SetParentSpanID(parentSpanID string) *Span
- func (span *Span) SetResourceID(resourceID string) *Span
- func (span *Span) SetScopeID(scopeID string) *Span
- func (span *Span) SetSpanID(spanID string) *Span
- func (span *Span) SetSpanKind(spanKind int8) *Span
- func (span *Span) SetStartTimeUnixNano(startTimeUnixNano string) *Span
- func (span *Span) SetStatusCode(statusCode int8) *Span
- func (span *Span) SetTraceID(traceID string) *Span
- func (span *Span) SetTraceState(traceState string) *Span
- type SpanAttribute
- type Sum
- type SumDataPointAttribute
- type SumDataPointExemplarAttribute
- type SumDatapoint
- type SumDatapointExemplar
- type SumResourceAttribute
- type SumScopeAttribute
- type Summary
- type SummaryDataPointAttribute
- type SummaryDatapoint
- type SummaryDatapointQuantileValues
- type SummaryResourceAttribute
- type SummaryScopeAttribute
- type TraceResourceAttribute
- type TraceScopeAttribute
- type ValueTypePair
Constants ¶
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 )
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
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 ¶
AttributeValueToKineticaTagValue
@param value @return string @return error
func ChunkBySize ¶
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 ¶
CreateDefaultConfig - function to create a default configuration
@return component.Config
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.
type EventAttribute ¶
type EventAttribute struct { EventID string `avro:"event_id"` EventName string `avro:"event_name"` Key string `avro:"key"` AttributeValue `mapstructure:",squash"` }
EventAttribute
func NewEventAttribute ¶
func NewEventAttribute(eventID 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"` ResourceID string `avro:"resource_id"` ScopeID string `avro:"scope_id"` MetricName string `avro:"metric_name"` Description string `avro:"metric_description"` Unit string `avro:"metric_unit"` AggregationTemporality int8 `avro:"aggregation_temporality"` }
ExponentialHistogram
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 string `avro:"start_time_unix"` TimeUnix string `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 string `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 { ResourceID string `avro:"resource_id"` Key string `avro:"key"` AttributeValue `mapstructure:",squash"` }
HistogramResourceAttribute
type ExponentialHistogramScopeAttribute ¶
type ExponentialHistogramScopeAttribute struct { ScopeID string `avro:"scope_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"` ResourceID string `avro:"resource_id"` ScopeID string `avro:"scope_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 string `mapstructure:"start_time_unix" avro:"start_time_unix"` TimeUnix string `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 string `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 { ResourceID string `avro:"resource_id"` Key string `avro:"key"` AttributeValue `mapstructure:",squash"` }
GaugeResourceAttribute
type GaugeScopeAttribute ¶
type GaugeScopeAttribute struct { ScopeID string `avro:"scope_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"` ResourceID string `avro:"resource_id"` ScopeID string `avro:"scope_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 string `avro:"start_time_unix"` TimeUnix string `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 HistogramDatapointExemplar ¶
type HistogramDatapointExemplar struct { HistogramID string `avro:"histogram_id"` DatapointID string `avro:"datapoint_id"` ExemplarID string `avro:"exemplar_id"` TimeUnix string `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 HistogramResourceAttribute ¶
type HistogramResourceAttribute struct { ResourceID string `avro:"resource_id"` Key string `avro:"key"` AttributeValue `mapstructure:",squash"` }
HistogramResourceAttribute
type HistogramScopeAttribute ¶
type HistogramScopeAttribute struct { ScopeID string `avro:"scope_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 (*KiWriter) GetOptions ¶
func (kiwriter *KiWriter) GetOptions() gpudb.GpudbOptions
GetOptions
@receiver kiwriter @return gpudb.GpudbOptions
func (*KiWriter) SetOptions ¶
func (kiwriter *KiWriter) SetOptions(Options gpudb.GpudbOptions) *KiWriter
SetOptions
@receiver kiwriter @param Options @return *kiwriter
type LinkAttribute ¶
type LinkAttribute struct { LinkID string `avro:"link_id"` TraceID string `avro:"trace_id"` SpanID string `avro:"span_id"` Key string `avro:"key"` AttributeValue `mapstructure:",squash"` }
LinkAttribute
func NewLinkAttribute ¶
func NewLinkAttribute(linkID 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"` ResourceID string `mapstructure:"resource_id" avro:"resource_id"` ScopeID string `mapstructure:"scope_id" avro:"scope_id"` TraceID string `mapstructure:"trace_id" avro:"trace_id"` SpanID string `mapstructure:"span_id" avro:"span_id"` TimeUnixNano string `mapstructure:"time_unix_nano" avro:"time_unix_nano"` ObservedTimeUnixNano string `mapstructure:"observerd_time_unix_nano" avro:"observerd_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, ResourceID string, ScopeID string, TraceID string, SpanID string, TimeUnixNano string, ObservedTimeUnixNano string, 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) SetObservedTimeUnixNano ¶
SetObservedTimeUnixNano
@receiver logs @param ObservedTimeUnixNano @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 { ResourceID string `avro:"resource_id"` Key string `avro:"key"` AttributeValue `mapstructure:",squash"` }
ResourceAttribute
func NewResourceAttribute ¶
func NewResourceAttribute(resourceID string, key string, attributes AttributeValue) *ResourceAttribute
NewResourceAttribute Constructor for LogsResourceAttribute
@param resourceID @param key @param attributes @return *LogsResourceAttribute
type ScopeAttribute ¶
type ScopeAttribute struct { ScopeID string `avro:"scope_id"` ScopeName string `avro:"scope_name"` ScopeVersion string `avro:"scope_version"` Key string `avro:"key"` AttributeValue `mapstructure:",squash"` }
ScopeAttribute
func NewScopeAttribute ¶
func NewScopeAttribute(scopeID 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" ` ResourceID string `mapstructure:"resource_id" avro:"resource_id" ` ScopeID string `mapstructure:"scope_id" avro:"scope_id" ` EventID string `mapstructure:"event_id" avro:"event_id" ` LinkID string `mapstructure:"link_id" avro:"link_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 string `mapstructure:"start_time_unix_nano" avro:"start_time_unix_nano"` EndTimeUnixNano string `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(resourceID string, scopeID string, eventID string, linkID string, traceID string, spanID string, parentSpanID string, traceState string, name string, spanKind int8, startTimeUnixNano string, endTimeUnixNano string, 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) SetDroppedAttributeCount ¶
SetDroppedAttributeCount
@receiver span @param droppedAttributeCount @return *Span
func (*Span) SetDroppedEventCount ¶
SetDroppedEventCount
@receiver span @param droppedEventCount @return *Span
func (*Span) SetDroppedLinkCount ¶
SetDroppedLinkCount
@receiver span @param droppedLinkCount @return *Span
func (*Span) SetEndTimeUnixNano ¶
SetEndTimeUnixNano
@receiver span @param endTimeUnixNano @return *Span
func (*Span) SetStartTimeUnixNano ¶
SetStartTimeUnixNano
@receiver span @param startTimeUnixNano @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"` ResourceID string `avro:"resource_id"` ScopeID string `avro:"scope_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 string `mapstructure:"start_time_unix" avro:"start_time_unix"` TimeUnix string `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 string `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 { ResourceID string `avro:"resource_id"` Key string `avro:"key"` AttributeValue `mapstructure:",squash"` }
SumResourceAttribute
type SumScopeAttribute ¶
type SumScopeAttribute struct { ScopeID string `avro:"scope_id"` ScopeName string `avro:"name"` ScopeVersion string `avro:"version"` Key string `avro:"key"` AttributeValue `mapstructure:",squash"` }
SumScopeAttribute
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 string `avro:"start_time_unix"` TimeUnix string `avro:"time_unix"` Count int64 `avro:"count"` Sum float64 `avro:"sum"` Flags int `avro:"flags"` }
SummaryDatapoint
type SummaryResourceAttribute ¶
type SummaryResourceAttribute struct { ResourceID string `avro:"resource_id"` Key string `avro:"key"` AttributeValue `mapstructure:",squash"` }
SummaryResourceAttribute
type SummaryScopeAttribute ¶
type SummaryScopeAttribute struct { ScopeID string `avro:"scope_id"` ScopeName string `avro:"name"` ScopeVersion string `avro:"version"` Key string `avro:"key"` AttributeValue `mapstructure:",squash"` }
SummaryScopeAttribute
type TraceResourceAttribute ¶
type TraceResourceAttribute struct { ResourceID string `avro:"resource_id"` Key string `avro:"key"` AttributeValue `mapstructure:"",squash` }
TraceResourceAttribute
func NewTraceResourceAttribute ¶
func NewTraceResourceAttribute(key string, attributes AttributeValue) *TraceResourceAttribute
NewTraceResourceAttribute Constructor for TraceResourceAttribute
@param key @param attributes @return *TraceResourceAttribute
type TraceScopeAttribute ¶
type TraceScopeAttribute struct { ScopeID string `avro:"scope_id"` ScopeName string `avro:"scope_name"` ScopeVersion string `avro:"scope_version"` Key string `avro:"key"` AttributeValue `mapstructure:",squash"` }
TraceScopeAttribute
func NewtraceScopeAttribute ¶
func NewtraceScopeAttribute(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