subscription

Documentation

Index

• type ISubscription
• type Message
• type Registry
  • func (r *Registry) Add(subscription ISubscription) error
  • func (r *Registry) OnEvent(msg Message) error

Types

type ISubscription

type ISubscription interface {
	OnEvent(msg Message)
	WithElectedResource() interface{}
	// Return an empty array for all event types or selective set an event type to filter for
	//Added    EventType = "ADDED"
	//Modified EventType = "MODIFIED"
	//Deleted  EventType = "DELETED"
	//Bookmark EventType = "BOOKMARK"
	//Error    EventType = "ERROR"
	WithEventType() []watch.EventType
}

type Message

type Message struct {
	Client kubernetes.Interface
	Event  watch.Event
}

type Registry

type Registry struct {
	Subscriptions []ISubscription
}

func (*Registry) Add

func (r *Registry) Add(subscription ISubscription) error

func (*Registry) OnEvent

func (r *Registry) OnEvent(msg Message) error