client

package

v0.1.1 Latest Latest Go to latest Published: May 8, 2018 License: MIT Imports: 16 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/prologic/msgbus

Documentation ¶

Index ¶

Constants
Variables
type Client
- func NewClient(url string, options *Options) *Client
type Options
type Subscriber
- func NewSubscriber(client *Client, topic string, handler msgbus.HandlerFunc) *Subscriber
- func (s *Subscriber) Start()
- func (s *Subscriber) Stop()

Constants ¶

View Source

const (
	// DefaultReconnectInterval ...
	DefaultReconnectInterval = 2

	// DefaultMaxReconnectInterval ...
	DefaultMaxReconnectInterval = 64
)

Variables ¶

View Source

var (
	// PublishedRegexp ...
	PublishedRegexp = regexp.MustCompile(
		"message successfully published to \\w+ with sequence \\d",
	)
)

Functions ¶

This section is empty.

Types ¶

type Client ¶

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

Client ...

func NewClient ¶

func NewClient(url string, options *Options) *Client

NewClient ...

func (*Client) Handle ¶

func (c *Client) Handle(msg *msgbus.Message) error

Handle ...

func (*Client) Publish ¶

func (c *Client) Publish(topic, message string) error

Publish ...

func (*Client) Pull ¶

func (c *Client) Pull(topic string) (msg *msgbus.Message, err error)

Pull ...

func (c *Client) Subscribe(topic string, handler msgbus.HandlerFunc) *Subscriber

Subscribe ...

type Options ¶

type Options struct {
	ReconnectInterval    int
	MaxReconnectInterval int
}

Options ...

type Subscriber ¶

type Subscriber struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

Subscriber ...

func NewSubscriber ¶

func NewSubscriber(client *Client, topic string, handler msgbus.HandlerFunc) *Subscriber

NewSubscriber ...

func (*Subscriber) Start ¶

func (s *Subscriber) Start()

Start ...

func (*Subscriber) Stop ¶

func (s *Subscriber) Stop()

Stop ...

Source Files ¶

View all Source files

client.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL