input

package
v0.6.14 Latest Latest
Warning

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

Go to latest
Published: Dec 13, 2023 License: MIT Imports: 35 Imported by: 0

Documentation

Index

Constants

View Source
const (
	EventCanonicalType = "com.vmware.event.router"
	EventSpecVersion   = cloudevents.VersionV1
	EventContentType   = cloudevents.ApplicationJSON
)

Variables

This section is empty.

Functions

func NewFromVSphere added in v0.3.25

func NewFromVSphere(vcEvent vctypes.BaseEvent, source string, options ...Option) (*cloudevents.Event, error)

NewFromVSphere returns a compliant CloudEvent for the given vSphere event

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
	KubeURL           string
	WinEventURL       string
	RancherURL        string
	AlertmanagerURL   string
	GitlabURL         string
	DataDogURL        string
	Site24x7URL       string
	CloudflareURL     string
	GoogleURL         string
	AWSURL            string
	ZabbixURL         string
	CustomJsonURL     string
	VCenterURL        string
	ObserviumEventURL string
	TeamcityURL       string

	ServerName    string
	Listen        string
	Tls           bool
	Insecure      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 NomadInput added in v0.6.9

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

func NewNomadInput added in v0.6.9

func NewNomadInput(options NomadInputOptions, processors *common.Processors, observability *common.Observability) *NomadInput

func (*NomadInput) Start added in v0.6.9

func (n *NomadInput) Start(wg *sync.WaitGroup, outputs *common.Outputs)

type NomadInputOptions added in v0.6.9

type NomadInputOptions struct {
	Address string
	Token   string
	Topics  []string
}

type Option added in v0.3.25

type Option func(e *cloudevents.Event) error

func WithAttributes added in v0.3.25

func WithAttributes(ceAttrs map[string]string) Option

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
}

type VCenterInput added in v0.4.0

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

func NewVCenterInput added in v0.4.0

func NewVCenterInput(options VCenterInputOptions, processors *common.Processors, observability *common.Observability) *VCenterInput

func (*VCenterInput) Start added in v0.4.0

func (vc *VCenterInput) Start(wg *sync.WaitGroup, _ *common.Outputs)

type VCenterInputOptions added in v0.4.0

type VCenterInputOptions struct {
	URL           string
	InsecureSSL   bool
	Checkpoint    bool
	AuthType      string
	AuthBasicName string
	AuthBasicPass string
	RootCA        string
	CheckpointDir string
	DelayMS       int
}

Jump to

Keyboard shortcuts

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