pubsub

func (*Hub) Acquire ¶

func (h *Hub) Acquire() *blobcache.Message

func (*Hub) Lookup ¶

func (h *Hub) Lookup(hash [32]byte) blobcache.TID

Lookup attempts to reverse hash. The zero value is returned an unknown topic

func (*Hub) Publish ¶

func (h *Hub) Publish(tmsg *blobcache.Message) int

Publish will return the number of destinations the topic was sent to tmsg should have been obtained using Acquire. After Publish is called, the caller does not need to call Release on the message.

func (*Hub) Release ¶

func (h *Hub) Release(x *blobcache.Message)

func (*Hub) Subscribe ¶

func (h *Hub) Subscribe(tid blobcache.TID, ch chan<- *blobcache.Message) error

Subscribe subscribes to a topic. Future calls to Publish will result in a message being sent on this channel.

func (*Hub) Unsubscribe ¶

func (h *Hub) Unsubscribe(tid blobcache.TID, ch chan<- *blobcache.Message) bool

Unsubscribe ensures that the channel is not subscribed to the topic. If it is effectful then true is returned. If nothing has to be done, then false is returned.