processor

Documentation

Index

• Constants
• type Consumer
• type EventsHandler
  • func NewEventsHandler(ctx context.Context, logData []byte) (*EventsHandler, error)
  • func (p *EventsHandler) Handle() []beat.Event
• type Latencies
• type MetricsProcessor
  • func NewMetricsProcessor(ctx context.Context) MetricsProcessor
• type Request
• type Response
• type Route
• type Service
• type TLS
• type TrafficLogEntry
• type TransactionProcessor
  • func NewTransactionProcessor(ctx context.Context) *TransactionProcessor

Constants

const (
	CtxTransactionID log.ContextField = "transactionID"
)

Types

type Consumer

type Consumer struct {
	CustomID  string      `json:"custom_id"`
	CreatedAt int64       `json:"created_at"`
	ID        string      `json:"id"`
	Tags      interface{} `json:"tags"`
	Username  string      `json:"username"`
}

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 Latencies

type Latencies struct {
	Request int `json:"request"`
	Kong    int `json:"kong"`
	Proxy   int `json:"proxy"`
}

type MetricsProcessor

type MetricsProcessor struct {
	// contains filtered or unexported fields
}

MetricsProcessor -

func NewMetricsProcessor

func NewMetricsProcessor(ctx context.Context) MetricsProcessor

type Request

type Request struct {
	QueryString map[string]string      `json:"querystring"`
	Size        int                    `json:"size"`
	URI         string                 `json:"uri"`
	URL         string                 `json:"url"`
	Headers     map[string]interface{} `json:"headers"`
	Method      string                 `json:"method"`
	TLS         *TLS                   `json:"tls"`
}

type Response

type Response struct {
	Headers map[string]interface{} `json:"headers"`
	Status  int                    `json:"status"`
	Size    int                    `json:"size"`
}

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 TLS

type TLS struct {
	Version                string `json:"version"`
	Cipher                 string `json:"cipher"`
	SupportedClientCiphers string `json:"supported_client_ciphers"`
	ClientVerify           string `json:"client_verify"`
}

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"`
}

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