arrow

Documentation

Overview

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

Index

• Constants
• type LogsProfileable
  • func NewLogsProfileable(tags []string, dataset dataset.LogsDataset, config *benchmark.Config) *LogsProfileable
  • func (s *LogsProfileable) Clear()
  • func (s *LogsProfileable) CompressionAlgorithm() benchmark.CompressionAlgorithm
  • func (s *LogsProfileable) ConvertOtlpArrowToOtlp(_ io.Writer)
  • func (s *LogsProfileable) ConvertOtlpToOtlpArrow(_ io.Writer, _, _ int)
  • func (s *LogsProfileable) DatasetSize() int
  • func (s *LogsProfileable) Deserialize(_ io.Writer, buffers [][]byte)
  • func (s *LogsProfileable) EnableUnaryRpcMode()
  • func (s *LogsProfileable) EndProfiling(_ io.Writer)
  • func (s *LogsProfileable) InitBatchSize(_ io.Writer, _ int)
  • func (s *LogsProfileable) Name() string
  • func (s *LogsProfileable) PrepareBatch(_ io.Writer, startAt, size int)
  • func (s *LogsProfileable) Process(io.Writer) string
  • func (s *LogsProfileable) Serialize(io.Writer) ([][]byte, error)
  • func (s *LogsProfileable) SetObserver(observer observer.ProducerObserver)
  • func (s *LogsProfileable) ShowStats()
  • func (s *LogsProfileable) StartProfiling(_ io.Writer)
  • func (s *LogsProfileable) Tags() []string
• type MetricsProfileable
  • func NewMetricsProfileable(tags []string, dataset dataset.MetricsDataset, config *benchmark.Config) *MetricsProfileable
  • func (s *MetricsProfileable) Clear()
  • func (s *MetricsProfileable) CompressionAlgorithm() benchmark.CompressionAlgorithm
  • func (s *MetricsProfileable) ConvertOtlpArrowToOtlp(_ io.Writer)
  • func (s *MetricsProfileable) ConvertOtlpToOtlpArrow(_ io.Writer, _, _ int)
  • func (s *MetricsProfileable) DatasetSize() int
  • func (s *MetricsProfileable) Deserialize(_ io.Writer, buffers [][]byte)
  • func (s *MetricsProfileable) EnableUnaryRpcMode()
  • func (s *MetricsProfileable) EndProfiling(_ io.Writer)
  • func (s *MetricsProfileable) InitBatchSize(_ io.Writer, _ int)
  • func (s *MetricsProfileable) Name() string
  • func (s *MetricsProfileable) PrepareBatch(_ io.Writer, startAt, size int)
  • func (s *MetricsProfileable) Process(io.Writer) string
  • func (s *MetricsProfileable) Serialize(io.Writer) ([][]byte, error)
  • func (s *MetricsProfileable) SetObserver(observer observer.ProducerObserver)
  • func (s *MetricsProfileable) ShowStats()
  • func (s *MetricsProfileable) StartProfiling(_ io.Writer)
  • func (s *MetricsProfileable) Tags() []string
• type TracesProfileable
  • func NewTraceProfileable(tags []string, dataset dataset.TraceDataset, config *benchmark.Config) *TracesProfileable
  • func WithOption(tags []string, options ...cfg.Option) *TracesProfileable
  • func (s *TracesProfileable) Clear()
  • func (s *TracesProfileable) CompressionAlgorithm() benchmark.CompressionAlgorithm
  • func (s *TracesProfileable) ConvertOtlpArrowToOtlp(_ io.Writer)
  • func (s *TracesProfileable) ConvertOtlpToOtlpArrow(_ io.Writer, _, _ int)
  • func (s *TracesProfileable) DatasetSize() int
  • func (s *TracesProfileable) Deserialize(_ io.Writer, buffers [][]byte)
  • func (s *TracesProfileable) EnableUnaryRpcMode()
  • func (s *TracesProfileable) EndProfiling(_ io.Writer)
  • func (s *TracesProfileable) InitBatchSize(_ io.Writer, _ int)
  • func (s *TracesProfileable) Name() string
  • func (s *TracesProfileable) PrepareBatch(_ io.Writer, startAt, size int)
  • func (s *TracesProfileable) Process(io.Writer) string
  • func (s *TracesProfileable) Serialize(io.Writer) ([][]byte, error)
  • func (s *TracesProfileable) SetDataset(dataset dataset.TraceDataset)
  • func (s *TracesProfileable) SetObserver(observer observer.ProducerObserver)
  • func (s *TracesProfileable) ShowStats()
  • func (s *TracesProfileable) StartProfiling(_ io.Writer)
  • func (s *TracesProfileable) Tags() []string

Constants

const OtelArrow = "OTel_ARROW"

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 observer.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 observer.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 WithOption

func WithOption(tags []string, options ...cfg.Option) *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) SetDataset

func (s *TracesProfileable) SetDataset(dataset dataset.TraceDataset)

func (*TracesProfileable) SetObserver

func (s *TracesProfileable) SetObserver(observer observer.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