tapping

Documentation

Index

• Constants
• func StartMonitoringServer() error
• type HeaderMatcher
• type HttpHeadersMatch
• type MatchPredicate
• type MatchSet
• type Message
• type RequestCollector
  • func NewRequestCollector(envoyHost string, envoyPort int, configId string, logger feedback.DataLogging, ...) (*RequestCollector, error)
  • func (rc *RequestCollector) TraceRequests() error
• type TapRequest
• type TapSink
• type Trace

Constants

const (
	CfgMonitoringHost = "monitoring.host"
	CfgMonitoringPort = "monitoring.port"
)

const (
	CfgEnvoyHost     = "envoy.host"
	CfgEnvoyPort     = "envoy.port"
	CfgEnvoyConfigId = "envoy.config_id"
)

const (
	TapUrl = "/tap"
)

Functions

func StartMonitoringServer

func StartMonitoringServer() error

Types

type HeaderMatcher

type HeaderMatcher struct {
	Name          string `yaml:"name"`
	ExactMatch    string `yaml:"exact_match,omitempty"`
	RegexMatch    string `yaml:"regex_match,omitempty"`
	RangeMatch    string `yaml:"range_match,omitempty"`
	PresentMatch  bool   `yaml:"present_match,omitempty"`
	PrefixMatch   string `yaml:"prefix_match,omitempty"`
	SuffixMatch   string `yaml:"suffix_match,omitempty"`
	ContainsMatch string `yaml:"contains_match,omitempty"`
	InvertMatch   bool   `yaml:"invert_match,omitempty"`
}

https://www.envoyproxy.io/docs/envoy/latest/api-v3/config/route/v3/route_components.proto#config-route-v3-headermatcher

type HttpHeadersMatch

type HttpHeadersMatch struct {
	Headers []HeaderMatcher `yaml:"headers"`
}

type MatchPredicate

type MatchPredicate struct {
	OrMatch                  MatchSet         `yaml:"or_match,omitempty"`
	AndMatch                 MatchSet         `yaml:"and_match,omitempty"`
	NotMatch                 *MatchPredicate  `yaml:"not_match,omitempty"`
	AnyMatch                 bool             `yaml:"any_match,omitempty"`
	HttpRequestHeadersMatch  HttpHeadersMatch `yaml:"http_request_headers_match,omitempty"`
	HttpResponseHeadersMatch HttpHeadersMatch `yaml:"http_response_headers_match,omitempty"`
}

https://www.envoyproxy.io/docs/envoy/latest/api-v3/config/tap/v3/common.proto#config-tap-v3-matchpredicate

type MatchSet

type MatchSet struct {
	Rules []MatchPredicate `yaml:"rules"`
}

https://www.envoyproxy.io/docs/envoy/latest/api-v3/config/tap/v3/common.proto#envoy-v3-api-msg-config-tap-v3-matchpredicate-matchset

type Message

type Message struct {
	HttpBufferedTrace struct {
		Request  Trace `json:"request,omitempty"`
		Response Trace `json:"response,omitempty"`
	} `json:"http_buffered_trace"`
}

type RequestCollector

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

func NewRequestCollector

func NewRequestCollector(
	envoyHost string,
	envoyPort int,
	configId string,
	logger feedback.DataLogging,
	prohibitedHeaders []string,
) (*RequestCollector, error)

func (*RequestCollector) TraceRequests

func (rc *RequestCollector) TraceRequests() error

type TapRequest

type TapRequest struct {
	ConfigID  string `yaml:"config_id"`
	TapConfig struct {
		MatchConfig  MatchPredicate `yaml:"match_config"`
		OutputConfig struct {
			Sinks              []TapSink `yaml:"sinks"`
			MaxBufferedTxBytes int32     `yaml:"max_buffered_tx_bytes"`
			MaxBufferedRxBytes int32     `yaml:"max_buffered_rx_bytes"`
		} `yaml:"output_config"`
	} `yaml:"tap_config"`
}

type TapSink

type TapSink struct {
	StreamingAdmin map[string]string `yaml:"streaming_admin"`
}

type Trace

type Trace struct {
	Headers []struct {
		Key   string `json:"key"`
		Value string `json:"value"`
	} `json:"headers"`
	Body struct {
		Truncated bool   `json:"truncated"`
		AsBytes   string `json:"as_bytes"`
	} `json:"body"`
}