umbrella

Documentation

Index

• func New(options map[string]interface{}) (collector.Client, error)
• type ActivityResponse
• type AuthResponse
• type Client
  • func (umbrellaClient *Client) ClientType() collector.ClientType
  • func (umbrellaClient *Client) Exit() (err error)
  • func (umbrellaClient *Client) Poll(timestamp time.Time, resultsChannel chan<- string, pollOffset int) (count int, currentTimestamp time.Time, err error)
  • func (umbrellaClient *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 ActivityResponse

type ActivityResponse struct {
	Meta interface{}   `json:"meta"`
	Data []interface{} `json:"data"`
}

type AuthResponse

type AuthResponse struct {
	TokenType   string `json:"token_type"`
	AccessToken string `json:"access_token"`
	ExpiresIn   int    `json:"expires_in"`
}

type Client

type Client struct {
	collector.Client
	Options     map[string]interface{}
	AccessToken string `json:"access_token"`
	// contains filtered or unexported fields
}

func (*Client) ClientType

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

func (*Client) Exit

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

func (*Client) Poll

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

Collect will query the source and pass the results back through a result channel

func (*Client) Stream

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