akamai

Documentation

Index

• func Int64ToString(i int64) string
• func New(options map[string]interface{}) (collector.Client, error)
• func UnixStringToTime(s string) time.Time
• type Client
  • func (akamaiClent *Client) ClientType() collector.ClientType
  • func (akamaiClient *Client) Exit() (err error)
  • func (akamaiClient *Client) GetEvents(eventUrl string, body []byte, resultsChannel chan<- string) (count, total, pageNumber, pageSize int, err error)
  • func (akamaiClient *Client) Poll(timestamp time.Time, resultsChannel chan<- string, pollOffset int) (count int, currentTimestamp time.Time, err error)
  • func (akamaiClient *Client) Stream(streamChannel chan<- string) (cancelFunc func(), err error)
• type DetailBody
• type DetailResponse

Functions

func Int64ToString

func Int64ToString(i int64) string

func New

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

func UnixStringToTime

func UnixStringToTime(s string) time.Time

Types

type Client

type Client struct {
	collector.Client
	Options map[string]interface{}
	// contains filtered or unexported fields
}

func (*Client) ClientType

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

func (*Client) Exit

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

func (*Client) GetEvents

func (akamaiClient *Client) GetEvents(eventUrl string, body []byte, resultsChannel chan<- string) (count, total, pageNumber, pageSize int, err error)

Get events

func (*Client) Poll

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

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

func (*Client) Stream

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

type DetailBody

type DetailBody struct {
	StartTimeSec int    `json:"startTimeSec"`
	EndTimeSec   int    `json:"endTimeSec"`
	OrderBy      string `json:"orderBy"`
	PageNumber   int    `json:"pageNumber"`
	PageSize     int    `json:"pageSize"`
	Filters      struct {
	} `json:"filters"`
}

type DetailResponse

type DetailResponse struct {
	PageInfo struct {
		TotalRecords int `json:"totalRecords"`
		PageNumber   int `json:"pageNumber"`
		PageSize     int `json:"pageSize"`
	} `json:"pageInfo"`
	DataRows []interface{} `json:"dataRows"`
}