envoy

package
v0.4.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 21, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

func NewRequestTrailerMap added in v0.4.1 

func NewRequestTrailerMap(hdr http.Header) api.RequestTrailerMap

func NewResponseTrailerMap added in v0.4.1 

func NewResponseTrailerMap(hdr http.Header) api.ResponseTrailerMap

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 (db *BufferInstance) WriteUint16(p uint16) error

func (*BufferInstance) WriteUint32 

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

func (*BufferInstance) WriteUint64 

func (db *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
	// contains filtered or unexported fields
}

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) GetAllHeaders added in v0.4.0 

func (i *HeaderMap) GetAllHeaders() map[string][]string

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) Cookie 

func (i *RequestHeaderMap) Cookie(name string) *http.Cookie

func (*RequestHeaderMap) Cookies 

func (i *RequestHeaderMap) Cookies() []*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) SetHost added in v0.4.0 

func (i *RequestHeaderMap) SetHost(host string)

func (*RequestHeaderMap) SetMethod added in v0.4.0 

func (i *RequestHeaderMap) SetMethod(method string)

func (*RequestHeaderMap) SetPath added in v0.4.0 

func (i *RequestHeaderMap) SetPath(path string)

func (*RequestHeaderMap) URL added in v0.3.0 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.