Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

pubsub

package module

Go to main page

Versions in this module

v0

v0.1.7

May 14, 2021

v0.1.6

May 11, 2021

Changes in this version

type Subscriber

+ func (s *Subscriber) Consumable() bool

+ func (s *Subscriber) Destroy()

+ func (s *Subscriber) Listener() chan struct{}

v0.1.5

May 9, 2021

Changes in this version

type PubSub

+ func (p *PubSub) IsAlive() bool

v0.1.4

May 7, 2021

Changes in this version

+ type Binary []byte

+ func (b *Binary) ReadFrom(r io.Reader) (int64, error)

+ func (b Binary) Bytes() []byte

+ func (b Binary) String() string

+ func (b Binary) WriteTo(w io.Writer) (int64, error)

type Message

+ func (m *Message) ReadFrom(r io.Reader) (int64, error)

+ func (m *Message) WriteTo(w io.Writer) (int64, error)

type PublishedMessage

+ func (p *PublishedMessage) ReadFrom(r io.Reader) (int64, error)

+ func (p *PublishedMessage) WriteTo(w io.Writer) (int64, error)

+ type String string

+ func (s *String) ReadFrom(r io.Reader) (int64, error)

+ func (s String) Bytes() []byte

+ func (s String) String() string

+ func (s String) WriteTo(w io.Writer) (int64, error)

v0.1.3

May 6, 2021

Changes in this version

type PubSub

+ SafetyChan chan *SafetyMode

+ SafetyMode bool

+ func (p *PubSub) AllowUnsafe() bool

+ func (p *PubSub) OnlySafe() bool

+ type SafetyMode struct

+ Enable bool

+ ResponseChan chan bool

v0.1.2

May 3, 2021

Changes in this version

type PubSub

+ func (p *PubSub) BPublish(msg *Message, delay time.Duration) (bool, uint64)

type PublishRequest

+ BlockFor time.Duration

v0.1.1

Apr 29, 2021

v0.1.0

Apr 28, 2021

Changes in this version

+ type Message struct

+ Data []byte

+ Topics []string

+ type PubSub struct

+ Alive bool

+ Index uint64

+ MessageChan chan *PublishRequest

+ SubscribeChan chan *SubscriptionRequest

+ SubscriberIdChan chan chan uint64

+ Subscribers map[string]map[uint64]chan *PublishedMessage

+ UnsubscribeChan chan *UnsubscriptionRequest

+ func New() *PubSub

+ func (p *PubSub) AddSubscription(subscriber *Subscriber, topics ...string) (bool, uint64)

+ func (p *PubSub) Publish(msg *Message) (bool, uint64)

+ func (p *PubSub) Start(ctx context.Context)

+ func (p *PubSub) Subscribe(cap uint64, topics ...string) *Subscriber

+ func (p *PubSub) Unsubscribe(subscriber *Subscriber, topics ...string) (bool, uint64)

+ func (p *PubSub) UnsubscribeAll(subscriber *Subscriber) (bool, uint64)

+ type PublishRequest struct

+ Message *Message

+ ResponseChan chan uint64

+ type PublishedMessage struct

+ Data []byte

+ Topic string

+ type Subscriber struct

+ Channel chan *PublishedMessage

+ Id uint64

+ Topics map[string]bool

+ func (s *Subscriber) AddSubscription(pubsub *PubSub, topics ...string) (bool, uint64)

+ func (s *Subscriber) BNext(delay time.Duration) *PublishedMessage

+ func (s *Subscriber) Close() bool

+ func (s *Subscriber) Next() *PublishedMessage

+ func (s *Subscriber) Unsubscribe(pubsub *PubSub, topics ...string) (bool, uint64)

+ func (s *Subscriber) UnsubscribeAll(pubsub *PubSub) (bool, uint64)

+ type SubscriptionRequest struct

+ ResponseChan chan uint64

+ Subscriber *Subscriber

+ type UnsubscriptionRequest struct

+ Id uint64

+ ResponseChan chan uint64

+ Topics []string