protocol

package

v0.0.0-...-a53e426 Latest Latest Go to latest Published: Apr 28, 2024 License: Apache-2.0 Imports: 23 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/alibaba/ilogtail

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func ConvertPipelineEventToOtlpEvent[T1 plog.ResourceLogs, T2 pmetric.ResourceMetrics, T3 ptrace.ResourceSpans](c *Converter, ps *models.PipelineGroupEvents) (t1 T1, t2 T2, t3 T3, err error)
func ConvertPipelineEventToOtlpLog(event models.PipelineEvent, scopeLog plog.ScopeLogs) (err error)
func ConvertPipelineEventToOtlpMetric(event models.PipelineEvent, scopeMetric pmetric.ScopeMetrics) (err error)
func ConvertPipelineEventToOtlpSpan(event models.PipelineEvent, scopeTrace ptrace.ScopeSpans) error
func ConvertPipelineGroupEvenstsToOtlpEvents(ps *models.PipelineGroupEvents, rsLogs plog.ResourceLogs, ...) error
func GetPooledByteBuf() *[]byte
func PutPooledByteBuf(buf *[]byte)
func TrimPrefix(str string) string
type Converter
- func NewConverter(protocol, encoding string, ...) (*Converter, error)
- func NewConverterWithSep(protocol, encoding, sep string, ignoreUnExpectedData bool, ...) (*Converter, error)
type MetricLabel
type MetricLabels

Constants ¶

View Source

const (
	ProtocolCustomSingle        = "custom_single"
	ProtocolCustomSingleFlatten = "custom_single_flatten"
	ProtocolOtlpV1              = "otlp_v1"
	ProtocolInfluxdb            = "influxdb"
	ProtocolJsonline            = "jsonline"
	ProtocolRaw                 = "raw"
)

View Source

const (
	EncodingNone     = "none"
	EncodingJSON     = "json"
	EncodingProtobuf = "protobuf"
	EncodingCustom   = "custom"
)

View Source

const (
	KeyValueSeparator = "#$#"
	LabelSeparator    = "|"
)

Variables ¶

This section is empty.

Functions ¶

func ConvertPipelineEventToOtlpEvent ¶

func ConvertPipelineEventToOtlpEvent[
	T1 plog.ResourceLogs,
	T2 pmetric.ResourceMetrics,
	T3 ptrace.ResourceSpans,
](c *Converter, ps *models.PipelineGroupEvents) (t1 T1, t2 T2, t3 T3, err error)

func ConvertPipelineEventToOtlpLog ¶

func ConvertPipelineEventToOtlpLog(event models.PipelineEvent, scopeLog plog.ScopeLogs) (err error)

func ConvertPipelineEventToOtlpMetric ¶

func ConvertPipelineEventToOtlpMetric(event models.PipelineEvent, scopeMetric pmetric.ScopeMetrics) (err error)

func ConvertPipelineEventToOtlpSpan ¶

func ConvertPipelineEventToOtlpSpan(event models.PipelineEvent, scopeTrace ptrace.ScopeSpans) error

func ConvertPipelineGroupEvenstsToOtlpEvents ¶

func ConvertPipelineGroupEvenstsToOtlpEvents(ps *models.PipelineGroupEvents, rsLogs plog.ResourceLogs, rsMetrics pmetric.ResourceMetrics, rsTraces ptrace.ResourceSpans) error

func GetPooledByteBuf ¶

func GetPooledByteBuf() *[]byte

func PutPooledByteBuf ¶

func PutPooledByteBuf(buf *[]byte)

func TrimPrefix ¶

func TrimPrefix(str string) string

Types ¶

type Converter ¶

type Converter struct {
	Protocol             string
	Encoding             string
	Separator            string
	IgnoreUnExpectedData bool
	OnlyContents         bool
	TagKeyRenameMap      map[string]string
	ProtocolKeyRenameMap map[string]string
}

func NewConverter ¶

func NewConverter(protocol, encoding string, tagKeyRenameMap, protocolKeyRenameMap map[string]string) (*Converter, error)

func NewConverterWithSep ¶

func NewConverterWithSep(protocol, encoding, sep string, ignoreUnExpectedData bool, tagKeyRenameMap, protocolKeyRenameMap map[string]string) (*Converter, error)

func (*Converter) ConvertPipelineGroupEventsToOTLPEventsV1 ¶

func (c *Converter) ConvertPipelineGroupEventsToOTLPEventsV1(ps *models.PipelineGroupEvents) (plog.ResourceLogs, pmetric.ResourceMetrics, ptrace.ResourceSpans, error)

PipelineGroupEvents -> OTLP Logs/Metrics/Traces

func (*Converter) ConvertToInfluxdbProtocolStream ¶

func (c *Converter) ConvertToInfluxdbProtocolStream(logGroup *protocol.LogGroup, targetFields []string) (stream [][]byte, values []map[string]string, err error)

ConvertToInfluxdbProtocolStream converts @logGroup to []byte in the influxdb line protocol, @c.TagKeyRenameMap, @c.ProtocolKeyRenameMap param will be ignored, as they are not very suitable for metrics.

func (*Converter) ConvertToInfluxdbProtocolStreamV2 ¶

func (c *Converter) ConvertToInfluxdbProtocolStreamV2(groupEvents *models.PipelineGroupEvents, targetFields []string) (stream [][]byte, values []map[string]string, err error)

func (*Converter) ConvertToJsonlineProtocolStreamFlatten ¶

func (c *Converter) ConvertToJsonlineProtocolStreamFlatten(logGroup *protocol.LogGroup) ([]byte, []map[string]string, error)

func (*Converter) ConvertToOtlpResourseLogs ¶

func (c *Converter) ConvertToOtlpResourseLogs(logGroup *protocol.LogGroup, targetFields []string) (plog.ResourceLogs, []map[string]string, error)

func (*Converter) ConvertToRawStream ¶

func (c *Converter) ConvertToRawStream(groupEvents *models.PipelineGroupEvents, targetFields []string) (stream [][]byte, values []map[string]string, err error)

func (*Converter) ConvertToSingleProtocolLogs ¶

func (c *Converter) ConvertToSingleProtocolLogs(logGroup *protocol.LogGroup, targetFields []string) ([]map[string]interface{}, []map[string]string, error)

func (*Converter) ConvertToSingleProtocolLogsFlatten ¶

func (c *Converter) ConvertToSingleProtocolLogsFlatten(logGroup *protocol.LogGroup, targetFields []string) ([]map[string]interface{}, []map[string]string, error)

func (*Converter) ConvertToSingleProtocolStream ¶

func (c *Converter) ConvertToSingleProtocolStream(logGroup *protocol.LogGroup, targetFields []string) ([][]byte, []map[string]string, error)

func (*Converter) ConvertToSingleProtocolStreamFlatten ¶

func (c *Converter) ConvertToSingleProtocolStreamFlatten(logGroup *protocol.LogGroup, targetFields []string) ([][]byte, []map[string]string, error)

func (*Converter) Do ¶

func (c *Converter) Do(logGroup *protocol.LogGroup) (logs interface{}, err error)

func (*Converter) DoWithSelectedFields ¶

func (c *Converter) DoWithSelectedFields(logGroup *protocol.LogGroup, targetFields []string) (logs interface{}, values []map[string]string, err error)

func (*Converter) ToByteStream ¶

func (c *Converter) ToByteStream(logGroup *protocol.LogGroup) (stream interface{}, err error)

func (*Converter) ToByteStreamWithSelectedFields ¶

func (c *Converter) ToByteStreamWithSelectedFields(logGroup *protocol.LogGroup, targetFields []string) (stream interface{}, values []map[string]string, err error)

func (*Converter) ToByteStreamWithSelectedFieldsV2 ¶

func (c *Converter) ToByteStreamWithSelectedFieldsV2(groupEvents *models.PipelineGroupEvents, targetFields []string) (stream interface{}, values []map[string]string, err error)

type MetricLabel ¶

type MetricLabel struct {
	Key   string
	Value string
}

type MetricLabels ¶

type MetricLabels []MetricLabel

func (MetricLabels) GetLabel ¶

func (m MetricLabels) GetLabel() string

func (MetricLabels) Len ¶

func (m MetricLabels) Len() int

func (MetricLabels) Less ¶

func (m MetricLabels) Less(i, j int) bool

func (MetricLabels) Swap ¶

func (m MetricLabels) Swap(i, j int)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL