api

Jan 14, 2025

Changes in this version

type FilterProcessCallbacks

+ AddData func(data []byte, isStreaming bool)

type HttpCAPI

+ HttpAddData func(s unsafe.Pointer, data []byte, isStreaming bool)

type StreamFilterCallbacks

+ RefreshRouteCache func()

Oct 15, 2024

Changes in this version

type PassThroughStreamFilter

+ func (*PassThroughStreamFilter) OnStreamComplete()

type StreamFilter

+ OnStreamComplete func()

Jul 19, 2024

Changes in this version

type ConnectionCallback

+ EnableHalfClose func(enabled bool)

+ type DecoderFilterCallbacks interface

+ type EncoderFilterCallbacks interface

type FilterCallbackHandler

+ DecoderFilterCallbacks func() DecoderFilterCallbacks

+ EncoderFilterCallbacks func() EncoderFilterCallbacks

+ type FilterProcessCallbacks interface

+ Continue func(StatusType)

+ RecoverPanic func()

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

type HeaderMap

+ GetAllHeaders func() map[string][]string

type NetworkCAPI

+ UpstreamConnEnableHalfClose func(f unsafe.Pointer, enableHalfClose int)

type StreamFilterCallbacks

+ ClearRouteCache func()

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

+ Log func(level LogType, msg string)

+ LogLevel func() LogType

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

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

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)