dds_consumer_lp

package

v0.2.1-dds Latest Latest Go to latest Published: Mar 10, 2021 License: MIT Imports: 5 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/rticommunity/telegraf

Links

Open Source Insights

README ¶

DDS Input Plugin with the Line Protocol Data Model

dds_consumer_lp plugin reads DDS data in a data model based on the Line Protocol format. This plugin creates a DDS reader with a DDS topic named Telegraf. The data type used by the reader is described in line_protocol.idl.

Configuration:

[[inputs.dds_consumer_lp]]
# DDS Domain ID configuration
domain_id = "0"

Documentation ¶

Constants ¶

View Source

const (
	FIELD_DOUBLE = 0
	FIELD_INT    = 1
	FIELD_UINT   = 2
	FIELD_STRING = 3
	FIELD_BOOL   = 4
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type DDSConsumer ¶

type DDSConsumer struct {
	// XML configuration file path
	DomainId string `toml:"domain_id"`
	// contains filtered or unexported fields
}

func (*DDSConsumer) Description ¶

func (d *DDSConsumer) Description() string

func (*DDSConsumer) Gather ¶

func (d *DDSConsumer) Gather(acc telegraf.Accumulator) error

func (*DDSConsumer) SampleConfig ¶

func (d *DDSConsumer) SampleConfig() string

func (*DDSConsumer) SetParser ¶

func (d *DDSConsumer) SetParser(parser parsers.Parser)

func (*DDSConsumer) Start ¶

func (d *DDSConsumer) Start(acc telegraf.Accumulator) (err error)

func (*DDSConsumer) Stop ¶

func (d *DDSConsumer) Stop()

type Field ¶

type Field struct {
	Key   string          `json:"key"`
	Kind  int             `json:"kind"`
	Value FieldValueUnion `json:"value"`
}

type FieldValueUnion ¶

type FieldValueUnion struct {
	D *float64 `json:"d,omitempty"`
	I *int64   `json:"i,omitempty"`
	U *uint64  `json:"u,omitempty"`
	S *string  `json:"s,omitempty"`
	B *bool    `json:"b,omitempty"`
}

type Metric ¶

type Metric struct {
	Name      string  `json:"name"`
	Tags      []Tag   `json:"tags"`
	Fields    []Field `json:"fields"`
	Timestamp int64   `json:"timestamp"`
}

type Tag ¶

type Tag struct {
	Key   string `json:"key"`
	Value string `json:"value"`
}

Source Files ¶

View all Source files

dds_consumer_lp.go

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