zephyr

Documentation

Index

• type Client
  • func NewClient() (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) SendMessage(sender, class, instance string, body []string) error
  • func (c *Client) SubscribeAndListen(class, instance string) (<-chan *zephyr.Message, error)
  • func (c *Client) TicketExpirationTime() time.Time

Types

type Client

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

func NewClient

func NewClient() (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) SendMessage

func (c *Client) SendMessage(sender, class, instance string, body []string) error

func (*Client) SubscribeAndListen

func (c *Client) SubscribeAndListen(class, instance string) (<-chan *zephyr.Message, error)

SubscribeAndListen starts listening to a zephyr class and instance tuple. To listen for all instances on a class, pass "*" as the instance. Zephyr classes and instances are case-insensitive and messages of any case may be returned.

func (*Client) TicketExpirationTime

func (c *Client) TicketExpirationTime() time.Time