record_message

Documentation

Index

• func ShowFieldStats(indent string, field *arrow.Field, column arrow.Array)
• type PayloadType
• type RecordMessage
  • func NewLogsMessage(schemaID string, record arrow.Record) *RecordMessage
  • func NewMetricsMessage(schemaID string, record arrow.Record) *RecordMessage
  • func NewRecordMessage(batchId int64, payloadType PayloadType, record arrow.Record) *RecordMessage
  • func NewRelatedDataMessage(schemaID string, record arrow.Record, payloadType PayloadType) *RecordMessage
  • func NewTraceMessage(schemaID string, record arrow.Record) *RecordMessage
  • func (rm *RecordMessage) BatchId() int64
  • func (rm *RecordMessage) PayloadType() PayloadType
  • func (rm *RecordMessage) Record() arrow.Record
  • func (rm *RecordMessage) SchemaID() string
  • func (rm *RecordMessage) SetPayloadType(payloadType PayloadType)
  • func (rm *RecordMessage) SetRecord(record arrow.Record)
  • func (rm *RecordMessage) ShowStats()

Functions

func ShowFieldStats

func ShowFieldStats(indent string, field *arrow.Field, column arrow.Array)

Types

type PayloadType

type PayloadType = v1.ArrowPayloadType

type RecordMessage

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

RecordMessage wraps an Arrow Record with a set of metadata used to identify the batch, schema ID, and few other properties.

func NewLogsMessage

func NewLogsMessage(schemaID string, record arrow.Record) *RecordMessage

NewLogsMessage creates a reference to a new RecordMessage from a given Arrow Record representing a collection of logs.

func NewMetricsMessage

func NewMetricsMessage(schemaID string, record arrow.Record) *RecordMessage

NewMetricsMessage creates a reference to a new RecordMessage from a given Arrow Record representing a collection of metrics.

func NewRecordMessage

func NewRecordMessage(batchId int64, payloadType PayloadType, record arrow.Record) *RecordMessage

NewRecordMessage creates a record message.

func NewRelatedDataMessage

func NewRelatedDataMessage(schemaID string, record arrow.Record, payloadType PayloadType) *RecordMessage

func NewTraceMessage

func NewTraceMessage(schemaID string, record arrow.Record) *RecordMessage

NewTraceMessage creates a reference to a new RecordMessage from a given Arrow Record representing a collection of traces.

func (*RecordMessage) BatchId

func (rm *RecordMessage) BatchId() int64

func (*RecordMessage) PayloadType

func (rm *RecordMessage) PayloadType() PayloadType

PayloadType returns the type of payload contained in this RecordMessage.

func (*RecordMessage) Record

func (rm *RecordMessage) Record() arrow.Record

Record returns the Arrow Record associated with this RecordMessage.

func (*RecordMessage) SchemaID

func (rm *RecordMessage) SchemaID() string

func (*RecordMessage) SetPayloadType

func (rm *RecordMessage) SetPayloadType(payloadType PayloadType)

func (*RecordMessage) SetRecord

func (rm *RecordMessage) SetRecord(record arrow.Record)

func (*RecordMessage) ShowStats

func (rm *RecordMessage) ShowStats()