pubsub

Documentation

Index

• type NameFilter
• type NamePubSub
  • func NewNamePubSub() NamePubSub
• type NameSubscription
• type ObjectType

Types

type NameFilter

type NameFilter func(ObjectType) bool

type NamePubSub

type NamePubSub interface {
	Publish(ObjectType)
	Subscribe(...NameFilter) NameSubscription
}

NamePubSub -

func NewNamePubSub

func NewNamePubSub() NamePubSub

NewName constructs and returns a new Name

type NameSubscription

type NameSubscription interface {
	Channel() <-chan ObjectType
	Next() (ObjectType, error)
	Cancel()
}

NameSubscription is returned for every subscription

type ObjectType

type ObjectType generic.Type // nolint