input

package
v0.3.1 Latest Latest
Warning

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

Go to latest
Published: Apr 7, 2022 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type HttpInput

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

func NewHttpInput

func NewHttpInput(options HttpInputOptions, processors *common.Processors, observability *common.Observability) *HttpInput

func (*HttpInput) Start

func (h *HttpInput) Start(wg *sync.WaitGroup, outputs *common.Outputs)

type HttpInputOptions

type HttpInputOptions struct {
	K8sURL          string
	RancherURL      string
	AlertmanagerURL string
	GitlabURL       string
	DataDogURL      string
	Site24x7URL     string
	CloudflareURL   string
	GoogleURL       string
	CustomJsonURL   string
	Listen          string
	Tls             bool
	Cert            string
	Key             string
	Chain           string
	HeaderTraceID   string
}

type HttpProcessHandleFunc added in v0.1.0

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

type PubSubInput added in v0.2.0

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

func NewPubSubInput added in v0.2.0

func NewPubSubInput(options PubSubInputOptions, processors *common.Processors, observability *common.Observability) *PubSubInput

func (*PubSubInput) Start added in v0.2.0

func (ps *PubSubInput) Start(wg *sync.WaitGroup, outputs *common.Outputs)

type PubSubInputOptions added in v0.2.0

type PubSubInputOptions struct {
	Credentials  string
	ProjectID    string
	Subscription string
}

Jump to

Keyboard shortcuts

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