pubsub

Documentation

Index

• type PubSub
  • func New(buffer int) (*PubSub, error)
  • func (ps *PubSub) Close() error
  • func (ps *PubSub) Publish(v interface{}) error
  • func (ps *PubSub) Subscribe(s Subscriber) error
  • func (ps *PubSub) UnSubscribe(s Subscriber)
• type Subscriber

Types

type PubSub

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

PubSub contains channel and subscribers.

func New

func New(buffer int) (*PubSub, error)

New return new PubSub intreface.

func (*PubSub) Close

func (ps *PubSub) Close() error

Close closes PubSub. To inspect unbsubscribing for another subscruber, you must create message structure to notify them. After publish notifycations, Close should be called.

func (*PubSub) Publish

func (ps *PubSub) Publish(v interface{}) error

Publish will publish message to subscribers

func (*PubSub) Subscribe

func (ps *PubSub) Subscribe(s Subscriber) error

Subscribe subscribe to the PubSub.

func (*PubSub) UnSubscribe

func (ps *PubSub) UnSubscribe(s Subscriber)

UnSubscribe un subscribe to the PubSub.

type Subscriber

type Subscriber interface {
	// should be unique to used as a map key
	SubscriberName() string
	// receive message from publisher
	OnMessage(v interface{})
}

Subscriber is interface that who want to consume message