api

package

Go to main page

Versions in this module

v1

v1.30.2

Jun 5, 2024

v1.30.1

Apr 18, 2024

v1.30.0

Apr 16, 2024

Changes in this version

type FilterCallbacks

+ ClearRouteCache func()

type HttpCAPI

+ ClearRouteCache func(r unsafe.Pointer)

type RequestHeaderMap

+ SetHost func(host string)

+ SetMethod func(method string)

+ SetPath func(path string)

type StreamInfo

+ WorkerID func() uint32

v1.29.5

Jun 5, 2024

v1.29.4

Apr 18, 2024

v1.29.3

Apr 5, 2024

v1.29.2

Mar 7, 2024

v1.29.1

Feb 10, 2024

v1.29.0

Jan 16, 2024

v1.28.4

Jun 5, 2024

v1.28.3

Apr 18, 2024

v1.28.2

Apr 4, 2024

v1.28.1

Feb 9, 2024

v1.28.0

Oct 19, 2023

Changes in this version

+ var ErrInternalFailure = errors.New("internal failure")

+ var ErrSerializationFailure = errors.New("serialization failure")

+ var ErrValueNotFound = errors.New("value not found")

+ func LogCritical(message string)

+ func LogCriticalf(format string, v ...any)

+ func LogDebug(message string)

+ func LogDebugf(format string, v ...any)

+ func LogError(message string)

+ func LogErrorf(format string, v ...any)

+ func LogInfo(message string)

+ func LogInfof(format string, v ...any)

+ func LogTrace(message string)

+ func LogTracef(format string, v ...any)

+ func LogWarn(message string)

+ func LogWarnf(format string, v ...any)

+ func SetCommonCAPI(api CommonCAPI)

+ type AccessLogType int

+ const AccessLogDownstreamEnd

+ const AccessLogDownstreamPeriodic

+ const AccessLogDownstreamStart

+ const AccessLogDownstreamTunnelSuccessfullyEstablished

+ const AccessLogNotSet

+ const AccessLogTcpConnectionEnd

+ const AccessLogTcpPeriodic

+ const AccessLogTcpUpstreamConnected

+ const AccessLogUpstreamEnd

+ const AccessLogUpstreamPeriodic

+ const AccessLogUpstreamPoolReady

+ type CommonCAPI interface

+ Log func(level LogType, message string)

+ LogLevel func() LogType

+ type ConfigCallbackHandler interface

+ type ConfigCallbacks interface

+ DefineCounterMetric func(name string) CounterMetric

+ DefineGaugeMetric func(name string) GaugeMetric

type ConnectionCloseType

+ const AbortReset

+ type CounterMetric interface

+ Get func() uint64

+ Increment func(offset int64)

+ Record func(value uint64)

+ type EmptyDownstreamFilter struct

+ func (*EmptyDownstreamFilter) OnData(buffer []byte, endOfStream bool) FilterStatus

+ func (*EmptyDownstreamFilter) OnEvent(event ConnectionEvent)

+ func (*EmptyDownstreamFilter) OnNewConnection() FilterStatus

+ func (*EmptyDownstreamFilter) OnWrite(buffer []byte, endOfStream bool) FilterStatus

+ type EmptyUpstreamFilter struct

+ func (*EmptyUpstreamFilter) OnData(buffer []byte, endOfStream bool) FilterStatus

+ func (*EmptyUpstreamFilter) OnEvent(event ConnectionEvent)

+ func (*EmptyUpstreamFilter) OnPoolFailure(poolFailureReason PoolFailureReason, transportFailureReason string)

+ func (*EmptyUpstreamFilter) OnPoolReady(cb ConnectionCallback)

type FilterCallbacks

+ GetProperty func(key string) (string, error)

+ type GaugeMetric interface

+ Get func() uint64

+ Increment func(offset int64)

+ Record func(value uint64)

+ type HistogramMetric interface

type HttpCAPI

+ HttpConfigFinalize func(c unsafe.Pointer)

+ HttpDefineMetric func(c unsafe.Pointer, metricType MetricType, name string) uint32

+ HttpDrainBuffer func(r unsafe.Pointer, bufferPtr uint64, length uint64)

+ HttpGetMetric func(c unsafe.Pointer, metricId uint32) uint64

+ HttpGetStringProperty func(r unsafe.Pointer, key string) (string, error)

+ HttpIncrementMetric func(c unsafe.Pointer, metricId uint32, offset int64)

+ HttpRecordMetric func(c unsafe.Pointer, metricId uint32, value uint64)

+ HttpSetBytesBufferHelper func(r unsafe.Pointer, bufferPtr uint64, value []byte, action BufferAction)

type LogType

+ func GetLogLevel() LogType

+ type MetricType uint32

+ const Counter

+ const Gauge

+ const Histogram

type PassThroughStreamFilter

+ func (*PassThroughStreamFilter) OnLog()

+ func (*PassThroughStreamFilter) OnLogDownstreamPeriodic()

+ func (*PassThroughStreamFilter) OnLogDownstreamStart()

type StreamFilter

+ OnLog func()

+ OnLogDownstreamPeriodic func()

+ OnLogDownstreamStart func()

v1.27.6

Jun 4, 2024

v1.27.5

Apr 18, 2024

v1.27.4

Apr 4, 2024

v1.27.3

Feb 9, 2024

v1.27.2

Oct 17, 2023

v1.27.1

Oct 11, 2023

v1.27.0

Jul 26, 2023

Changes in this version

+ const GCFinalize

+ const NormalFinalize

+ func CgoCheckDisabled() bool

+ type BufferAction int

+ const AppendBuffer

+ const PrependBuffer

+ const SetBuffer

+ type BufferInstance interface

+ AppendString func(s string) error

+ Prepend func(data []byte) error

+ PrependString func(s string) error

+ Set func([]byte) error

+ SetString func(string) error

+ type ConnectionCallback interface

+ Close func(closeType ConnectionCloseType)

+ StreamInfo func() StreamInfo

+ Write func(buffer []byte, endStream bool)

+ type ConnectionCloseType int

+ const Abort

+ const FlushWrite

+ const FlushWriteAndDelay

+ const NoFlush

+ func (t ConnectionCloseType) String() string

+ type ConnectionEvent int

+ const Connected

+ const ConnectedZeroRtt

+ const LocalClose

+ const RemoteClose

+ func (e ConnectionEvent) String() string

+ type ConnectionInfoType int

+ const ConnectionInfoLocalAddr

+ const ConnectionInfoRemoteAddr

+ func (t ConnectionInfoType) String() string

+ type DataBufferBase interface

+ Append func(data []byte) error

+ Bytes func() []byte

+ Drain func(offset int)

+ Len func() int

+ Peek func(n int) []byte

+ Reset func()

+ String func() string

+ Write func(p []byte) (n int, err error)

+ WriteByte func(p byte) error

+ WriteString func(s string) (n int, err error)

+ WriteUint16 func(p uint16) error

+ WriteUint32 func(p uint32) error

+ WriteUint64 func(p uint64) error

+ type DestroyReason int

+ const Normal

+ const Terminate

+ type DownstreamFilter interface

+ OnData func(buffer []byte, endOfStream bool) FilterStatus

+ OnEvent func(event ConnectionEvent)

+ OnNewConnection func() FilterStatus

+ OnWrite func(buffer []byte, endOfStream bool) FilterStatus

+ type DynamicMetadata interface

+ Get func(filterName string) map[string]interface{}

+ Set func(filterName string, key string, value interface{})

+ type EnvoyRequestPhase int

+ const DecodeDataPhase

+ const DecodeHeaderPhase

+ const DecodeTrailerPhase

+ const EncodeDataPhase

+ const EncodeHeaderPhase

+ const EncodeTrailerPhase

+ func (e EnvoyRequestPhase) String() string

+ type FilterCallbackHandler interface

+ type FilterCallbacks interface

+ Continue func(StatusType)

+ Log func(level LogType, msg string)

+ LogLevel func() LogType

+ RecoverPanic func()

+ SendLocalReply func(responseCode int, bodyText string, headers map[string]string, grpcStatus int64, ...)

+ type FilterState interface

+ GetString func(key string) string

+ SetString func(key, value string, stateType StateType, lifeSpan LifeSpan, ...)

+ type FilterStatus int

+ const NetworkFilterContinue

+ const NetworkFilterStopIteration

+ func (s FilterStatus) String() string

+ type HeaderMap interface

+ Add func(key, value string)

+ ByteSize func() uint64

+ Del func(key string)

+ Get func(key string) (string, bool)

+ GetRaw func(name string) string

+ Range func(f func(key, value string) bool)

+ RangeWithCopy func(f func(key, value string) bool)

+ Set func(key, value string)

+ Values func(key string) []string

+ type HttpCAPI interface

+ HttpContinue func(r unsafe.Pointer, status uint64)

+ HttpCopyHeaders func(r unsafe.Pointer, num uint64, bytes uint64) map[string][]string

+ HttpCopyTrailers func(r unsafe.Pointer, num uint64, bytes uint64) map[string][]string

+ HttpFinalize func(r unsafe.Pointer, reason int)

+ HttpGetBuffer func(r unsafe.Pointer, bufferPtr uint64, value *string, length uint64)

+ HttpGetDynamicMetadata func(r unsafe.Pointer, filterName string) map[string]interface{}

+ HttpGetHeader func(r unsafe.Pointer, key *string, value *string)

+ HttpGetIntegerValue func(r unsafe.Pointer, id int) (uint64, bool)

+ HttpGetStringFilterState func(r unsafe.Pointer, key string) string

+ HttpGetStringValue func(r unsafe.Pointer, id int) (string, bool)

+ HttpLog func(level LogType, message string)

+ HttpLogLevel func() LogType

+ HttpRemoveHeader func(r unsafe.Pointer, key *string)

+ HttpRemoveTrailer func(r unsafe.Pointer, key *string)

+ HttpSendLocalReply func(r unsafe.Pointer, responseCode int, bodyText string, headers map[string]string, ...)

+ HttpSendPanicReply func(r unsafe.Pointer, details string)

+ HttpSetBufferHelper func(r unsafe.Pointer, bufferPtr uint64, value string, action BufferAction)

+ HttpSetDynamicMetadata func(r unsafe.Pointer, filterName string, key string, value interface{})

+ HttpSetHeader func(r unsafe.Pointer, key *string, value *string, add bool)

+ HttpSetStringFilterState func(r unsafe.Pointer, key string, value string, stateType StateType, ...)

+ HttpSetTrailer func(r unsafe.Pointer, key *string, value *string, add bool)

+ type LifeSpan int

+ const LifeSpanConnection

+ const LifeSpanFilterChain

+ const LifeSpanRequest

+ const LifeSpanTopSpan

+ type LogType int

+ const Critical

+ const Debug

+ const Error

+ const Info

+ const Trace

+ const Warn

+ func (self LogType) String() string

+ type MetadataMap interface

+ type NetworkCAPI interface

+ DownstreamClose func(f unsafe.Pointer, closeType int)

+ DownstreamFinalize func(f unsafe.Pointer, reason int)

+ DownstreamInfo func(f unsafe.Pointer, infoType int) string

+ DownstreamWrite func(f unsafe.Pointer, bufferPtr unsafe.Pointer, bufferLen int, endStream int)

+ GetFilterState func(f unsafe.Pointer, key string) string

+ SetFilterState func(f unsafe.Pointer, key string, value string, stateType StateType, ...)

+ UpstreamClose func(f unsafe.Pointer, closeType int)

+ UpstreamConnect func(libraryID string, addr string) unsafe.Pointer

+ UpstreamFinalize func(f unsafe.Pointer, reason int)

+ UpstreamInfo func(f unsafe.Pointer, infoType int) string

+ UpstreamWrite func(f unsafe.Pointer, bufferPtr unsafe.Pointer, bufferLen int, endStream int)

+ type PassThroughStreamDecoderFilter struct

+ func (*PassThroughStreamDecoderFilter) DecodeData(BufferInstance, bool) StatusType

+ func (*PassThroughStreamDecoderFilter) DecodeHeaders(RequestHeaderMap, bool) StatusType

+ func (*PassThroughStreamDecoderFilter) DecodeTrailers(RequestTrailerMap) StatusType

+ type PassThroughStreamEncoderFilter struct

+ func (*PassThroughStreamEncoderFilter) EncodeData(BufferInstance, bool) StatusType

+ func (*PassThroughStreamEncoderFilter) EncodeHeaders(ResponseHeaderMap, bool) StatusType

+ func (*PassThroughStreamEncoderFilter) EncodeTrailers(ResponseTrailerMap) StatusType

+ type PassThroughStreamFilter struct

+ func (*PassThroughStreamFilter) OnDestroy(DestroyReason)

+ type PoolFailureReason int

+ const LocalConnectionFailure

+ const Overflow

+ const RemoteConnectionFailure

+ const Timeout

+ func (r PoolFailureReason) String() string

+ type RequestHeaderMap interface

+ Host func() string

+ Method func() string

+ Path func() string

+ Protocol func() string

+ Scheme func() string

+ type RequestTrailerMap interface

+ type ResponseHeaderMap interface

+ Status func() (int, bool)

+ type ResponseTrailerMap interface

+ type StateType int

+ const StateTypeMutable

+ const StateTypeReadOnly

+ type StatusType int

+ const Continue

+ const DataContinue

+ const DataStopIterationAndBuffer

+ const DataStopIterationAndWatermark

+ const DataStopIterationNoBuffer

+ const HeaderContinue

+ const HeaderContinueAndDontEndStream

+ const HeaderStopAllIterationAndBuffer

+ const HeaderStopAllIterationAndWatermark

+ const HeaderStopIteration

+ const LocalReply

+ const Running

+ const StopAndBuffer

+ const StopAndBufferWatermark

+ const StopNoBuffer

+ const TrailerContinue

+ const TrailerStopIteration

+ type StreamDecoderFilter interface

+ DecodeData func(BufferInstance, bool) StatusType

+ DecodeHeaders func(RequestHeaderMap, bool) StatusType

+ DecodeTrailers func(RequestTrailerMap) StatusType

+ type StreamEncoderFilter interface

+ EncodeData func(BufferInstance, bool) StatusType

+ EncodeHeaders func(ResponseHeaderMap, bool) StatusType

+ EncodeTrailers func(ResponseTrailerMap) StatusType

+ type StreamFilter interface

+ OnDestroy func(DestroyReason)

+ type StreamFilterCallbacks interface

+ StreamInfo func() StreamInfo

+ type StreamFilterConfigFactory func(config interface{}) StreamFilterFactory

+ type StreamFilterConfigParser interface

+ Merge func(parentConfig interface{}, childConfig interface{}) interface{}

+ Parse func(any *anypb.Any) (interface{}, error)

+ type StreamFilterFactory func(callbacks FilterCallbackHandler) StreamFilter

+ type StreamInfo interface

+ AttemptCount func() uint32

+ DownstreamLocalAddress func() string

+ DownstreamRemoteAddress func() string

+ DynamicMetadata func() DynamicMetadata

+ FilterChainName func() string

+ FilterState func() FilterState

+ GetRouteName func() string

+ Protocol func() (string, bool)

+ ResponseCode func() (uint32, bool)

+ ResponseCodeDetails func() (string, bool)

+ UpstreamClusterName func() (string, bool)

+ UpstreamLocalAddress func() (string, bool)

+ UpstreamRemoteAddress func() (string, bool)

+ VirtualClusterName func() (string, bool)

+ type StreamSharing int

+ const None

+ const SharedWithUpstreamConnection

+ const SharedWithUpstreamConnectionOnce

+ type UpstreamFilter interface

+ OnData func(buffer []byte, endOfStream bool)

+ OnEvent func(event ConnectionEvent)

+ OnPoolFailure func(poolFailureReason PoolFailureReason, transportFailureReason string)

+ OnPoolReady func(cb ConnectionCallback)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL