arrow

package
v0.0.0-...-cafc5b9 Latest Latest
Warning

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

 Go to latest Published: Aug 16, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Package arrow implements the Profile interface for the OTLP Arrow protocol.

Index

Constants

View Source 
const OtelArrow = "OTel_ARROW"

Variables

This section is empty.

Functions

This section is empty.

Types

type LogsProfileable 

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

func NewLogsProfileable 

func NewLogsProfileable(tags []string, dataset dataset.LogsDataset, config *benchmark.Config) *LogsProfileable

func (*LogsProfileable) Clear 

func (s *LogsProfileable) Clear()

func (*LogsProfileable) CompressionAlgorithm 

func (s *LogsProfileable) CompressionAlgorithm() benchmark.CompressionAlgorithm

func (*LogsProfileable) ConvertOtlpArrowToOtlp 

func (s *LogsProfileable) ConvertOtlpArrowToOtlp(_ io.Writer)

func (*LogsProfileable) ConvertOtlpToOtlpArrow 

func (s *LogsProfileable) ConvertOtlpToOtlpArrow(_ io.Writer, _, _ int)

func (*LogsProfileable) DatasetSize 

func (s *LogsProfileable) DatasetSize() int

func (*LogsProfileable) Deserialize 

func (s *LogsProfileable) Deserialize(_ io.Writer, buffers [][]byte)

func (*LogsProfileable) EnableUnaryRpcMode 

func (s *LogsProfileable) EnableUnaryRpcMode()

func (*LogsProfileable) EndProfiling 

func (s *LogsProfileable) EndProfiling(_ io.Writer)

func (*LogsProfileable) InitBatchSize 

func (s *LogsProfileable) InitBatchSize(_ io.Writer, _ int)

func (*LogsProfileable) Name 

func (s *LogsProfileable) Name() string

func (*LogsProfileable) PrepareBatch 

func (s *LogsProfileable) PrepareBatch(_ io.Writer, startAt, size int)

func (*LogsProfileable) Process 

func (s *LogsProfileable) Process(io.Writer) string

func (*LogsProfileable) Serialize 

func (s *LogsProfileable) Serialize(io.Writer) ([][]byte, error)

func (*LogsProfileable) SetObserver 

func (s *LogsProfileable) SetObserver(observer arrow_record.ProducerObserver)

func (*LogsProfileable) ShowStats 

func (s *LogsProfileable) ShowStats()

func (*LogsProfileable) StartProfiling 

func (s *LogsProfileable) StartProfiling(_ io.Writer)

func (*LogsProfileable) Tags 

func (s *LogsProfileable) Tags() []string

type MetricsProfileable 

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

func NewMetricsProfileable 

func NewMetricsProfileable(tags []string, dataset dataset.MetricsDataset, config *benchmark.Config) *MetricsProfileable

func (*MetricsProfileable) Clear 

func (s *MetricsProfileable) Clear()

func (*MetricsProfileable) CompressionAlgorithm 

func (s *MetricsProfileable) CompressionAlgorithm() benchmark.CompressionAlgorithm

func (*MetricsProfileable) ConvertOtlpArrowToOtlp 

func (s *MetricsProfileable) ConvertOtlpArrowToOtlp(_ io.Writer)

func (*MetricsProfileable) ConvertOtlpToOtlpArrow 

func (s *MetricsProfileable) ConvertOtlpToOtlpArrow(_ io.Writer, _, _ int)

func (*MetricsProfileable) DatasetSize 

func (s *MetricsProfileable) DatasetSize() int

func (*MetricsProfileable) Deserialize 

func (s *MetricsProfileable) Deserialize(_ io.Writer, buffers [][]byte)

func (*MetricsProfileable) EnableUnaryRpcMode 

func (s *MetricsProfileable) EnableUnaryRpcMode()

func (*MetricsProfileable) EndProfiling 

func (s *MetricsProfileable) EndProfiling(_ io.Writer)

func (*MetricsProfileable) InitBatchSize 

func (s *MetricsProfileable) InitBatchSize(_ io.Writer, _ int)

func (*MetricsProfileable) Name 

func (s *MetricsProfileable) Name() string

func (*MetricsProfileable) PrepareBatch 

func (s *MetricsProfileable) PrepareBatch(_ io.Writer, startAt, size int)

func (*MetricsProfileable) Process 

func (s *MetricsProfileable) Process(io.Writer) string

func (*MetricsProfileable) Serialize 

func (s *MetricsProfileable) Serialize(io.Writer) ([][]byte, error)

func (*MetricsProfileable) SetObserver 

func (s *MetricsProfileable) SetObserver(observer arrow_record.ProducerObserver)

func (*MetricsProfileable) ShowStats 

func (s *MetricsProfileable) ShowStats()

func (*MetricsProfileable) StartProfiling 

func (s *MetricsProfileable) StartProfiling(_ io.Writer)

func (*MetricsProfileable) Tags 

func (s *MetricsProfileable) Tags() []string

type TracesProfileable 

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

func NewTraceProfileable 

func NewTraceProfileable(tags []string, dataset dataset.TraceDataset, config *benchmark.Config) *TracesProfileable

func (*TracesProfileable) Clear 

func (s *TracesProfileable) Clear()

func (*TracesProfileable) CompressionAlgorithm 

func (s *TracesProfileable) CompressionAlgorithm() benchmark.CompressionAlgorithm

func (*TracesProfileable) ConvertOtlpArrowToOtlp 

func (s *TracesProfileable) ConvertOtlpArrowToOtlp(_ io.Writer)

func (*TracesProfileable) ConvertOtlpToOtlpArrow 

func (s *TracesProfileable) ConvertOtlpToOtlpArrow(_ io.Writer, _, _ int)

func (*TracesProfileable) DatasetSize 

func (s *TracesProfileable) DatasetSize() int

func (*TracesProfileable) Deserialize 

func (s *TracesProfileable) Deserialize(_ io.Writer, buffers [][]byte)

func (*TracesProfileable) EnableUnaryRpcMode 

func (s *TracesProfileable) EnableUnaryRpcMode()

func (*TracesProfileable) EndProfiling 

func (s *TracesProfileable) EndProfiling(_ io.Writer)

func (*TracesProfileable) InitBatchSize 

func (s *TracesProfileable) InitBatchSize(_ io.Writer, _ int)

func (*TracesProfileable) Name 

func (s *TracesProfileable) Name() string

func (*TracesProfileable) PrepareBatch 

func (s *TracesProfileable) PrepareBatch(_ io.Writer, startAt, size int)

func (*TracesProfileable) Process 

func (s *TracesProfileable) Process(io.Writer) string

func (*TracesProfileable) Serialize 

func (s *TracesProfileable) Serialize(io.Writer) ([][]byte, error)

func (*TracesProfileable) SetObserver 

func (s *TracesProfileable) SetObserver(observer arrow_record.ProducerObserver)

func (*TracesProfileable) ShowStats 

func (s *TracesProfileable) ShowStats()

func (*TracesProfileable) StartProfiling 

func (s *TracesProfileable) StartProfiling(_ io.Writer)

func (*TracesProfileable) Tags 

func (s *TracesProfileable) Tags() []string

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.