queue

Documentation

Index

• Variables
• func New(url string) (*queue, error)
• type Queue

Variables

var DefaultURI = nats.DefaultURL

Functions

func New

func New(url string) (*queue, error)

Types

type Queue

type Queue interface {
	Publish(subject string, data interface{}) error
	Subscribe(subject string, fn interface{}) error

	Close()
}