input

package
v0.3.23 Latest Latest
Warning

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

Go to latest
Published: Jun 20, 2022 License: MIT Imports: 17 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 {
	HealthcheckURL  string
	K8sURL          string
	RancherURL      string
	AlertmanagerURL string
	GitlabURL       string
	DataDogURL      string
	Site24x7URL     string
	CloudflareURL   string
	GoogleURL       string
	AWSURL          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