analytics

type Attribute struct {
	Name  string
	Value interface{}
}

type Manager interface {
	Start()
	Close()
	SendRecords(authContext *auth.Context, records []Record) error
}

type Options struct {
	// LegacyEndpoint is true if using older direct-submit protocol (opdk)
	LegacyEndpoint bool
	// BufferPath is the directory where the adapter will buffer analytics records.
	BufferPath string
	// StagingFileLimit is the maximum number of files stored in the staging directory.
	// Once this is reached, the oldest files will start being removed.
	StagingFileLimit int
	// Base Apigee URL (legacy saas)
	BaseURL *url.URL
	// Client is a configured HTTPClient
	Client *http.Client
	// SendChannelSize is the size of the records channel
	SendChannelSize int
	// collection interval
	CollectionInterval time.Duration
	// contains filtered or unexported fields
}

type Record struct {
	ClientReceivedStartTimestamp int64       `json:"client_received_start_timestamp"`
	ClientReceivedEndTimestamp   int64       `json:"client_received_end_timestamp"`
	TargetSentStartTimestamp     int64       `json:"target_sent_start_timestamp,omitempty"`
	TargetSentEndTimestamp       int64       `json:"target_sent_end_timestamp,omitempty"`
	TargetReceivedStartTimestamp int64       `json:"target_received_start_timestamp,omitempty"`
	TargetReceivedEndTimestamp   int64       `json:"target_received_end_timestamp,omitempty"`
	ClientSentStartTimestamp     int64       `json:"client_sent_start_timestamp"`
	ClientSentEndTimestamp       int64       `json:"client_sent_end_timestamp"`
	RecordType                   string      `json:"recordType"`
	APIProxy                     string      `json:"apiproxy"`
	RequestURI                   string      `json:"request_uri"`
	RequestPath                  string      `json:"request_path"`
	RequestVerb                  string      `json:"request_verb"`
	ClientIP                     string      `json:"client_ip,omitempty"`
	UserAgent                    string      `json:"useragent"`
	APIProxyRevision             int         `json:"apiproxy_revision"`
	ResponseStatusCode           int         `json:"response_status_code"`
	DeveloperEmail               string      `json:"developer_email,omitempty"`
	DeveloperApp                 string      `json:"developer_app,omitempty"`
	AccessToken                  string      `json:"access_token,omitempty"`
	ClientID                     string      `json:"client_id,omitempty"`
	APIProduct                   string      `json:"api_product,omitempty"`
	Organization                 string      `json:"organization"`
	Environment                  string      `json:"environment"`
	GatewaySource                string      `json:"gateway_source"`
	GatewayFlowID                string      `json:"gateway_flow_id"`
	Attributes                   []Attribute `json:"-"`
}