transfer

Documentation

Index

• type Transfer
  • func (t *Transfer) Close() error
  • func (t *Transfer) Connect() error
  • func (t *Transfer) Description() string
  • func (t *Transfer) Handle()
  • func (t *Transfer) SampleConfig() string
  • func (t *Transfer) Write(metrics []telegraf.Metric) error
• type TransferEntry
  • func (t *TransferEntry) Connect() error
  • func (t *TransferEntry) Template(in string, attributes map[string]interface{}) string
  • func (t *TransferEntry) TransferItem(id int, item *TransferItem)
  • func (t *TransferEntry) Write(source string, attributes map[string]interface{}) error
• type TransferItem
  • func (t *TransferItem) AddDest(d string) error

Types

type Transfer

type Transfer struct {
	Source       string
	Entry        []*TransferEntry
	RemoveSource int
	Concurrency  int
	// contains filtered or unexported fields
}

func (*Transfer) Close

func (t *Transfer) Close() error

func (*Transfer) Connect

func (t *Transfer) Connect() error

func (*Transfer) Description

func (t *Transfer) Description() string

func (*Transfer) Handle

func (t *Transfer) Handle()

func (*Transfer) SampleConfig

func (t *Transfer) SampleConfig() string

func (*Transfer) Write

func (t *Transfer) Write(metrics []telegraf.Metric) error

type TransferEntry

type TransferEntry struct {
	Destination   []string
	Error         string
	Verbose       int
	Retries       int
	RetryWait     string
	TempExtension string
	Tagpass       map[string][]string
	Namepass      map[string][]string
	Fieldpass     map[string][]string
	// contains filtered or unexported fields
}

func (*TransferEntry) Connect

func (t *TransferEntry) Connect() error

func (*TransferEntry) Template

func (t *TransferEntry) Template(in string, attributes map[string]interface{}) string

func (*TransferEntry) TransferItem

func (t *TransferEntry) TransferItem(id int, item *TransferItem)

func (*TransferEntry) Write

func (t *TransferEntry) Write(source string, attributes map[string]interface{}) error

type TransferItem

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

func (*TransferItem) AddDest

func (t *TransferItem) AddDest(d string) error