natsc

Documentation

Index

• type Client
  • func Connect(addr, clusterID, clientID string) (*Client, error)
  • func (c *Client) Publish(subject string, message []byte, validateJSON bool) error
  • func (c *Client) Subscribe(subject string, delta time.Duration) (chan json.RawMessage, error)
  • func (c Client) Validate(data []byte) error

Types

type Client

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

func Connect

func Connect(addr, clusterID, clientID string) (*Client, error)

func (*Client) Publish

func (c *Client) Publish(subject string, message []byte, validateJSON bool) error

func (*Client) Subscribe

func (c *Client) Subscribe(subject string, delta time.Duration) (chan json.RawMessage, error)

func (Client) Validate

func (c Client) Validate(data []byte) error