event

package
v0.2.2 Latest Latest
Warning

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

 Go to latest Published: Feb 24, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.