pubsub

Documentation

Index

• func New(options map[string]interface{}) (collector.Client, error)
• type Client
  • func (pubsubClient *Client) ClientType() collector.ClientType
  • func (pubsubClient *Client) Exit() (err error)
  • func (pubsubClient *Client) Poll(timestamp time.Time, resultsChannel chan<- string, pollOffset int) (count int, currentTimestamp time.Time, err error)
  • func (pubsubClient *Client) Stream(streamChannel chan<- string) (cancelFunc func(), err error)

Functions

func New

func New(options map[string]interface{}) (collector.Client, error)

New will initialize and return an authorized Client

Types

type Client

type Client struct {
	collector.Client
	Options map[string]interface{}
}

func (*Client) ClientType

func (pubsubClient *Client) ClientType() collector.ClientType

func (*Client) Exit

func (pubsubClient *Client) Exit() (err error)

func (*Client) Poll

func (pubsubClient *Client) Poll(timestamp time.Time, resultsChannel chan<- string, pollOffset int) (count int, currentTimestamp time.Time, err error)

func (*Client) Stream

func (pubsubClient *Client) Stream(streamChannel chan<- string) (cancelFunc func(), err error)