client

Documentation

Index

• func Subscribe(url, topic string, opt Options) (messages <-chan *types.Any, errors <-chan error, done chan<- struct{}, ...)
• type Options

Functions

func Subscribe

func Subscribe(url, topic string, opt Options) (
	messages <-chan *types.Any,
	errors <-chan error,
	done chan<- struct{},
	err error,
)

Subscribe subscribes to a topic hosted at given url. It returns a channel of incoming events and errors as well as done which will close the connection and exit the subscriber.

Types

type Options

type Options struct {
	// SocketDir is the directory to look for socket files for unix:// urls
	SocketDir string

	// Path is the URL path, if the server's handler is at the mux path (e.g. /events)
	Path string
}

Options contain client options