proxylatency

Documentation

Index

• Variables
• type ProxyLatency
  • func (*ProxyLatency) Descriptor() ([]byte, []int)
  • func (this *ProxyLatency) Equal(that interface{}) bool
  • func (m *ProxyLatency) GetChargeClusterStat() *types.BoolValue
  • func (m *ProxyLatency) GetChargeListenerStat() *types.BoolValue
  • func (m *ProxyLatency) GetMeasureRequestInternally() bool
  • func (m *ProxyLatency) GetRequest() ProxyLatency_Measurement
  • func (m *ProxyLatency) GetResponse() ProxyLatency_Measurement
  • func (*ProxyLatency) ProtoMessage()
  • func (m *ProxyLatency) Reset()
  • func (m *ProxyLatency) String() string
  • func (m *ProxyLatency) XXX_DiscardUnknown()
  • func (m *ProxyLatency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ProxyLatency) XXX_Merge(src proto.Message)
  • func (m *ProxyLatency) XXX_Size() int
  • func (m *ProxyLatency) XXX_Unmarshal(b []byte) error
• type ProxyLatency_Measurement
  • func (ProxyLatency_Measurement) EnumDescriptor() ([]byte, []int)
  • func (x ProxyLatency_Measurement) String() string

Variables

var ProxyLatency_Measurement_name = map[int32]string{
	0: "LAST_INCOMING_FIRST_OUTGOING",
	1: "FIRST_INCOMING_FIRST_OUTGOING",
	2: "LAST_INCOMING_LAST_OUTGOING",
	3: "FIRST_INCOMING_LAST_OUTGOING",
}

var ProxyLatency_Measurement_value = map[string]int32{
	"LAST_INCOMING_FIRST_OUTGOING":  0,
	"FIRST_INCOMING_FIRST_OUTGOING": 1,
	"LAST_INCOMING_LAST_OUTGOING":   2,
	"FIRST_INCOMING_LAST_OUTGOING":  3,
}

Types

type ProxyLatency

type ProxyLatency struct {
	// How to measure the request.
	Request ProxyLatency_Measurement `` /* 139-byte string literal not displayed */
	// When FIRST_OUTGOING (i.e. LAST_INCOMING_FIRST_OUTGOING or FIRST_INCOMING_FIRST_OUTGOING) is
	// instead of when the first byte is sent upstream. This has the advantage of not measuring the time
	// selected for request measurment, finish measuring proxy latency when decodeHeader for this
	// it takes a connection to form, which may skew the P99.
	// filter is hit instead of when the first byte is sent upstream. This has the advantage of not
	// for this to work the filter should be inserted last, just before the router filter.
	// measuring the time it takes a connection to form, which may skew the P99. For this to work
	// this filter should be inserted last, just before the router filter. This has no effect if
	// other measurement type is selected, and has no effect on how response is measured.
	MeasureRequestInternally bool `` /* 136-byte string literal not displayed */
	// How measure the response.
	Response ProxyLatency_Measurement `` /* 141-byte string literal not displayed */
	// Charge a stat per upstream cluster. If not specified, defaults to true.
	ChargeClusterStat *types.BoolValue `protobuf:"bytes,3,opt,name=charge_cluster_stat,json=chargeClusterStat,proto3" json:"charge_cluster_stat,omitempty"`
	// Charge a stat per listener. If not specified, defaults to true.
	ChargeListenerStat   *types.BoolValue `protobuf:"bytes,4,opt,name=charge_listener_stat,json=chargeListenerStat,proto3" json:"charge_listener_stat,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Configure the proxy latency filter. This filter measures the latency incurred by the filter chain in a histogram.

func (*ProxyLatency) Descriptor

func (*ProxyLatency) Descriptor() ([]byte, []int)

func (*ProxyLatency) Equal

func (this *ProxyLatency) Equal(that interface{}) bool

func (*ProxyLatency) GetChargeClusterStat

func (m *ProxyLatency) GetChargeClusterStat() *types.BoolValue

func (*ProxyLatency) GetChargeListenerStat

func (m *ProxyLatency) GetChargeListenerStat() *types.BoolValue

func (*ProxyLatency) GetMeasureRequestInternally

func (m *ProxyLatency) GetMeasureRequestInternally() bool

func (*ProxyLatency) GetRequest

func (m *ProxyLatency) GetRequest() ProxyLatency_Measurement

func (*ProxyLatency) GetResponse

func (m *ProxyLatency) GetResponse() ProxyLatency_Measurement

func (*ProxyLatency) ProtoMessage

func (*ProxyLatency) ProtoMessage()

func (*ProxyLatency) Reset

func (m *ProxyLatency) Reset()

func (*ProxyLatency) String

func (m *ProxyLatency) String() string

func (*ProxyLatency) XXX_DiscardUnknown

func (m *ProxyLatency) XXX_DiscardUnknown()

func (*ProxyLatency) XXX_Marshal

func (m *ProxyLatency) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProxyLatency) XXX_Merge

func (m *ProxyLatency) XXX_Merge(src proto.Message)

func (*ProxyLatency) XXX_Size

func (m *ProxyLatency) XXX_Size() int

func (*ProxyLatency) XXX_Unmarshal

func (m *ProxyLatency) XXX_Unmarshal(b []byte) error

type ProxyLatency_Measurement

type ProxyLatency_Measurement int32

How to perform the latency measurement. Given an incoming request from downstream and outging request to upstream; or incoming response from upstream and outgoing repsonse to downstream, This outlines how to measure the latency used by the proxy.

const (
	// Count from the last byte of the incoming request\response to the first byte of the outgoing request\response.
	ProxyLatency_LAST_INCOMING_FIRST_OUTGOING ProxyLatency_Measurement = 0
	// Count from the first byte of the incoming request\response to the first byte of the outgoing request\response.
	ProxyLatency_FIRST_INCOMING_FIRST_OUTGOING ProxyLatency_Measurement = 1
	// Count from the last byte of the incoming request\response to the last byte of the outgoing request\response.
	ProxyLatency_LAST_INCOMING_LAST_OUTGOING ProxyLatency_Measurement = 2
	// Count from the first byte of the incoming request\response to the last byte of the outgoing request\response.
	ProxyLatency_FIRST_INCOMING_LAST_OUTGOING ProxyLatency_Measurement = 3
)

func (ProxyLatency_Measurement) EnumDescriptor

func (ProxyLatency_Measurement) EnumDescriptor() ([]byte, []int)

func (ProxyLatency_Measurement) String

func (x ProxyLatency_Measurement) String() string