input

package
v0.3.25 Latest Latest
Warning

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

Go to latest
Published: Jul 12, 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
	WinEventURL     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 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 VCInput added in v0.3.25

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

func NewVCInput added in v0.3.25

func NewVCInput(options VCInputOptions, processors *common.Processors, observability *common.Observability) *VCInput

func (*VCInput) Start added in v0.3.25

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

type VCInputOptions added in v0.3.25

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