proxy

Documentation

Index

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

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