types

package

Go to main page

Versions in this module

v1

v1.6.0

Aug 17, 2023

Changes in this version

type HostStats

+ UpstreamResponseClientErrorEWMA metrics.EWMA

+ UpstreamResponseServerErrorEWMA metrics.EWMA

+ UpstreamResponseTotalEWMA metrics.EWMA

v1.5.0

Apr 25, 2023

Changes in this version

type ClusterInfo

+ IsClusterPoolEnable func() bool

+ SlowStart func() SlowStart

type ClusterStats

+ UpstreamRequestDurationEWMA metrics.EWMA

type Host

+ LastHealthCheckPassTime func() time.Time

+ SetLastHealthCheckPassTime func(lastHealthCheckPassTime time.Time)

type HostStats

+ UpstreamRequestDurationEWMA metrics.EWMA

type LoadBalancerType

+ const PeakEwma

+ type SlowStart struct

+ Aggression float64

+ MinWeightPercent float64

+ Mode SlowStartMode

+ SlowStartDuration time.Duration

+ type SlowStartMode string

+ const ModeDuration

v1.4.0

Feb 28, 2023

Changes in this version

+ const VarProcessTimeDuration

+ type HealthCheckLog interface

+ Log func(host Host, changedState bool, isHealthy bool)

type LoadBalancerType

+ const LeastActiveConnection

v1.3.0

Dec 1, 2022

v1.2.0

Oct 28, 2022

Changes in this version

+ const VarAcceptBuffer

+ const VarAcceptChan

+ const VarAccessLogs

+ const VarConnDefaultReadBufferSize

+ const VarConnection

+ const VarConnectionEventListeners

+ const VarConnectionFd

+ const VarConnectionPoolIndex

+ const VarDownStreamProtocol

+ const VarDownStreamReqHeaders

+ const VarDownStreamRespHeaders

+ const VarListenerName

+ const VarListenerPort

+ const VarListenerType

+ const VarNetworkFilterChainFactories

+ const VarOriRemoteAddr

+ const VarProxyGeneralConfig

+ const VarStreamID

+ const VarTraceId

+ const VarTraceSpan

+ const VarTraceSpanKey

+ const VarUpStreamProtocol

+ var VariableAcceptBuffer = variable.NewVariable(VarAcceptBuffer, nil, nil, variable.DefaultSetter, 0)

+ var VariableAcceptChan = variable.NewVariable(VarAcceptChan, nil, nil, variable.DefaultSetter, 0)

+ var VariableAccessLogs = variable.NewVariable(VarAccessLogs, nil, nil, variable.DefaultSetter, 0)

+ var VariableConnDefaultReadBufferSize = variable.NewVariable(VarConnDefaultReadBufferSize, nil, nil, variable.DefaultSetter, 0)

+ var VariableConnection = variable.NewVariable(VarConnection, nil, nil, variable.DefaultSetter, 0)

+ var VariableConnectionEventListeners = variable.NewVariable(VarConnectionEventListeners, nil, nil, variable.DefaultSetter, 0)

+ var VariableConnectionFd = variable.NewVariable(VarConnectionFd, nil, nil, variable.DefaultSetter, 0)

+ var VariableConnectionID = variable.NewVariable(VarConnectionID, nil, nil, variable.DefaultSetter, 0)

+ var VariableConnectionPoolIndex = variable.NewVariable(VarConnectionPoolIndex, nil, nil, variable.DefaultSetter, 0)

+ var VariableDownStreamProtocol = variable.NewVariable(VarDownStreamProtocol, nil, nil, variable.DefaultSetter, 0)

+ var VariableDownStreamReqHeaders = variable.NewVariable(VarDownStreamReqHeaders, nil, nil, variable.DefaultSetter, 0)

+ var VariableDownStreamRespHeaders = variable.NewVariable(VarDownStreamRespHeaders, nil, nil, variable.DefaultSetter, 0)

+ var VariableListenerName = variable.NewVariable(VarListenerName, nil, nil, variable.DefaultSetter, 0)

+ var VariableListenerPort = variable.NewVariable(VarListenerPort, nil, nil, variable.DefaultSetter, 0)

+ var VariableListenerType = variable.NewVariable(VarListenerType, nil, nil, variable.DefaultSetter, 0)

+ var VariableNetworkFilterChainFactories = variable.NewVariable(VarNetworkFilterChainFactories, nil, nil, variable.DefaultSetter, 0)

+ var VariableOriRemoteAddr = variable.NewVariable(VarOriRemoteAddr, nil, nil, variable.DefaultSetter, 0)

+ var VariableProxyGeneralConfig = variable.NewVariable(VarProxyGeneralConfig, nil, nil, variable.DefaultSetter, 0)

+ var VariableStreamID = variable.NewVariable(VarStreamID, nil, nil, variable.DefaultSetter, 0)

+ var VariableTraceId = variable.NewVariable(VarTraceId, nil, nil, variable.DefaultSetter, 0)

+ var VariableTraceSpan = variable.NewVariable(VarTraceSpan, nil, nil, variable.DefaultSetter, 0)

+ var VariableTraceSpankey = variable.NewVariable(VarTraceSpanKey, nil, nil, variable.DefaultSetter, 0)

+ var VariableUpstreamConnectionID = variable.NewVariable(VarUpstreamConnectionID, nil, nil, variable.DefaultSetter, 0)

+ var VariableUpstreamProtocol = variable.NewVariable(VarUpStreamProtocol, nil, nil, variable.DefaultSetter, 0)

type ClientConnection

+ SetMark func(uint32)

type ClusterInfo

+ Mark func() uint32

type Listener

+ GetOriginalDstType func() v2.OriginalDstType

+ IsOriginalDst func() bool

+ SetOriginalDstType func(use v2.OriginalDstType)

v1.1.0

Aug 23, 2022

Changes in this version

+ const AllHostMetaKey

+ const FallbackMetaKey

+ const MetaKeySep

+ const VarConnectionID

+ const VarTraceID

+ const VarUpstreamConnectionID

type ClusterManager

+ AddOrUpdateClusterAndHost func(cluster v2.Cluster, hosts []v2.Host) error

+ UpdateCluster func(cluster v2.Cluster, clusterHandler ClusterUpdateHandler) error

+ UpdateHosts func(clusterName string, hostConfigs []v2.Host, hostHandler HostUpdateHandler) error

+ type ClusterUpdateHandler func(oldCluster, newCluster Cluster)

type ContextKey

+ const ContextKeyConnectionEventListeners

+ const ContextUpstreamConnectionID

type HostSet

+ Get func(i int) Host

+ Range func(func(Host) bool)

+ Size func() int

+ type HostUpdateHandler func(cluster Cluster, hostConfigs []v2.Host)

+ type SubsetLoadBalancer interface

+ LoadBalancers func() map[string]LoadBalancer

v1.0.1

May 11, 2022

v1.0.0

Apr 15, 2022

v0

v0.27.0

Apr 6, 2022

Changes in this version

+ const VarListenerMatchFallbackIP

+ const VarRequestRawData

+ const VarResponseRawData

type ClusterInfo

+ IdleTimeout func() time.Duration

type ConnectionHandler

+ CloseListeners func()

+ GracefulCloseListener func(lctx context.Context, name string) error

+ GracefulStopListener func(lctx context.Context, name string) error

+ GracefulStopListeners func() error

type LBOriDstInfo

+ IsReplaceLocal func() bool

type Listener

+ Shutdown func() error

type ListenerEventListener

+ OnShutdown func()

type SdsClient

+ FetchSecret func(ctx context.Context, name string) (*SdsSecret, error)

+ RequireSecret func(name string)

type SecretProvider

+ AckResponse func(resp interface{})

v0.26.0

Dec 28, 2021

Changes in this version

+ const VarProtocolConfig

+ var MosnUDSPath = MosnConfigPath

type ContextKey

+ const ContextKeyUpStreamProtocol

+ type NewConnPool func(ctx context.Context, host Host) ConnectionPool

+ type ProtocolStreamFactory interface

+ CreateBiDirectStream func(context context.Context, connection ClientConnection, ...) ClientStreamConnection

+ CreateClientStream func(context context.Context, connection ClientConnection, ...) ClientStreamConnection

+ CreateServerStream func(context context.Context, connection api.Connection, ...) ServerStreamConnection

+ ProtocolMatch func(context context.Context, prot string, magic []byte) error

v0.25.0

Oct 12, 2021

Changes in this version

+ const VarHttp2RequestUseStream

+ const VarHttp2ResponseUseStream

+ const VarProtocolRequestUseStream

+ const VarProtocolResponseUseStream

+ const VarProxyDisableRetry

v0.24.0

Aug 5, 2021

Changes in this version

+ const VarRouterMeta

v0.23.0

Jun 4, 2021

Changes in this version

type ClusterInfo

+ SubType func() string

type ClusterManager

+ ShutdownConnectionPool func(proto ProtocolName, addr string)

v0.22.0

Apr 2, 2021

Changes in this version

+ const VarHttp2RequestPathOriginal

+ const VarHttpRequestPathOriginal

+ const VarPathOriginal

+ const VarProtocolRequestPathOriginal

+ type ABI interface

+ GetABIExports func() interface{}

+ GetABIImports func() interface{}

+ Name func() string

+ SetABIImports func(imports interface{})

+ type ABIHandler interface

+ OnInstanceCreate func(instance WasmInstance)

+ OnInstanceDestroy func(instance WasmInstance)

+ OnInstanceStart func(instance WasmInstance)

+ type WasmFunction = common.WasmFunction

+ type WasmInstance = common.WasmInstance

+ type WasmManager interface

+ AddOrUpdateWasm func(wasmConfig v2.WasmPluginConfig) error

+ GetWasmPluginWrapperByName func(pluginName string) WasmPluginWrapper

+ UninstallWasmPluginByName func(pluginName string) error

+ type WasmModule = common.WasmModule

+ type WasmPlugin interface

+ Clear func()

+ EnsureInstanceNum func(num int) int

+ Exec func(f func(instance WasmInstance) bool)

+ GetInstance func() WasmInstance

+ GetPluginConfig func() v2.WasmPluginConfig

+ GetVmConfig func() v2.WasmVmConfig

+ InstanceNum func() int

+ PluginName func() string

+ ReleaseInstance func(instance WasmInstance)

+ SetCpuLimit func(cpu int)

+ SetMemLimit func(mem int)

+ type WasmPluginHandler interface

+ OnConfigUpdate func(config v2.WasmPluginConfig)

+ OnPluginDestroy func(plugin WasmPlugin)

+ OnPluginStart func(plugin WasmPlugin)

+ type WasmPluginWrapper interface

+ GetConfig func() v2.WasmPluginConfig

+ GetPlugin func() WasmPlugin

+ RegisterPluginHandler func(pluginHandler WasmPluginHandler)

+ Update func(config v2.WasmPluginConfig, plugin WasmPlugin)

+ type WasmVM = common.WasmVM

v0.21.0

Feb 2, 2021

Changes in this version

+ const HeaderOriginalPath

+ const RPCRouteMatchKey

+ const VarDirection

+ const VarHeaderRPCMethod

+ const VarHeaderRPCService

+ const VarHeaderStatus

+ const VarHost

+ const VarIstioHeaderHost

+ const VarMethod

+ const VarPath

+ const VarQueryString

+ const VarScheme

+ type HeaderMatcher interface

+ HeaderMatchCriteria func() api.KeyValueMatchCriteria

+ Matches func(ctx context.Context, requestHeaders api.HeaderMap) bool

v0.20.0

Jan 5, 2021

Changes in this version

+ const DefaultRouteHandler

+ const ErrorKeyConfigParse

+ const MosnProcessFailedFlags

+ var TransferMosnconfigDomainSocket = MosnConfigPath + string(os.PathSeparator) + "mosnconfig.sock"

type LoadBalancerType

+ const RequestRoundRobin

v0.19.0

Dec 1, 2020

Changes in this version

+ const VarProxyIsDirectResponse

+ const VarRequestedServerName

+ const VarResponseFlags

+ const VarRouteName

+ const VarUpstreamCluster

+ const VarUpstreamTransportFailureReason

+ var ClusterID = "Kubernetes"

+ var IsDirectResponse = "true"

v0.18.0

Nov 3, 2020

Changes in this version

+ var ErrWriteBufferChanTimeout = errors.New("writeBufferChan has timeout")

+ type TLSClientContextManager interface

+ Fallback func() bool

+ HashValue func() *HashValue

v0.17.0

Sep 30, 2020

Changes in this version

type ContextKey

+ const ContextKeyConnection

+ const ContextKeyConnectionPoolIndex

type Listener

+ IsBindToPort func() bool

+ type PoolMode int

+ const Multiplex

+ const PingPong

+ const TCP

type StreamConnection

+ EnableWorkerPool func() bool

v0.16.0

Sep 2, 2020

Changes in this version

type ClusterManager

+ GetTLSManager func() TLSContextManager

+ UpdateTLSManager func(*v2.TLSConfig)

v0.15.0

Aug 5, 2020

Changes in this version

+ const DefaultUDPIdleTimeout

+ const DefaultUDPReadTimeout

+ const ErrorKeyProxyPanic

+ const VarHttp2RequestScheme

+ const VarHttpRequestScheme

+ const VarProtocolRequestScheme

type ClusterManager

+ UDPConnForCluster func(balancerContext LoadBalancerContext, snapshot ClusterSnapshot) CreateConnectionData

type ConnectionPool

+ TLSHashValue func() *HashValue

type ContextKey

+ const ContextKeyConfigDownStreamProtocol

+ const ContextKeyConfigUpStreamProtocol

+ const ContextKeyDownStreamRespHeaders

+ const ContextKeyStreamFilterPhase

+ type HashValue struct

+ func NewHashValue(v [sha256.Size]byte) *HashValue

+ func (v *HashValue) Equal(hash *HashValue) bool

+ func (v *HashValue) String() string

type Host

+ CreateUDPConnection func(context context.Context) CreateConnectionData

+ SetClusterInfo func(info ClusterInfo)

+ TLSHashValue func() *HashValue

+ type TLSConfigContext struct

+ func NewTLSConfigContext(cfg *tls.Config, f func(cfg *tls.Config) *HashValue) *TLSConfigContext

+ func (ctx *TLSConfigContext) Config() *tls.Config

+ func (ctx *TLSConfigContext) HashValue() *HashValue

type TLSContextManager

+ HashValue func() *HashValue

type TLSProvider

+ GetTLSConfigContext func(client bool) *TLSConfigContext

v0.14.0

Jul 1, 2020

Changes in this version

+ const GlobalShutdownTimeout

+ const VarHttp2RequestArg

+ const VarHttp2RequestLength

+ const VarHttp2RequestMethod

+ const VarHttp2RequestPath

+ const VarHttp2RequestUri

+ const VarPrefixHttp2Arg

+ const VarPrefixHttp2Cookie

+ const VarPrefixHttp2Header

+ const VarProtocolCookie

+ const VarProtocolRequestArg

+ const VarProtocolRequestArgPrefix

+ const VarProtocolRequestHeader

+ const VarProtocolRequestLength

+ const VarProtocolRequestMethod

+ const VarProtocolRequestPath

+ const VarProtocolRequestUri

+ var IstioPodInfoPath = "/etc/istio/pod"

+ var IstioVersion = "unknow"

+ var PhaseName = []string

+ func GetPodLabels() map[string]string

+ func IsApplicationNodeType(nType string) bool

type ClusterInfo

+ ClusterType func() v2.ClusterType

type ContextKey

+ const ContextKeyDownStreamHeaders

+ const ContextKeyProxyGeneralConfig

type ListenerEventListener

+ PreStopHook func(ctx context.Context) func() error

type LoadBalancerContext

+ DownstreamRoute func() api.Route

type LoadBalancerType

+ const Maglev

+ type NodeType string

+ const AllPortsLiteral

+ const Router

+ const SidecarProxy

+ type TrafficInterceptionMode string

+ const InterceptionNone

+ const InterceptionRedirect

+ const InterceptionTproxy

+ type XdsStats struct

+ CdsUpdateReject metrics.Counter

+ CdsUpdateSuccess metrics.Counter

+ LdsUpdateReject metrics.Counter

+ LdsUpdateSuccess metrics.Counter

v0.13.0

Jun 1, 2020

Changes in this version

+ const InternalErrorCode

+ const VarProxyGzipSwitch

+ func ConvertReasonToCode(reason StreamResetReason) int

v0.12.0

Apr 28, 2020

Changes in this version

+ const VarHttpRequestArg

+ const VarHttpRequestPath

+ const VarHttpRequestUri

type ClusterInfo

+ LbConfig func() v2.IsCluster_LbConfig

type ConnectionPool

+ Host func() Host

+ UpdateHost func(Host)

type ContextKey

+ const ContextKeyDownStreamProtocol

+ const ContextKeyH2Stream

type LoadBalancerType

+ const LeastActiveRequest

+ const WeightedRoundRobin

type Phase

+ const ChooseHost

+ const DownFilterAfterChooseHost

+ const WaitNotify

type Resource

+ Cur func() int64

+ UpdateCur func(int64)

v0.11.0

Apr 3, 2020

Changes in this version

+ const DefaultIdleTimeout

+ const ErrorKeySdsFailed

+ const ErrorKeyTLSRead

+ const VarBytesReceived

+ const VarBytesSent

+ const VarDownstreamLocalAddress

+ const VarDownstreamRemoteAddress

+ const VarDuration

+ const VarHttpRequestLength

+ const VarHttpRequestMethod

+ const VarPrefixHttpArg

+ const VarPrefixHttpCookie

+ const VarPrefixHttpHeader

+ const VarPrefixReqHeader

+ const VarPrefixRespHeader

+ const VarProtocol

+ const VarProxyGlobalTimeout

+ const VarProxyHijackStatus

+ const VarProxyTryTimeout

+ const VarRequestFinishedDuration

+ const VarRequestReceivedDuration

+ const VarResponseCode

+ const VarResponseFlag

+ const VarResponseReceivedDuration

+ const VarStartTime

+ const VarUpstreamHost

+ const VarUpstreamLocalAddress

type ClusterInfo

+ LbOriDstInfo func() LBOriDstInfo

+ type LBOriDstInfo interface

+ GetHeader func() string

+ IsEnabled func() bool

type LoadBalancerContext

+ DownstreamCluster func() ClusterInfo

type LoadBalancerType

+ const ORIGINAL_DST

+ type MatchResult int

+ const MatchAgain

+ const MatchFailed

+ const MatchSuccess

type Protocol

+ Name func() ProtocolName

type ProtocolEngine

+ Match func(ctx context.Context, data IoBuffer) (ProtocolName, MatchResult)

+ type ProtocolMatch func(data []byte) MatchResult

+ type ProtocolName = api.Protocol

v0.10.0

Feb 28, 2020

Changes in this version

+ const ChannelFullException

+ const CodecException

+ const CodecExceptionCode

+ const DefaultAccessLogFormat

+ const DefaultConnReadTimeout

+ const DefaultConnTryTimeout

+ const DefaultConnWriteTimeout

+ const DefaultRouteTimeout

+ const DeserialExceptionCode

+ const DeserializeException

+ const ErrorKeyAdmin

+ const ErrorKeyAppendHeader

+ const ErrorKeyClusterGet

+ const ErrorKeyCodec

+ const ErrorKeyConfigDump

+ const ErrorKeyHeartBeat

+ const ErrorKeyReconfigure

+ const ErrorKeyRouteMatch

+ const ErrorKeyTLSFallback

+ const ErrorKeyUpstreamConn

+ const ErrorModuleMosn

+ const ErrorSubModuleAdmin

+ const ErrorSubModuleCommon

+ const ErrorSubModuleIO

+ const ErrorSubModuleProxy

+ const GlobalProxyName

+ const GlobalTimeout

+ const HeaderException

+ const HeaderGlobalTimeout

+ const HeaderHost

+ const HeaderMethod

+ const HeaderPath

+ const HeaderQueryString

+ const HeaderRPCMethod

+ const HeaderRPCService

+ const HeaderStatus

+ const HeaderStreamID

+ const HeaderStremEnd

+ const HeaderTryTimeout

+ const HeaderXprotocolHeartbeat

+ const HeaderXprotocolRespIsException

+ const HeaderXprotocolRespStatus

+ const HeaderXprotocolStreamId

+ const HeaderXprotocolSubProtocol

+ const LimitExceededCode

+ const NoHealthUpstreamCode

+ const NoStatusCodeForHijackException

+ const PermissionDeniedCode

+ const RouterMetadataKey

+ const RouterMetadataKeyLb

+ const RouterUnavailableCode

+ const SerializeException

+ const SofaRouteMatchKey

+ const SofaRouterType

+ const SuccessCode

+ const TimeoutExceptionCode

+ const UnknownCode

+ const UpstreamOverFlowCode

+ var ConnPoolFactories map[api.Protocol]bool

+ var ErrChanFull = errors.New(ChannelFullException)

+ var ErrCodecException = errors.New(CodecException)

+ var ErrConnectionHasClosed = errors.New("connection has closed")

+ var ErrDeserializeException = errors.New(DeserializeException)

+ var ErrExit = errors.New("downstream process completed")

+ var ErrNoStatusCodeForHijack = errors.New(NoStatusCodeForHijackException)

+ var ErrSerializeException = errors.New(SerializeException)

+ var ErrWriteTryLockTimeout = errors.New("write trylock has timeout")

+ var MosnBasePath = ...

+ var MosnConfigPath = MosnBasePath + string(os.PathSeparator) + "conf"

+ var MosnLogBasePath = MosnBasePath + string(os.PathSeparator) + "logs"

+ var MosnLogDefaultPath = MosnLogBasePath + string(os.PathSeparator) + "mosn.log"

+ var MosnLogProxyPath = MosnLogBasePath + string(os.PathSeparator) + "proxy.log"

+ var MosnPidDefaultFileName = MosnLogBasePath + string(os.PathSeparator) + "mosn.pid"

+ var ReconfigureDomainSocket = MosnConfigPath + string(os.PathSeparator) + "reconfig.sock"

+ var TransferConnDomainSocket = MosnConfigPath + string(os.PathSeparator) + "conn.sock"

+ var TransferListenDomainSocket = MosnConfigPath + string(os.PathSeparator) + "listen.sock"

+ var TransferStatsDomainSocket = MosnConfigPath + string(os.PathSeparator) + "stats.sock"

+ func InitDefaultPath(path string)

+ func InitXdsFlags(serviceCluster, serviceNode string, serviceMeta []string)

+ func RegisterConnPoolFactory(protocol api.Protocol, registered bool)

+ type Addresses []net.Addr

+ func (as Addresses) Contains(addr net.Addr) bool

+ type BufferPoolCtx interface

+ Index func() int

+ New func() interface{}

+ Reset func(interface{})

+ type ClientConnection interface

+ Connect func() error

+ type ClientStreamConnection interface

+ NewStream func(ctx context.Context, responseReceiveListener StreamReceiveListener) StreamSender

+ type Cluster interface

+ AddHealthCheckCallbacks func(cb HealthCheckCb)

+ Snapshot func() ClusterSnapshot

+ StopHealthChecking func()

+ UpdateHosts func([]Host)

+ type ClusterConfigFactoryCb interface

+ UpdateClusterConfig func(configs []v2.Cluster) error

+ type ClusterHostFactoryCb interface

+ UpdateClusterHost func(cluster string, hosts []v2.Host) error

+ type ClusterInfo interface

+ ConnBufferLimitBytes func() uint32

+ ConnectTimeout func() time.Duration

+ LbSubsetInfo func() LBSubsetInfo

+ LbType func() LoadBalancerType

+ MaxRequestsPerConn func() uint32

+ Name func() string

+ ResourceManager func() ResourceManager

+ Stats func() ClusterStats

+ TLSMng func() TLSContextManager

+ type ClusterManager interface

+ AddClusterHealthCheckCallbacks func(name string, cb HealthCheckCb) error

+ AddOrUpdatePrimaryCluster func(cluster v2.Cluster) error

+ AppendClusterHosts func(clusterName string, hostConfigs []v2.Host) error

+ ClusterExist func(clusterName string) bool

+ ConnPoolForCluster func(balancerContext LoadBalancerContext, snapshot ClusterSnapshot, ...) ConnectionPool

+ Destroy func()

+ GetClusterSnapshot func(context context.Context, cluster string) ClusterSnapshot

+ PutClusterSnapshot func(ClusterSnapshot)

+ RemoveClusterHosts func(clusterName string, hosts []string) error

+ RemovePrimaryCluster func(clusters ...string) error

+ TCPConnForCluster func(balancerContext LoadBalancerContext, snapshot ClusterSnapshot) CreateConnectionData

+ UpdateClusterHosts func(cluster string, hosts []v2.Host) error

+ type ClusterManagerFilter interface

+ OnCreated func(cccb ClusterConfigFactoryCb, chcb ClusterHostFactoryCb)

+ type ClusterSnapshot interface

+ ClusterInfo func() ClusterInfo

+ HostNum func(metadata api.MetadataMatchCriteria) int

+ HostSet func() HostSet

+ IsExistsHosts func(metadata api.MetadataMatchCriteria) bool

+ LoadBalancer func() LoadBalancer

+ type ClusterStats struct

+ LBSubSetsFallBack metrics.Counter

+ LBSubsetsCreated metrics.Gauge

+ UpstreamBytesReadTotal metrics.Counter

+ UpstreamBytesWriteTotal metrics.Counter

+ UpstreamConnectionActive metrics.Counter

+ UpstreamConnectionClose metrics.Counter

+ UpstreamConnectionCloseNotify metrics.Counter

+ UpstreamConnectionConFail metrics.Counter

+ UpstreamConnectionLocalClose metrics.Counter

+ UpstreamConnectionLocalCloseWithActiveRequest metrics.Counter

+ UpstreamConnectionRemoteClose metrics.Counter

+ UpstreamConnectionRemoteCloseWithActiveRequest metrics.Counter

+ UpstreamConnectionRetry metrics.Counter

+ UpstreamConnectionTotal metrics.Counter

+ UpstreamRequestActive metrics.Counter

+ UpstreamRequestDuration metrics.Histogram

+ UpstreamRequestDurationTotal metrics.Counter

+ UpstreamRequestFailureEject metrics.Counter

+ UpstreamRequestLocalReset metrics.Counter

+ UpstreamRequestPendingOverflow metrics.Counter

+ UpstreamRequestRemoteReset metrics.Counter

+ UpstreamRequestRetry metrics.Counter

+ UpstreamRequestRetryOverflow metrics.Counter

+ UpstreamRequestTimeout metrics.Counter

+ UpstreamRequestTotal metrics.Counter

+ UpstreamResponseFailed metrics.Counter

+ UpstreamResponseSuccess metrics.Counter

+ type ConfigUtility interface

+ MatchHeaders func(requestHeaders map[string]string, configHeaders []*HeaderData) bool

+ MatchQueryParams func(queryParams QueryParams, configQueryParams []QueryParameterMatcher) bool

+ type ConnectionHandler interface

+ AddOrUpdateListener func(lc *v2.Listener, networkFiltersFactories []api.NetworkFilterChainFactory, ...) (ListenerEventListener, error)

+ FindListenerByAddress func(addr net.Addr) Listener

+ FindListenerByName func(name string) Listener

+ ListListenersFile func(lctx context.Context) []*os.File

+ RemoveListeners func(name string)

+ StartListeners func(lctx context.Context)

+ StopConnection func()

+ StopListener func(lctx context.Context, name string, stop bool) error

+ StopListeners func(lctx context.Context, close bool) error

+ type ConnectionPool interface

+ CheckAndInit func(ctx context.Context) bool

+ Close func()

+ NewStream func(ctx context.Context, receiver StreamReceiveListener, ...)

+ Protocol func() api.Protocol

+ Shutdown func()

+ SupportTLS func() bool

+ type ConnectionStats struct

+ ReadBuffered metrics.Gauge

+ ReadTotal metrics.Counter

+ WriteBuffered metrics.Gauge

+ WriteTotal metrics.Counter

+ type ContextKey int

+ const ContextKeyAcceptBuffer

+ const ContextKeyAcceptChan

+ const ContextKeyAccessLogs

+ const ContextKeyActiveSpan

+ const ContextKeyBufferPoolCtx

+ const ContextKeyConnectionFd

+ const ContextKeyConnectionID

+ const ContextKeyEnd

+ const ContextKeyListenerName

+ const ContextKeyListenerPort

+ const ContextKeyListenerStatsNameSpace

+ const ContextKeyListenerType

+ const ContextKeyNetworkFilterChainFactories

+ const ContextKeyStreamFilterChainFactories

+ const ContextKeyStreamID

+ const ContextKeyTraceId

+ const ContextKeyTraceSpanKey

+ const ContextKeyVariables

+ const ContextOriRemoteAddr

+ const ContextSubProtocol

+ type CreateConnectionData struct

+ Connection ClientConnection

+ Host Host

+ type Decoder interface

+ Decode func(ctx context.Context, data buffer.IoBuffer) (interface{}, error)

+ type Driver interface

+ Get func(proto api.Protocol) Tracer

+ Init func(config map[string]interface{}) error

+ Register func(proto api.Protocol, builder TracerBuilder)

+ type Encoder interface

+ Encode func(ctx context.Context, model interface{}) (buffer.IoBuffer, error)

+ type FailureType string

+ const FailureActive

+ const FailureNetwork

+ const FailurePassive

+ type FallBackPolicy uint8

+ const AnyEndPoint

+ const DefaultSubset

+ const NoFallBack

+ type FilterChainFactory interface

+ CreateListenerFilterChain func(listener ListenerFilterManager)

+ CreateNetworkFilterChain func(conn api.Connection)

+ type HandlerStatus int

+ const HandlerAvailable

+ const HandlerNotAvailable

+ const HandlerStop

+ type HeaderData struct

+ IsRegex bool

+ Name LowerCaseString

+ RegexPattern *regexp.Regexp

+ Value string

+ type HeaderFormat interface

+ Append func() bool

+ Format func(info api.RequestInfo) string

+ type HeaderMap = api.HeaderMap

+ type HealthCheckCb func(host Host, changedState bool, isHealthy bool)

+ type HealthCheckSession interface

+ CheckHealth func() bool

+ OnTimeout func()

+ type HealthCheckSessionFactory interface

+ NewSession func(cfg map[string]interface{}, host Host) HealthCheckSession

+ type HealthChecker interface

+ AddHostCheckCompleteCb func(cb HealthCheckCb)

+ SetHealthCheckerHostSet func(HostSet)

+ Start func()

+ Stop func()

+ type HealthFlag int

+ const FAILED_ACTIVE_HC

+ const FAILED_OUTLIER_CHECK

+ type Host interface

+ Address func() net.Addr

+ ClearHealthFlag func(flag HealthFlag)

+ ClusterInfo func() ClusterInfo

+ Config func() v2.Host

+ ContainHealthFlag func(flag HealthFlag) bool

+ CreateConnection func(context context.Context) CreateConnectionData

+ Health func() bool

+ HealthFlag func() HealthFlag

+ HostStats func() HostStats

+ SetHealthFlag func(flag HealthFlag)

+ type HostInfo = api.HostInfo

+ type HostPredicate func(Host) bool

+ type HostSet interface

+ HealthyHosts func() []Host

+ Hosts func() []Host

+ type HostStats struct

+ UpstreamConnectionActive metrics.Counter

+ UpstreamConnectionClose metrics.Counter

+ UpstreamConnectionCloseNotify metrics.Counter

+ UpstreamConnectionConFail metrics.Counter

+ UpstreamConnectionLocalClose metrics.Counter

+ UpstreamConnectionLocalCloseWithActiveRequest metrics.Counter

+ UpstreamConnectionRemoteClose metrics.Counter

+ UpstreamConnectionRemoteCloseWithActiveRequest metrics.Counter

+ UpstreamConnectionTotal metrics.Counter

+ UpstreamRequestActive metrics.Counter

+ UpstreamRequestDuration metrics.Histogram

+ UpstreamRequestDurationTotal metrics.Counter

+ UpstreamRequestFailureEject metrics.Counter

+ UpstreamRequestLocalReset metrics.Counter

+ UpstreamRequestPendingOverflow metrics.Counter

+ UpstreamRequestRemoteReset metrics.Counter

+ UpstreamRequestTimeout metrics.Counter

+ UpstreamRequestTotal metrics.Counter

+ UpstreamResponseFailed metrics.Counter

+ UpstreamResponseSuccess metrics.Counter

+ type IoBuffer = buffer.IoBuffer

+ type KeepAlive interface

+ AddCallback func(cb KeepAliveCallback)

+ GetTimeout func() time.Duration

+ HandleSuccess func(id uint64)

+ HandleTimeout func(id uint64)

+ SendKeepAlive func()

+ StartIdleTimeout func()

+ Stop func()

+ type KeepAliveCallback func(KeepAliveStatus)

+ type KeepAliveStatus int

+ const KeepAliveSuccess

+ const KeepAliveTimeout

+ type LBSubsetEntry interface

+ Active func() bool

+ Children func() LbSubsetMap

+ CreateLoadBalancer func(LoadBalancerType, HostSet)

+ HostNum func() int

+ Initialized func() bool

+ LoadBalancer func() LoadBalancer

+ type LBSubsetInfo interface

+ DefaultSubset func() SubsetMetadata

+ FallbackPolicy func() FallBackPolicy

+ IsEnabled func() bool

+ SubsetKeys func() []SortedStringSetType

+ type LbSubsetMap map[string]ValueSubsetMap

+ type Listener interface

+ Addr func() net.Addr

+ Close func(lctx context.Context) error

+ Config func() *v2.Listener

+ GetListenerCallbacks func() ListenerEventListener

+ ListenerFile func() (*os.File, error)

+ ListenerTag func() uint64

+ Name func() string

+ PerConnBufferLimitBytes func() uint32

+ SetConfig func(config *v2.Listener)

+ SetListenerCallbacks func(cb ListenerEventListener)

+ SetListenerTag func(tag uint64)

+ SetPerConnBufferLimitBytes func(limitBytes uint32)

+ SetUseOriginalDst func(use bool)

+ Start func(lctx context.Context, restart bool)

+ Stop func() error

+ UseOriginalDst func() bool

+ type ListenerEventListener interface

+ OnAccept func(rawc net.Conn, useOriginalDst bool, oriRemoteAddr net.Addr, ...)

+ OnClose func()

+ OnNewConnection func(ctx context.Context, conn api.Connection)

+ type ListenerFilter interface

+ OnAccept func(cb ListenerFilterCallbacks) api.FilterStatus

+ type ListenerFilterCallbacks interface

+ Conn func() net.Conn

+ ContinueFilterChain func(ctx context.Context, success bool)

+ SetOriginalAddr func(ip string, port int)

+ type ListenerFilterManager interface

+ AddListenerFilter func(lf *ListenerFilter)

+ type LoadBalancer interface

+ ChooseHost func(context LoadBalancerContext) Host

+ HostNum func(api.MetadataMatchCriteria) int

+ IsExistsHosts func(api.MetadataMatchCriteria) bool

+ type LoadBalancerContext interface

+ DownstreamConnection func() net.Conn

+ DownstreamContext func() context.Context

+ DownstreamHeaders func() api.HeaderMap

+ MetadataMatchCriteria func() api.MetadataMatchCriteria

+ type LoadBalancerType string

+ const Random

+ const RoundRobin

+ type LowerCaseString interface

+ Equal func(rhs LowerCaseString) bool

+ Get func() string

+ Lower func()

+ type Metrics interface

+ Counter func(key string) metrics.Counter

+ Each func(func(string, interface{}))

+ Gauge func(key string) metrics.Gauge

+ Histogram func(key string) metrics.Histogram

+ Labels func() map[string]string

+ SortedLabels func() (keys, vals []string)

+ Type func() string

+ UnregisterAll func()

+ type MetricsSink interface

+ Flush func(writer io.Writer, metrics []Metrics)

+ type Pair struct

+ T1 string

+ T2 string

+ type Phase int

+ const DownFilter

+ const DownFilterAfterRoute

+ const DownRecvData

+ const DownRecvHeader

+ const DownRecvTrailer

+ const End

+ const InitPhase

+ const MatchRoute

+ const Oneway

+ const Retry

+ const UpFilter

+ const UpRecvData

+ const UpRecvHeader

+ const UpRecvTrailer

+ const WaitNofity

+ type PoolEventListener interface

+ OnFailure func(reason PoolFailureReason, host Host)

+ OnReady func(sender StreamSender, host Host)

+ type PoolFailureReason string

+ const ConnectionFailure

+ const Overflow

+ type Protocol = api.Protocol

+ type ProtocolEngine interface

+ Register func(protocolCode byte, encoder Encoder, decoder Decoder) error

+ type QueryParameterMatcher interface

+ Matches func(requestQueryParams QueryParams) bool

+ type QueryParams map[string]string

+ type RegisterUpstreamUpdateMethodCb interface

+ GetClusterNameByServiceName func(serviceName string) string

+ TriggerClusterUpdate func(clusterName string, hosts []v2.Host)

+ type RequestInfo = api.RequestInfo

+ type Resource interface

+ CanCreate func() bool

+ Decrease func()

+ Increase func()

+ Max func() uint64

+ type ResourceManager interface

+ Connections func() Resource

+ PendingRequests func() Resource

+ Requests func() Resource

+ Retries func() Resource

+ type Route = api.Route

+ type RouteHandler interface

+ IsAvailable func(context.Context, ClusterManager) (ClusterSnapshot, HandlerStatus)

+ Route func() api.Route

+ type RouterManager interface

+ AddOrUpdateRouters func(routerConfig *v2.RouterConfiguration) error

+ AddRoute func(routerConfigName, domain string, route *v2.Router) error

+ GetRouterWrapperByName func(routerConfigName string) RouterWrapper

+ RemoveAllRoutes func(routerConfigName, domain string) error

+ type RouterType string

+ type RouterWrapper interface

+ GetRouters func() Routers

+ GetRoutersConfig func() v2.RouterConfiguration

+ type Routers interface

+ AddRoute func(domain string, route *v2.Router) int

+ MatchAllRoutes func(headers api.HeaderMap, randomValue uint64) []api.Route

+ MatchRoute func(headers api.HeaderMap, randomValue uint64) api.Route

+ MatchRouteFromHeaderKV func(headers api.HeaderMap, key, value string) api.Route

+ RemoveAllRoutes func(domain string) int

+ type SdsClient interface

+ AddUpdateCallback func(sdsConfig *auth.SdsSecretConfig, callback SdsUpdateCallbackFunc) error

+ DeleteUpdateCallback func(sdsConfig *auth.SdsSecretConfig) error

+ SetSecret func(name string, secret *auth.Secret)

+ type SdsSecret struct

+ CertificatePEM string

+ Name string

+ PrivateKeyPEM string

+ ValidationPEM string

+ func SecretConvert(raw *auth.Secret) *SdsSecret

+ type SdsUpdateCallbackFunc func(name string, secret *SdsSecret)

+ type SecretProvider interface

+ SetSecret func(name string, secret *auth.Secret)

+ type ServerStreamConnection interface

+ type ServerStreamConnectionEventListener interface

+ NewStreamDetect func(context context.Context, sender StreamSender, span Span) StreamReceiveListener

+ type SimpleCluster interface

+ UpdateHosts func(newHosts []Host)

+ type SortedHosts []Host

+ func (s SortedHosts) Len() int

+ func (s SortedHosts) Less(i, j int) bool

+ func (s SortedHosts) Swap(i, j int)

+ type SortedStringSetType struct

+ func InitSet(input []string) SortedStringSetType

+ func (ss *SortedStringSetType) Keys() []string

+ func (ss *SortedStringSetType) Len() int

+ func (ss *SortedStringSetType) Less(i, j int) bool

+ func (ss *SortedStringSetType) Swap(i, j int)

+ type Span interface

+ FinishSpan func()

+ InjectContext func(requestHeaders api.HeaderMap)

+ ParentSpanId func() string

+ SetOperation func(operation string)

+ SetRequestInfo func(requestInfo api.RequestInfo)

+ SetTag func(key uint64, value string)

+ SpanId func() string

+ SpawnChild func(operationName string, startTime time.Time) Span

+ Tag func(key uint64) string

+ TraceId func() string

+ type Stream interface

+ AddEventListener func(streamEventListener StreamEventListener)

+ DestroyStream func()

+ ID func() uint64

+ RemoveEventListener func(streamEventListener StreamEventListener)

+ ResetStream func(reason StreamResetReason)

+ type StreamConnection interface

+ ActiveStreamsNum func() int

+ CheckReasonError func(connected bool, event api.ConnectionEvent) (StreamResetReason, bool)

+ Dispatch func(buffer buffer.IoBuffer)

+ GoAway func()

+ Protocol func() api.Protocol

+ Reset func(reason StreamResetReason)

+ type StreamConnectionEventListener interface

+ OnGoAway func()

+ type StreamEventListener interface

+ OnDestroyStream func()

+ OnResetStream func(reason StreamResetReason)

+ type StreamReceiveListener interface

+ OnDecodeError func(ctx context.Context, err error, headers api.HeaderMap)

+ OnReceive func(ctx context.Context, headers api.HeaderMap, data buffer.IoBuffer, ...)

+ type StreamResetReason string

+ const StreamConnectionFailed

+ const StreamConnectionSuccessed

+ const StreamConnectionTermination

+ const StreamLocalReset

+ const StreamOverflow

+ const StreamRemoteReset

+ const UpstreamGlobalTimeout

+ const UpstreamPerTryTimeout

+ const UpstreamReset

+ type StreamSender interface

+ AppendData func(ctx context.Context, data buffer.IoBuffer, endStream bool) error

+ AppendHeaders func(ctx context.Context, headers api.HeaderMap, endStream bool) error

+ AppendTrailers func(ctx context.Context, trailers api.HeaderMap) error

+ GetStream func() Stream

+ type SubsetMetadata []Pair

+ type TLSContextManager interface

+ Conn func(net.Conn) (net.Conn, error)

+ Enabled func() bool

+ type TLSProvider interface

+ Empty func() bool

+ GetTLSConfig func(client bool) *tls.Config

+ MatchedALPN func(protos []string) bool

+ MatchedServerName func(sn string) bool

+ Ready func() bool

+ type Tracer interface

+ Start func(ctx context.Context, request interface{}, startTime time.Time) Span

+ type TracerBuilder func(config map[string]interface{}) (Tracer, error)

+ type ValueSubsetMap map[string]LBSubsetEntry

+ type VirtualHost interface

+ AddRoute func(route *v2.Router) error

+ GetAllRoutesFromEntries func(headers api.HeaderMap, randomValue uint64) []api.Route

+ GetRouteFromEntries func(headers api.HeaderMap, randomValue uint64) api.Route

+ GetRouteFromHeaderKV func(key, value string) api.Route

+ Name func() string

+ RemoveAllRoutes func()

+ type XdsInfo struct

+ Metadata *types.Struct

+ ServiceCluster string

+ ServiceNode string

+ func GetGlobalXdsInfo() *XdsInfo

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