sink

Documentation

Index

• type File
  • func NewFile(options FileOptions, observability *common.Observability) *File
  • func (f *File) Name() string
  • func (f *File) Process(d common.Discovery, so common.SinkObject)
  • func (f *File) Providers() []string
• type FileOptions
• type Json
  • func NewJson(options JsonOptions, observability *common.Observability) *Json
  • func (j *Json) Name() string
  • func (j *Json) Process(d common.Discovery, so common.SinkObject)
  • func (j *Json) Providers() []string
• type JsonOptions
• type Observability
  • func NewObservability(options ObservabilityOptions, observability *common.Observability) *Observability
  • func (o *Observability) Name() string
  • func (o *Observability) Process(d common.Discovery, so common.SinkObject)
  • func (o *Observability) Providers() []string
• type ObservabilityOptions
• type PubSub
  • func NewPubSub(options PubSubOptions, observability *common.Observability) *PubSub
  • func (ps *PubSub) Close()
  • func (ps *PubSub) Name() string
  • func (ps *PubSub) Process(d common.Discovery, so common.SinkObject)
  • func (ps *PubSub) Providers() []string
• type PubSubOptions
• type PubSubPublishObject
• type Telegraf
  • func NewTelegraf(options TelegrafOptions, observability *common.Observability) *Telegraf
  • func (t *Telegraf) Name() string
  • func (t *Telegraf) Process(d common.Discovery, so common.SinkObject)
  • func (t *Telegraf) Providers() []string
• type TelegrafCertOptions
• type TelegrafDNSOptions
• type TelegrafHTTPOptions
• type TelegrafOptions
• type TelegrafSignalOptions
• type TelegrafTCPOptions
• type Yaml
  • func NewYaml(options YamlOptions, observability *common.Observability) *Yaml
  • func (y *Yaml) Name() string
  • func (y *Yaml) Process(d common.Discovery, so common.SinkObject)
  • func (y *Yaml) Providers() []string
• type YamlOptions

Types

type File

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

func NewFile

func NewFile(options FileOptions, observability *common.Observability) *File

func (*File) Name

func (f *File) Name() string

func (*File) Process

func (f *File) Process(d common.Discovery, so common.SinkObject)

func (*File) Providers

func (f *File) Providers() []string

type FileOptions

type FileOptions struct {
	Checksum  bool
	Providers []string
	Names     []string
}

type Json

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

func NewJson

func NewJson(options JsonOptions, observability *common.Observability) *Json

func (*Json) Name

func (j *Json) Name() string

func (*Json) Process

func (j *Json) Process(d common.Discovery, so common.SinkObject)

func (*Json) Providers

func (j *Json) Providers() []string

type JsonOptions

type JsonOptions struct {
	Dir       string
	Providers []string
}

type Observability

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

func NewObservability

func NewObservability(options ObservabilityOptions, observability *common.Observability) *Observability

func (*Observability) Name

func (o *Observability) Name() string

func (*Observability) Process

func (o *Observability) Process(d common.Discovery, so common.SinkObject)

func (*Observability) Providers

func (o *Observability) Providers() []string

type ObservabilityOptions

type ObservabilityOptions struct {
	DiscoveryName string
	TotalName     string
	Providers     []string
	Labels        []string
}

type PubSub

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

func NewPubSub

func NewPubSub(options PubSubOptions, observability *common.Observability) *PubSub

func (*PubSub) Close

func (ps *PubSub) Close()

func (*PubSub) Name

func (ps *PubSub) Name() string

func (*PubSub) Process

func (ps *PubSub) Process(d common.Discovery, so common.SinkObject)

func (*PubSub) Providers

func (ps *PubSub) Providers() []string

type PubSubOptions

type PubSubOptions struct {
	Enabled     bool
	Credentials string
	ProjectID   string
	TopicID     string
	Providers   []string
}

type PubSubPublishObject

type PubSubPublishObject struct {
	Source  string      `json:"source"`
	Type    string      `json:"type"`
	Cluster string      `json:"cluster"`
	Data    interface{} `json:"data"`
}

type Telegraf

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

func NewTelegraf

func NewTelegraf(options TelegrafOptions, observability *common.Observability) *Telegraf

func (*Telegraf) Name

func (t *Telegraf) Name() string

func (*Telegraf) Process

func (t *Telegraf) Process(d common.Discovery, so common.SinkObject)

func (*Telegraf) Providers

func (t *Telegraf) Providers() []string

type TelegrafCertOptions

type TelegrafCertOptions struct {
	telegraf.InputX509CertOptions
	Template string
	Conf     string
}

type TelegrafDNSOptions

type TelegrafDNSOptions struct {
	telegraf.InputDNSQueryOptions
	Template string
	Conf     string
}

type TelegrafHTTPOptions

type TelegrafHTTPOptions struct {
	telegraf.InputHTTPResponseOptions
	Template string
	Conf     string
}

type TelegrafOptions

type TelegrafOptions struct {
	Providers []string
	Signal    TelegrafSignalOptions
	Cert      TelegrafCertOptions
	DNS       TelegrafDNSOptions
	HTTP      TelegrafHTTPOptions
	TCP       TelegrafTCPOptions
	Checksum  bool
}

type TelegrafSignalOptions

type TelegrafSignalOptions struct {
	telegraf.InputPrometheusHttpOptions
	Template string
	Tags     string
}

type TelegrafTCPOptions

type TelegrafTCPOptions struct {
	telegraf.InputNetResponseOptions
	Template string
	Conf     string
}

type Yaml

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

func NewYaml

func NewYaml(options YamlOptions, observability *common.Observability) *Yaml

func (*Yaml) Name

func (y *Yaml) Name() string

func (*Yaml) Process

func (y *Yaml) Process(d common.Discovery, so common.SinkObject)

func (*Yaml) Providers

func (y *Yaml) Providers() []string

type YamlOptions

type YamlOptions struct {
	Dir       string
	Providers []string
}