inlong

package
v0.0.1 Latest Latest
Warning

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

Go to latest
Published: Jan 1, 2026 License: MIT Imports: 9 Imported by: 0

README

Inlong Output Plugin

This plugin publishes metrics to an Apache InLong instance.

⭐ Telegraf v1.35.0 🏷️ messaging 💻 all

Global configuration options

Plugins support additional global and plugin configuration settings for tasks such as modifying metrics, tags, and fields, creating aliases, and configuring plugin ordering. See CONFIGURATION.md for more details.

Configuration

# Send telegraf metrics to Apache Inlong
[[outputs.inlong]]
  ## Manager URL to obtain the Inlong data-proxy IP list for sending the data
  url = "http://127.0.0.1:8083"

  ## Unique identifier for the data-stream group
  group_id = "telegraf"  

  ## Unique identifier for the data stream within its group
  stream_id = "telegraf"  

  ## Data format to output.
  ## Each data format has its own unique set of configuration options, read
  ## more about them here:
  ## https://github.com/netxops/unicontroller/blob/master/docs/DATA_FORMATS_OUTPUT.md
  # data_format = "influx"

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Inlong

type Inlong struct {
	ManagerURL string          `toml:"url"`
	GroupID    string          `toml:"group_id"`
	StreamID   string          `toml:"stream_id"`
	Log        telegraf.Logger `toml:"-"`
	// contains filtered or unexported fields
}

func (*Inlong) Close

func (i *Inlong) Close() error

func (*Inlong) Connect

func (i *Inlong) Connect() error

func (*Inlong) Init

func (i *Inlong) Init() error

func (*Inlong) SampleConfig

func (*Inlong) SampleConfig() string

func (*Inlong) SetSerializer

func (i *Inlong) SetSerializer(serializer telegraf.Serializer)

func (*Inlong) Write

func (i *Inlong) Write(metrics []telegraf.Metric) error

Jump to

Keyboard shortcuts

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