proxy

type AgentReport struct {
	Type    string `json:"type"`
	Version string `json:"version"`
}

type ApplicationReport struct {
	Environment string `json:"environment,omitempty"`
}

type LogReport struct {
	SecretKey   string            `json:"secretKey,omitempty"`
	Application ApplicationReport `json:"application"`
	Runtime     RuntimeReport     `json:"runtime"`
	Agent       AgentReport       `json:"agent"`
	Logs        []ReportLog       `json:"logs,omitempty"`
}

type ReportDataCollectionRule struct {
	FilterHash string                 `json:"filterHash,omitempty"`
	Params     map[string]interface{} `json:"params,omitempty"`
	Signature  string                 `json:"signature"`
}

type ReportLog struct {
	LogLevel string `json:"logLevel"`

	StartedAt                 int                         `json:"startedAt,omitempty"` // Unix timestamp UTC milliseconds
	EndedAt                   int                         `json:"endedAt,omitempty"`   // Unix timestamp UTC milliseconds
	Type                      string                      `json:"type,omitempty"`      // REQUEST_END on success, REQUEST_ERROR on connection errors
	Stage                     string                      `json:"stageType,omitempty"`
	ActiveDataCollectionRules *[]ReportDataCollectionRule `json:"activeDataCollectionRules,omitempty"` // More compact than sending the complete rule.

	Port     uint16 `json:"port"`
	Protocol string `json:"protocol"` // Scheme: http[s]
	Hostname string `json:"hostname"`

	Path           string      `json:"path,omitempty"`
	Method         string      `json:"method,omitempty"`
	URL            string      `json:"url,omitempty"`
	RequestHeaders http.Header `json:"requestHeaders"`

	ResponseHeaders http.Header `json:"responseHeaders"`
	StatusCode      int         `json:"statusCode,omitempty"`

	// filters.StageBodies. Note that these 4 may very well NOT be valid strings.
	RequestBody  string `json:"requestBody,omitempty"`
	ResponseBody string `json:"responseBody,omitempty"`
	// Payload SHAs
	RequestBodyPayloadSHA  string `json:"requestBodyPayloadSha,omitempty"`
	ResponseBodyPayloadSHA string `json:"responseBodyPayloadSha,omitempty"`

	// Error
	ErrorCode        string `json:"errorCode,omitempty"`
	ErrorFullMessage string `json:"errorFullMessage,omitempty"`
}

type RuntimeReport struct {
	Version  string `json:"version"`
	Arch     string `json:"arch"`
	Platform string `json:"platform"`
	Type     string `json:"type"`
	Hostname string `json:"hostname,omitempty"`
}

type Sender struct {
	// Finish is used to transmit the app termination request to the background
	// sending loop.
	Finish chan struct{}

	// done is used by the background sending loop to confirm it is done, allowing
	// Stop to wait for a clean exit
	Done chan struct{}

	// ForceFinish is a channel that is closed when we no longer wish to wait for
	// draining to complete.
	ForceFinish chan struct{}

	// Draining is a channel that is closed when the sender is finishing. It is
	// used to stop Send enqueuing further logs.
	Draining chan struct{}

	// FanIn receives the ReportLog elements to send from all the goroutines
	// created on API calls termination, serializing them to the background sending loop.
	FanIn chan ReportLog

	// Acks receives the acknowledgments from the HTTP sending the marshaled
	// ReportLog elements to the Bearer platform.
	//
	// In this version, each element has value 1. When sending gets to be batched
	// in a later version, this value will represent the number of acknowledged
	// LogReport elements actually transmitted.
	Acks chan uint

	// InFlight is the number of ReportLog elements awaiting delivery to the
	// Bearer platform.
	InFlight uint

	// Lost is the number of lost and never sent ReportLog elements. It is reset
	// to 0 when transmission resumes.
	Lost uint

	// Counter is the total number of records handled.
	Counter uint

	// InflightLimit is the maximum value of Inflight before bandwidth reduction
	// is triggered. When InFlight exceeds this value, extra ReportLog elements
	// are dropped, only counting the number of lost elements, to avoid saturation
	// of the client process and network.
	InFlightLimit uint

	// LogEndpoint is the URL of the Bearer host receiving the logs.
	LogEndpoint string

	// EnvironmentType is the runtime environment type, e.g. staging or production.
	EnvironmentType string

	// SecretKey is the account secret key.
	SecretKey string

	// Version is the agent version.
	Version string

	http.Client
	*zerolog.Logger
}

type Stage string