events

package
v0.0.3 Latest Latest
Warning

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

Go to latest
Published: Aug 14, 2023 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Event

type Event struct {
	EventType string
	Source    string
	Sink      string
	ID        int
	StartTime string
	Format    EventFormat
}

type EventFormat

type EventFormat int
const (
	Legacy EventFormat = iota
	CloudEvent
)

func EventFormatFromString

func EventFormatFromString(format string) EventFormat

func (EventFormat) String

func (e EventFormat) String() string

type Factory

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

func NewGeneratorFactory

func NewGeneratorFactory(senderC chan<- Event) *Factory

func (*Factory) ConfigureAndStartGenerator

func (f *Factory) ConfigureAndStartGenerator(sub *v1alpha2.Subscription, eventType string) *Generator

func (*Factory) OnChangedSubscription

func (f *Factory) OnChangedSubscription(subscription *unstructured.Unstructured)

func (*Factory) OnDeleteSubscription

func (f *Factory) OnDeleteSubscription(subscription *unstructured.Unstructured)

func (*Factory) OnNewSubscription

func (f *Factory) OnNewSubscription(subscription *unstructured.Unstructured)

func (*Factory) StartReconcile

func (f *Factory) StartReconcile(subscription *unstructured.Unstructured)

func (*Factory) Stop

func (f *Factory) Stop()

type Generator

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

func NewGenerator

func NewGenerator(eventType, source string, eps int, format string, senderC chan<- Event) *Generator

func (*Generator) Start

func (e *Generator) Start()

func (*Generator) Stop

func (e *Generator) Stop()

func (*Generator) Update

func (e *Generator) Update(format EventFormat)

type NamespaceName

type NamespaceName struct {
	Name, Namespace string
}

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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