event

Documentation

Index

• type Broker
  • func NewBroker(stopCh <-chan struct{}) *Broker
  • func (b *Broker) Enqueue(msg Message)
  • func (b *Broker) GetMessageBus() *pubsub.PubSub
  • func (b *Broker) Unsub(pubSub *pubsub.PubSub, ch chan interface{})
• type EventType
• type Message
• type ServiceExportEvent
  • func (e *ServiceExportEvent) ClusterKey() string

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