sink

package
v0.9.7 Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2024 License: MIT Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type File added in v0.8.1 

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

func NewFile added in v0.8.1 

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

func (*File) Name added in v0.8.1 

func (f *File) Name() string

func (*File) Process added in v0.8.1 

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

func (*File) Providers added in v0.8.1 

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

type FileOptions added in v0.8.1 

type FileOptions struct {
	Checksum     bool
	Providers    []string
	Names        []string
	Replacements 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 added in v0.6.1 

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 added in v0.6.1 

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 added in v0.6.11 

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

func (*PubSub) Close added in v0.6.11 

func (ps *PubSub) Close()

func (*PubSub) Name added in v0.6.11 

func (ps *PubSub) Name() string

func (*PubSub) Process added in v0.6.11 

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

func (*PubSub) Providers added in v0.6.11 

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

type PubSubOptions added in v0.6.11 

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

type PubSubPublishObject added in v0.6.11 

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 added in v0.6.1 

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
	Dir  string
	File string
	Tags string
}

type TelegrafTCPOptions 

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

type WebServer added in v0.9.4 

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

func NewWebServer added in v0.9.4 

func NewWebServer(options WebServerOptions, observability *common.Observability) *WebServer

func (*WebServer) Name added in v0.9.4 

func (ws *WebServer) Name() string

func (*WebServer) Process added in v0.9.4 

func (ws *WebServer) Process(d common.Discovery, so common.SinkObject)

func (*WebServer) Providers added in v0.9.4 

func (ws *WebServer) Providers() []string

func (*WebServer) Start added in v0.9.4 

func (ws *WebServer) Start(wg *sync.WaitGroup)

type WebServerOptions added in v0.9.4 

type WebServerOptions struct {
	ServerName string
	Listen     string
	Tls        bool
	Insecure   bool
	Cert       string
	Key        string
	Chain      string
	Providers  []string
}

type WebServerProcessor added in v0.9.4 

type WebServerProcessor = func(w http.ResponseWriter, r *http.Request) error

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 added in v0.6.1 

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

type YamlOptions 

type YamlOptions struct {
	Dir       string
	Providers []string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.