input

package
v0.5.7 Latest Latest
Warning

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

Go to latest
Published: Aug 25, 2022 License: MIT Imports: 34 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

	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 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