pubsub

Documentation

Index

• Constants
• type Event
• type EventType
• type Interface
• type PubSub
  • func New() *PubSub
  • func (s *PubSub) Publish(evt Event)
  • func (s *PubSub) Subscribe(ctx context.Context, filter Selector) watch.Interface
• type Selector

Constants

const (
	Added    = watch.Added
	Modified = watch.Modified
	Deleted  = watch.Deleted
)

Types

type Event

type Event = watch.Event

type EventType

type EventType = watch.EventType

type Interface

type Interface = watch.Interface

type PubSub

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

func New

func New() *PubSub

func (*PubSub) Publish

func (s *PubSub) Publish(evt Event)

func (*PubSub) Subscribe

func (s *PubSub) Subscribe(ctx context.Context, filter Selector) watch.Interface

type Selector

type Selector struct {
	Type      runtime.Object
	Namespace string
	Name      string
	// contains filtered or unexported fields
}