proxy

Documentation

Index

• Constants
• type Proxy
  • func NewProxy(ctx context.Context, config *v2.Proxy, clusterManager types.ClusterManager) Proxy
• type Stats
• type Timeout
• type UpstreamCallbacks
• type UpstreamFailureReason

Constants

const (
	VarStartTime                string = "start_time"
	VarRequestReceivedDuration  string = "request_received_duration"
	VarResponseReceivedDuration string = "response_received_duration"
	VarRequestFinishedDuration  string = "request_finished_duration"
	VarBytesSent                string = "bytes_sent"
	VarBytesReceived            string = "bytes_received"
	VarProtocol                 string = "protocol"
	VarResponseCode             string = "response_code"
	VarDuration                 string = "duration"
	VarResponseFlag             string = "response_flag"
	VarUpstreamLocalAddress     string = "upstream_local_address"
	VarDownstreamLocalAddress   string = "downstream_local_address"
	VarDownstreamRemoteAddress  string = "downstream_remote_address"
	VarUpstreamHost             string = "upstream_host"
)

The identification of a request info's content

Types

type Proxy

type Proxy interface {
	types.ReadFilter

	ReadDisableUpstream(disable bool)

	ReadDisableDownstream(disable bool)
}

Proxy

func NewProxy

func NewProxy(ctx context.Context, config *v2.Proxy, clusterManager types.ClusterManager) Proxy

NewProxy create proxy instance for given v2.Proxy config

type Stats

type Stats struct {
	DownstreamConnectionTotal   gometrics.Counter
	DownstreamConnectionDestroy gometrics.Counter
	DownstreamConnectionActive  gometrics.Counter
	DownstreamBytesReadTotal    gometrics.Counter
	DownstreamBytesWriteTotal   gometrics.Counter
	DownstreamRequestTotal      gometrics.Counter
	DownstreamRequestActive     gometrics.Counter
	DownstreamRequestReset      gometrics.Counter
	DownstreamRequestTime       gometrics.Histogram
	DownstreamRequestTimeTotal  gometrics.Counter
	DownstreamProcessTime       gometrics.Histogram
	DownstreamProcessTimeTotal  gometrics.Counter
	DownstreamRequestFailed     gometrics.Counter
}

type Timeout

type Timeout struct {
	GlobalTimeout time.Duration
	TryTimeout    time.Duration
}

Timeout

type UpstreamCallbacks

type UpstreamCallbacks interface {
	types.ReadFilter
	types.ConnectionEventListener
}

UpstreamCallbacks callback invoked when upstream event happened

type UpstreamFailureReason

type UpstreamFailureReason string

UpstreamFailureReason

const (
	ConnectFailed         UpstreamFailureReason = "ConnectFailed"
	NoHealthyUpstream     UpstreamFailureReason = "NoHealthyUpstream"
	ResourceLimitExceeded UpstreamFailureReason = "ResourceLimitExceeded"
	NoRoute               UpstreamFailureReason = "NoRoute"
)

Group pf some Upstream Failure Reason