Documentation
¶
Index ¶
Constants ¶
View Source
const (
CtxTransactionID log.ContextField = "transactionID"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EventsHandler ¶
type EventsHandler struct {
// contains filtered or unexported fields
}
EventsHandler -
func NewEventsHandler ¶
func NewEventsHandler(ctx context.Context, logData []byte) (*EventsHandler, error)
NewEventsHandler - return a new EventProcessor
func (*EventsHandler) Handle ¶
func (p *EventsHandler) Handle() []beat.Event
Handle - processes the batch of events from the http request
type MetricsProcessor ¶
type MetricsProcessor struct {
// contains filtered or unexported fields
}
MetricsProcessor -
func NewMetricsProcessor ¶
func NewMetricsProcessor(ctx context.Context) MetricsProcessor
type Route ¶
type Route struct {
ID string `json:"id"`
UpdatedAt int64 `json:"updated_at"`
Protocols []string `json:"protocols"`
StripPath bool `json:"strip_path"`
CreatedAt int64 `json:"created_at"`
WsID string `json:"ws_id"`
Service map[string]string `json:"service"`
Name string `json:"name"`
Hosts []string `json:"hosts"`
PreserveHost bool `json:"preserve_host"`
RegexPriority int `json:"regex_priority"`
Paths []string `json:"paths"`
ResponseBuffering bool `json:"response_buffering"`
HttpsRedirectStatusCode int `json:"https_redirect_status_code"`
PathHandling string `json:"path_handling"`
RequestBuffering bool `json:"request_buffering"`
}
type Service ¶
type Service struct {
Host string `json:"host"`
CreatedAt int64 `json:"created_at"`
ConnectTimeout int `json:"connect_timeout"`
ID string `json:"id"`
Protocol string `json:"protocol"`
Name string `json:"name"`
ReadTimeout int `json:"read_timeout"`
Port int `json:"port"`
Path string `json:"path"`
UpdatedAt int64 `json:"updated_at"`
WriteTimeout int `json:"write_timeout"`
Retries int `json:"retries"`
WsID string `json:"ws_id"`
}
type TrafficLogEntry ¶
type TrafficLogEntry struct {
ClientIP string `json:"client_ip"`
StartedAt int64 `json:"started_at"`
UpstreamURI string `json:"upstream_uri"`
Latencies *Latencies `json:"latencies"`
Request *Request `json:"request"`
Response *Response `json:"response"`
Route *Route `json:"route"`
Service *Service `json:"service"`
Consumer *Consumer `json:"consumer"`
ShouldSample bool
}
TrafficLogEntry - Represents the structure of log entry the agent will receive from Kong's HTTP Log Plugin
type TransactionProcessor ¶
type TransactionProcessor struct {
// contains filtered or unexported fields
}
TransactionProcessor -
func NewTransactionProcessor ¶
func NewTransactionProcessor(ctx context.Context) *TransactionProcessor
Click to show internal directories.
Click to hide internal directories.