Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

event

package

Go to main page

Versions in this module

v0

v0.2.0

Feb 16, 2025

v0.1.1

Jan 21, 2024

v0.1.0

Jan 14, 2024

Changes in this version

+ var ErrMuxClosed = errors.New("event: mux closed")

+ type Feed struct

+ func (f *Feed) Send(value interface{}) (nsent int)

+ func (f *Feed) Subscribe(channel interface{}) Subscription

+ type FeedOf struct

+ func (f *FeedOf[T]) Send(value T) (nsent int)

+ func (f *FeedOf[T]) Subscribe(channel chan<- T) Subscription

+ type ResubscribeErrFunc func(context.Context, error) (Subscription, error)

+ type ResubscribeFunc func(context.Context) (Subscription, error)

+ type Subscription interface

+ Err func() <-chan error

+ Unsubscribe func()

+ func JoinSubscriptions(subs ...Subscription) Subscription

+ func NewSubscription(producer func(<-chan struct{}) error) Subscription

+ func Resubscribe(backoffMax time.Duration, fn ResubscribeFunc) Subscription

+ func ResubscribeErr(backoffMax time.Duration, fn ResubscribeErrFunc) Subscription

+ type SubscriptionScope struct

+ func (sc *SubscriptionScope) Close()

+ func (sc *SubscriptionScope) Count() int

+ func (sc *SubscriptionScope) Track(s Subscription) Subscription

+ type TypeMux struct

+ func (mux *TypeMux) Post(ev interface{}) error

+ func (mux *TypeMux) Stop()

+ func (mux *TypeMux) Subscribe(types ...interface{}) *TypeMuxSubscription

+ type TypeMuxEvent struct

+ Data interface{}

+ Time time.Time

+ type TypeMuxSubscription struct

+ func (s *TypeMuxSubscription) Chan() <-chan *TypeMuxEvent

+ func (s *TypeMuxSubscription) Closed() bool

+ func (s *TypeMuxSubscription) Unsubscribe()