pubsub

Documentation

Overview

Package pubsub simulates a package that provides publication/subscription type services.

Index

• type PubSub
  • func New(host string) *PubSub
  • func (ps *PubSub) Publish(key string, v interface{}) error
  • func (ps *PubSub) Subscribe(key string) error

Types

type PubSub

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

PubSub provides access to a queue system.

func New

func New(host string) *PubSub

New creates a pubsub value for use.

func (*PubSub) Publish

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

Publish sends the data for the specified key.

func (*PubSub) Subscribe

func (ps *PubSub) Subscribe(key string) error

Subscribe sets up an request to receive messages for the specified key.