event

package
v0.2.11 Latest Latest
Warning

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

Go to latest
Published: Oct 8, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Broker

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

func NewBroker

func NewBroker(stopCh <-chan struct{}) *Broker

func (*Broker) Enqueue

func (b *Broker) Enqueue(msg Message)

func (*Broker) GetMessageBus

func (b *Broker) GetMessageBus() *pubsub.PubSub

func (*Broker) Unsub

func (b *Broker) Unsub(pubSub *pubsub.PubSub, ch chan interface{})

type EventType

type EventType string
const (
	ServiceExportCreated  EventType = "service.export.created"
	ServiceExportDeleted  EventType = "service.export.deleted"
	ServiceExportAccepted EventType = "service.export.accepted"
	ServiceExportRejected EventType = "service.export.rejected"
)

type Message

type Message struct {
	Kind   EventType
	OldObj interface{}
	NewObj interface{}
}

type ServiceExportEvent

type ServiceExportEvent struct {
	Geo           *config.ConnectorConfig
	ServiceExport *svcexpv1alpha1.ServiceExport
	Service       *corev1.Service
	Error         string
}

func (*ServiceExportEvent) ClusterKey

func (e *ServiceExportEvent) ClusterKey() string

Jump to

Keyboard shortcuts

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