events

Documentation

Index

• type Event
• type EventFormat
  • func EventFormatFromString(format string) EventFormat
  • func (e EventFormat) String() string
• type Factory
  • func NewGeneratorFactory(senderC chan<- Event) *Factory
  • func (f *Factory) ConfigureAndStartGenerator(sub *v1alpha2.Subscription, eventType string) *Generator
  • func (f *Factory) OnChangedSubscription(subscription *unstructured.Unstructured)
  • func (f *Factory) OnDeleteSubscription(subscription *unstructured.Unstructured)
  • func (f *Factory) OnNewSubscription(subscription *unstructured.Unstructured)
  • func (f *Factory) StartReconcile(subscription *unstructured.Unstructured)
  • func (f *Factory) Stop()
• type Generator
  • func NewGenerator(eventType, source string, eps int, format string, senderC chan<- Event) *Generator
  • func (e *Generator) Start()
  • func (e *Generator) Stop()
  • func (e *Generator) Update(format EventFormat)
• type NamespaceName

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
}