proxy

Documentation

Index

• func GetWorkerPool() mosnsync.WorkerPool
• type Proxy
  • func NewProxy(ctx context.Context, config *v2.Proxy) Proxy
• type Stats
  • func (s *Stats) DownstreamUpdateRequestCode(returnCode int)
• type Timeout
• type UpstreamCallbacks
• type UpstreamFailureReason

Functions

func GetWorkerPool

func GetWorkerPool() mosnsync.WorkerPool

Types

type Proxy

type Proxy interface {
	api.ReadFilter

	ReadDisableUpstream(disable bool)

	ReadDisableDownstream(disable bool)

	// active stream size
	ActiveStreamSize() int
}

Proxy

func NewProxy

func NewProxy(ctx context.Context, config *v2.Proxy) 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
	DownstreamRequest200Total   gometrics.Counter
	DownstreamRequest206Total   gometrics.Counter
	DownstreamRequest302Total   gometrics.Counter
	DownstreamRequest304Total   gometrics.Counter
	DownstreamRequest400Total   gometrics.Counter
	DownstreamRequest403Total   gometrics.Counter
	DownstreamRequest404Total   gometrics.Counter
	DownstreamRequest416Total   gometrics.Counter
	DownstreamRequest499Total   gometrics.Counter
	DownstreamRequest500Total   gometrics.Counter
	DownstreamRequest502Total   gometrics.Counter
	DownstreamRequest503Total   gometrics.Counter
	DownstreamRequest504Total   gometrics.Counter
	DownstreamRequestOtherTotal gometrics.Counter
}

func (*Stats) DownstreamUpdateRequestCode

func (s *Stats) DownstreamUpdateRequestCode(returnCode int)

type Timeout

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

Timeout

type UpstreamCallbacks

type UpstreamCallbacks interface {
	api.ReadFilter
	api.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