envoy

Documentation

Index

• func DisableLogInTest()
• func NewCAPIFilterCallbackHandler() *capiFilterCallbackHandler
• func NewDynamicMetadata(data map[string]map[string]interface{}) api.DynamicMetadata
• func NewFilterCallbackHandler() *filterCallbackHandler
• func NewFilterState(data map[string]string) api.FilterState
• type BufferInstance
  • func NewBufferInstance(b []byte) *BufferInstance
  • func (db *BufferInstance) Append(data []byte) error
  • func (bi *BufferInstance) AppendString(s string) error
  • func (db *BufferInstance) Bytes() []byte
  • func (db *BufferInstance) Drain(offset int)
  • func (db *BufferInstance) Len() int
  • func (bi *BufferInstance) Prepend(data []byte) error
  • func (bi *BufferInstance) PrependString(s string) error
  • func (db *BufferInstance) Reset()
  • func (bi *BufferInstance) Set(data []byte) error
  • func (bi *BufferInstance) SetString(s string) error
  • func (db *BufferInstance) String() string
  • func (db *BufferInstance) Write(p []byte) (int, error)
  • func (db *BufferInstance) WriteByte(b byte) error
  • func (db *BufferInstance) WriteString(s string) (int, error)
  • func (b *BufferInstance) WriteUint16(p uint16) error
  • func (b *BufferInstance) WriteUint32(p uint32) error
  • func (b *BufferInstance) WriteUint64(p uint64) error
• type DynamicMetadata
  • func (i *DynamicMetadata) Get(filterName string) map[string]interface{}
  • func (i *DynamicMetadata) Set(filterName string, key string, value interface{})
• type FilterState
  • func (i *FilterState) GetString(key string) string
  • func (i *FilterState) SetString(key, value string, stateType capi.StateType, lifeSpan capi.LifeSpan, ...)
• type HeaderMap
  • func (i *HeaderMap) Add(key, value string)
  • func (i *HeaderMap) Del(key string)
  • func (i *HeaderMap) Get(key string) (string, bool)
  • func (i *HeaderMap) GetRaw(name string) string
  • func (i *HeaderMap) Range(f func(key, value string) bool)
  • func (i *HeaderMap) RangeWithCopy(f func(key, value string) bool)
  • func (i *HeaderMap) Set(key, value string)
  • func (i *HeaderMap) Values(key string) []string
• type LocalResponse
• type RequestHeaderMap
  • func NewRequestHeaderMap(hdr http.Header) *RequestHeaderMap
  • func (i *RequestHeaderMap) Cookies() map[string]*http.Cookie
  • func (i *RequestHeaderMap) Host() string
  • func (i *RequestHeaderMap) Method() string
  • func (i *RequestHeaderMap) Path() string
  • func (i *RequestHeaderMap) Scheme() string
  • func (i *RequestHeaderMap) Url() *url.URL
• type ResponseHeaderMap
  • func NewResponseHeaderMap(hdr http.Header) *ResponseHeaderMap
  • func (i *ResponseHeaderMap) Status() (int, bool)
• type StreamInfo
  • func (i *StreamInfo) AttemptCount() uint32
  • func (i *StreamInfo) DownstreamLocalAddress() string
  • func (i *StreamInfo) DownstreamRemoteAddress() string
  • func (i *StreamInfo) DownstreamRemoteParsedAddress() *api.IPAddress
  • func (i *StreamInfo) DynamicMetadata() api.DynamicMetadata
  • func (i *StreamInfo) FilterChainName() string
  • func (i *StreamInfo) FilterState() api.FilterState
  • func (i *StreamInfo) GetProperty(key string) (string, bool)
  • func (i *StreamInfo) GetRouteName() string
  • func (i *StreamInfo) Protocol() (string, bool)
  • func (i *StreamInfo) ResponseCode() (uint32, bool)
  • func (i *StreamInfo) ResponseCodeDetails() (string, bool)
  • func (i *StreamInfo) SetDynamicMetadata(data api.DynamicMetadata)
  • func (i *StreamInfo) SetFilterState(data api.FilterState)
  • func (i *StreamInfo) UpstreamClusterName() (string, bool)
  • func (i *StreamInfo) UpstreamLocalAddress() (string, bool)
  • func (i *StreamInfo) UpstreamRemoteAddress() (string, bool)
  • func (i *StreamInfo) VirtualClusterName() (string, bool)
  • func (i *StreamInfo) WorkerID() uint32

Functions

func DisableLogInTest

func DisableLogInTest()

func NewCAPIFilterCallbackHandler

func NewCAPIFilterCallbackHandler() *capiFilterCallbackHandler

func NewDynamicMetadata

func NewDynamicMetadata(data map[string]map[string]interface{}) api.DynamicMetadata

func NewFilterCallbackHandler

func NewFilterCallbackHandler() *filterCallbackHandler

func NewFilterState

func NewFilterState(data map[string]string) api.FilterState

Types

type BufferInstance

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

func NewBufferInstance

func NewBufferInstance(b []byte) *BufferInstance

func (*BufferInstance) Append

func (db *BufferInstance) Append(data []byte) error

func (*BufferInstance) AppendString

func (bi *BufferInstance) AppendString(s string) error

func (*BufferInstance) Bytes

func (db *BufferInstance) Bytes() []byte

func (*BufferInstance) Drain

func (db *BufferInstance) Drain(offset int)

func (*BufferInstance) Len

func (db *BufferInstance) Len() int

func (*BufferInstance) Prepend

func (bi *BufferInstance) Prepend(data []byte) error

func (*BufferInstance) PrependString

func (bi *BufferInstance) PrependString(s string) error

func (*BufferInstance) Reset

func (db *BufferInstance) Reset()

func (*BufferInstance) Set

func (bi *BufferInstance) Set(data []byte) error

func (*BufferInstance) SetString

func (bi *BufferInstance) SetString(s string) error

func (*BufferInstance) String

func (db *BufferInstance) String() string

func (*BufferInstance) Write

func (db *BufferInstance) Write(p []byte) (int, error)

func (*BufferInstance) WriteByte

func (db *BufferInstance) WriteByte(b byte) error

func (*BufferInstance) WriteString

func (db *BufferInstance) WriteString(s string) (int, error)

func (*BufferInstance) WriteUint16

func (b *BufferInstance) WriteUint16(p uint16) error

func (*BufferInstance) WriteUint32

func (b *BufferInstance) WriteUint32(p uint32) error

func (*BufferInstance) WriteUint64

func (b *BufferInstance) WriteUint64(p uint64) error

type DynamicMetadata

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

func (*DynamicMetadata) Get

func (i *DynamicMetadata) Get(filterName string) map[string]interface{}

func (*DynamicMetadata) Set

func (i *DynamicMetadata) Set(filterName string, key string, value interface{})

type FilterState

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

func (*FilterState) GetString

func (i *FilterState) GetString(key string) string

func (*FilterState) SetString

func (i *FilterState) SetString(key, value string, stateType capi.StateType, lifeSpan capi.LifeSpan, streamSharing capi.StreamSharing)

type HeaderMap

type HeaderMap struct {
	http.Header
}

func (*HeaderMap) Add

func (i *HeaderMap) Add(key, value string)

func (*HeaderMap) Del

func (i *HeaderMap) Del(key string)

func (*HeaderMap) Get

func (i *HeaderMap) Get(key string) (string, bool)

func (*HeaderMap) GetRaw

func (i *HeaderMap) GetRaw(name string) string

func (*HeaderMap) Range

func (i *HeaderMap) Range(f func(key, value string) bool)

func (*HeaderMap) RangeWithCopy

func (i *HeaderMap) RangeWithCopy(f func(key, value string) bool)

func (*HeaderMap) Set

func (i *HeaderMap) Set(key, value string)

func (*HeaderMap) Values

func (i *HeaderMap) Values(key string) []string

type LocalResponse

type LocalResponse struct {
	Code    int
	Body    string
	Headers map[string][]string
}

type RequestHeaderMap

type RequestHeaderMap struct {
	HeaderMap
}

func NewRequestHeaderMap

func NewRequestHeaderMap(hdr http.Header) *RequestHeaderMap

func (*RequestHeaderMap) Cookies

func (i *RequestHeaderMap) Cookies() map[string]*http.Cookie

func (*RequestHeaderMap) Host

func (i *RequestHeaderMap) Host() string

func (*RequestHeaderMap) Method

func (i *RequestHeaderMap) Method() string

func (*RequestHeaderMap) Path

func (i *RequestHeaderMap) Path() string

func (*RequestHeaderMap) Scheme

func (i *RequestHeaderMap) Scheme() string

func (*RequestHeaderMap) Url

func (i *RequestHeaderMap) Url() *url.URL

type ResponseHeaderMap

type ResponseHeaderMap struct {
	HeaderMap
}

func NewResponseHeaderMap

func NewResponseHeaderMap(hdr http.Header) *ResponseHeaderMap

func (*ResponseHeaderMap) Status

func (i *ResponseHeaderMap) Status() (int, bool)

type StreamInfo

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

func (*StreamInfo) AttemptCount

func (i *StreamInfo) AttemptCount() uint32

func (*StreamInfo) DownstreamLocalAddress

func (i *StreamInfo) DownstreamLocalAddress() string

func (*StreamInfo) DownstreamRemoteAddress

func (i *StreamInfo) DownstreamRemoteAddress() string

func (*StreamInfo) DownstreamRemoteParsedAddress

func (i *StreamInfo) DownstreamRemoteParsedAddress() *api.IPAddress

func (*StreamInfo) DynamicMetadata

func (i *StreamInfo) DynamicMetadata() api.DynamicMetadata

func (*StreamInfo) FilterChainName

func (i *StreamInfo) FilterChainName() string

func (*StreamInfo) FilterState

func (i *StreamInfo) FilterState() api.FilterState

func (*StreamInfo) GetProperty

func (i *StreamInfo) GetProperty(key string) (string, bool)

func (*StreamInfo) GetRouteName

func (i *StreamInfo) GetRouteName() string

func (*StreamInfo) Protocol

func (i *StreamInfo) Protocol() (string, bool)

func (*StreamInfo) ResponseCode

func (i *StreamInfo) ResponseCode() (uint32, bool)

func (*StreamInfo) ResponseCodeDetails

func (i *StreamInfo) ResponseCodeDetails() (string, bool)

func (*StreamInfo) SetDynamicMetadata

func (i *StreamInfo) SetDynamicMetadata(data api.DynamicMetadata)

func (*StreamInfo) SetFilterState

func (i *StreamInfo) SetFilterState(data api.FilterState)

func (*StreamInfo) UpstreamClusterName

func (i *StreamInfo) UpstreamClusterName() (string, bool)

func (*StreamInfo) UpstreamLocalAddress

func (i *StreamInfo) UpstreamLocalAddress() (string, bool)

func (*StreamInfo) UpstreamRemoteAddress

func (i *StreamInfo) UpstreamRemoteAddress() (string, bool)

func (*StreamInfo) VirtualClusterName

func (i *StreamInfo) VirtualClusterName() (string, bool)

func (*StreamInfo) WorkerID

func (i *StreamInfo) WorkerID() uint32