Versions in this module Expand all Collapse all v0 v0.16.4 Nov 29, 2024 Changes in this version + var BalanceInboundConnections_name = map[int32]string + var BalanceInboundConnections_value = map[string]int32 + var File_pbmesh_v1alpha1_connection_proto protoreflect.FileDescriptor + var File_pbmesh_v1alpha1_expose_proto protoreflect.FileDescriptor + var File_pbmesh_v1alpha1_proxy_proto protoreflect.FileDescriptor + var File_pbmesh_v1alpha1_routing_proto protoreflect.FileDescriptor + var File_pbmesh_v1alpha1_upstreams_proto protoreflect.FileDescriptor + var MeshGatewayMode_name = map[int32]string + var MeshGatewayMode_value = map[string]int32 + var ProxyMode_name = map[int32]string + var ProxyMode_value = map[string]int32 + type BalanceInboundConnections int32 + const BalanceInboundConnections_BALANCE_INBOUND_CONNECTIONS_DEFAULT + const BalanceInboundConnections_BALANCE_INBOUND_CONNECTIONS_EXACT + func (BalanceInboundConnections) Descriptor() protoreflect.EnumDescriptor + func (BalanceInboundConnections) EnumDescriptor() ([]byte, []int) + func (BalanceInboundConnections) Type() protoreflect.EnumType + func (x BalanceInboundConnections) Enum() *BalanceInboundConnections + func (x BalanceInboundConnections) Number() protoreflect.EnumNumber + func (x BalanceInboundConnections) String() string + type BootstrapConfig struct + DogstatsdUrl string + OverrideJsonTpl string + PrometheusBindAddr string + ReadyBindAddr string + StaticClustersJson string + StaticListenersJson string + StatsBindAddr string + StatsConfigJson string + StatsFlushInterval string + StatsSinksJson string + StatsTags []string + StatsdUrl string + TracingConfigJson string + func (*BootstrapConfig) Descriptor() ([]byte, []int) + func (*BootstrapConfig) ProtoMessage() + func (msg *BootstrapConfig) MarshalBinary() ([]byte, error) + func (msg *BootstrapConfig) UnmarshalBinary(b []byte) error + func (x *BootstrapConfig) GetDogstatsdUrl() string + func (x *BootstrapConfig) GetOverrideJsonTpl() string + func (x *BootstrapConfig) GetPrometheusBindAddr() string + func (x *BootstrapConfig) GetReadyBindAddr() string + func (x *BootstrapConfig) GetStaticClustersJson() string + func (x *BootstrapConfig) GetStaticListenersJson() string + func (x *BootstrapConfig) GetStatsBindAddr() string + func (x *BootstrapConfig) GetStatsConfigJson() string + func (x *BootstrapConfig) GetStatsFlushInterval() string + func (x *BootstrapConfig) GetStatsSinksJson() string + func (x *BootstrapConfig) GetStatsTags() []string + func (x *BootstrapConfig) GetStatsdUrl() string + func (x *BootstrapConfig) GetTracingConfigJson() string + func (x *BootstrapConfig) ProtoReflect() protoreflect.Message + func (x *BootstrapConfig) Reset() + func (x *BootstrapConfig) String() string + type ConnectionConfig struct + ConnectTimeoutMs uint64 + RequestTimeoutMs uint64 + func (*ConnectionConfig) Descriptor() ([]byte, []int) + func (*ConnectionConfig) ProtoMessage() + func (msg *ConnectionConfig) MarshalBinary() ([]byte, error) + func (msg *ConnectionConfig) UnmarshalBinary(b []byte) error + func (x *ConnectionConfig) GetConnectTimeoutMs() uint64 + func (x *ConnectionConfig) GetRequestTimeoutMs() uint64 + func (x *ConnectionConfig) ProtoReflect() protoreflect.Message + func (x *ConnectionConfig) Reset() + func (x *ConnectionConfig) String() string + type DynamicConfig struct + ExposeConfig *ExposeConfig + InboundConnections *InboundConnectionsConfig + ListenerTracingJson string + LocalClusterJson string + LocalConnection map[string]*ConnectionConfig + LocalWorkloadAddress string + LocalWorkloadPort uint32 + LocalWorkloadSocketPath string + MeshGatewayMode MeshGatewayMode + Mode ProxyMode + PublicListenerJson string + TransparentProxy *TransparentProxy + func (*DynamicConfig) Descriptor() ([]byte, []int) + func (*DynamicConfig) ProtoMessage() + func (msg *DynamicConfig) MarshalBinary() ([]byte, error) + func (msg *DynamicConfig) UnmarshalBinary(b []byte) error + func (x *DynamicConfig) GetExposeConfig() *ExposeConfig + func (x *DynamicConfig) GetInboundConnections() *InboundConnectionsConfig + func (x *DynamicConfig) GetListenerTracingJson() string + func (x *DynamicConfig) GetLocalClusterJson() string + func (x *DynamicConfig) GetLocalConnection() map[string]*ConnectionConfig + func (x *DynamicConfig) GetLocalWorkloadAddress() string + func (x *DynamicConfig) GetLocalWorkloadPort() uint32 + func (x *DynamicConfig) GetLocalWorkloadSocketPath() string + func (x *DynamicConfig) GetMeshGatewayMode() MeshGatewayMode + func (x *DynamicConfig) GetMode() ProxyMode + func (x *DynamicConfig) GetPublicListenerJson() string + func (x *DynamicConfig) GetTransparentProxy() *TransparentProxy + func (x *DynamicConfig) ProtoReflect() protoreflect.Message + func (x *DynamicConfig) Reset() + func (x *DynamicConfig) String() string + type ExposeConfig struct + ExposePaths []*ExposePath + func (*ExposeConfig) Descriptor() ([]byte, []int) + func (*ExposeConfig) ProtoMessage() + func (msg *ExposeConfig) MarshalBinary() ([]byte, error) + func (msg *ExposeConfig) UnmarshalBinary(b []byte) error + func (x *ExposeConfig) GetExposePaths() []*ExposePath + func (x *ExposeConfig) ProtoReflect() protoreflect.Message + func (x *ExposeConfig) Reset() + func (x *ExposeConfig) String() string + type ExposePath struct + ListenerPort uint32 + LocalPathPort uint32 + Path string + Protocol v1alpha1.Protocol + func (*ExposePath) Descriptor() ([]byte, []int) + func (*ExposePath) ProtoMessage() + func (msg *ExposePath) MarshalBinary() ([]byte, error) + func (msg *ExposePath) UnmarshalBinary(b []byte) error + func (x *ExposePath) GetListenerPort() uint32 + func (x *ExposePath) GetLocalPathPort() uint32 + func (x *ExposePath) GetPath() string + func (x *ExposePath) GetProtocol() v1alpha1.Protocol + func (x *ExposePath) ProtoReflect() protoreflect.Message + func (x *ExposePath) Reset() + func (x *ExposePath) String() string + type InboundConnectionsConfig struct + BalanceInboundConnections BalanceInboundConnections + MaxInboundConnections uint64 + func (*InboundConnectionsConfig) Descriptor() ([]byte, []int) + func (*InboundConnectionsConfig) ProtoMessage() + func (msg *InboundConnectionsConfig) MarshalBinary() ([]byte, error) + func (msg *InboundConnectionsConfig) UnmarshalBinary(b []byte) error + func (x *InboundConnectionsConfig) GetBalanceInboundConnections() BalanceInboundConnections + func (x *InboundConnectionsConfig) GetMaxInboundConnections() uint64 + func (x *InboundConnectionsConfig) ProtoReflect() protoreflect.Message + func (x *InboundConnectionsConfig) Reset() + func (x *InboundConnectionsConfig) String() string + type MeshGatewayMode int32 + const MeshGatewayMode_MESH_GATEWAY_MODE_LOCAL + const MeshGatewayMode_MESH_GATEWAY_MODE_NONE + const MeshGatewayMode_MESH_GATEWAY_MODE_REMOTE + const MeshGatewayMode_MESH_GATEWAY_MODE_UNSPECIFIED + func (MeshGatewayMode) Descriptor() protoreflect.EnumDescriptor + func (MeshGatewayMode) EnumDescriptor() ([]byte, []int) + func (MeshGatewayMode) Type() protoreflect.EnumType + func (x MeshGatewayMode) Enum() *MeshGatewayMode + func (x MeshGatewayMode) Number() protoreflect.EnumNumber + func (x MeshGatewayMode) String() string + type PassiveHealthCheck struct + EnforcingConsecutive_5Xx uint32 + Interval *durationpb.Duration + MaxFailures uint32 + func (*PassiveHealthCheck) Descriptor() ([]byte, []int) + func (*PassiveHealthCheck) ProtoMessage() + func (msg *PassiveHealthCheck) MarshalBinary() ([]byte, error) + func (msg *PassiveHealthCheck) UnmarshalBinary(b []byte) error + func (x *PassiveHealthCheck) GetEnforcingConsecutive_5Xx() uint32 + func (x *PassiveHealthCheck) GetInterval() *durationpb.Duration + func (x *PassiveHealthCheck) GetMaxFailures() uint32 + func (x *PassiveHealthCheck) ProtoReflect() protoreflect.Message + func (x *PassiveHealthCheck) Reset() + func (x *PassiveHealthCheck) String() string + type PreparedQueryUpstream struct + Datacenter string + ListenAddr isPreparedQueryUpstream_ListenAddr + Name string + UpstreamConfig *UpstreamConfig + func (*PreparedQueryUpstream) Descriptor() ([]byte, []int) + func (*PreparedQueryUpstream) ProtoMessage() + func (m *PreparedQueryUpstream) GetListenAddr() isPreparedQueryUpstream_ListenAddr + func (msg *PreparedQueryUpstream) MarshalBinary() ([]byte, error) + func (msg *PreparedQueryUpstream) UnmarshalBinary(b []byte) error + func (x *PreparedQueryUpstream) GetDatacenter() string + func (x *PreparedQueryUpstream) GetName() string + func (x *PreparedQueryUpstream) GetTcp() *TCPAddress + func (x *PreparedQueryUpstream) GetUnix() *UnixSocketAddress + func (x *PreparedQueryUpstream) GetUpstreamConfig() *UpstreamConfig + func (x *PreparedQueryUpstream) ProtoReflect() protoreflect.Message + func (x *PreparedQueryUpstream) Reset() + func (x *PreparedQueryUpstream) String() string + type PreparedQueryUpstream_Tcp struct + Tcp *TCPAddress + type PreparedQueryUpstream_Unix struct + Unix *UnixSocketAddress + type ProxyConfiguration struct + BootstrapConfig *BootstrapConfig + DynamicConfig *DynamicConfig + OpaqueConfig *structpb.Struct + Workloads *v1alpha1.WorkloadSelector + func (*ProxyConfiguration) Descriptor() ([]byte, []int) + func (*ProxyConfiguration) ProtoMessage() + func (msg *ProxyConfiguration) MarshalBinary() ([]byte, error) + func (msg *ProxyConfiguration) UnmarshalBinary(b []byte) error + func (x *ProxyConfiguration) GetBootstrapConfig() *BootstrapConfig + func (x *ProxyConfiguration) GetDynamicConfig() *DynamicConfig + func (x *ProxyConfiguration) GetOpaqueConfig() *structpb.Struct + func (x *ProxyConfiguration) GetWorkloads() *v1alpha1.WorkloadSelector + func (x *ProxyConfiguration) ProtoReflect() protoreflect.Message + func (x *ProxyConfiguration) Reset() + func (x *ProxyConfiguration) String() string + type ProxyMode int32 + const ProxyMode_PROXY_MODE_DEFAULT + const ProxyMode_PROXY_MODE_DIRECT + const ProxyMode_PROXY_MODE_TRANSPARENT + func (ProxyMode) Descriptor() protoreflect.EnumDescriptor + func (ProxyMode) EnumDescriptor() ([]byte, []int) + func (ProxyMode) Type() protoreflect.EnumType + func (x ProxyMode) Enum() *ProxyMode + func (x ProxyMode) Number() protoreflect.EnumNumber + func (x ProxyMode) String() string + type TCPAddress struct + Ip string + Port uint32 + func (*TCPAddress) Descriptor() ([]byte, []int) + func (*TCPAddress) ProtoMessage() + func (msg *TCPAddress) MarshalBinary() ([]byte, error) + func (msg *TCPAddress) UnmarshalBinary(b []byte) error + func (x *TCPAddress) GetIp() string + func (x *TCPAddress) GetPort() uint32 + func (x *TCPAddress) ProtoReflect() protoreflect.Message + func (x *TCPAddress) Reset() + func (x *TCPAddress) String() string + type TransparentProxy struct + DialedDirectly bool + OutboundListenerPort uint32 + func (*TransparentProxy) Descriptor() ([]byte, []int) + func (*TransparentProxy) ProtoMessage() + func (msg *TransparentProxy) MarshalBinary() ([]byte, error) + func (msg *TransparentProxy) UnmarshalBinary(b []byte) error + func (x *TransparentProxy) GetDialedDirectly() bool + func (x *TransparentProxy) GetOutboundListenerPort() uint32 + func (x *TransparentProxy) ProtoReflect() protoreflect.Message + func (x *TransparentProxy) Reset() + func (x *TransparentProxy) String() string + type UnixSocketAddress struct + Mode string + Path string + func (*UnixSocketAddress) Descriptor() ([]byte, []int) + func (*UnixSocketAddress) ProtoMessage() + func (msg *UnixSocketAddress) MarshalBinary() ([]byte, error) + func (msg *UnixSocketAddress) UnmarshalBinary(b []byte) error + func (x *UnixSocketAddress) GetMode() string + func (x *UnixSocketAddress) GetPath() string + func (x *UnixSocketAddress) ProtoReflect() protoreflect.Message + func (x *UnixSocketAddress) Reset() + func (x *UnixSocketAddress) String() string + type Upstream struct + Datacenter string + DestinationPort string + DestinationRef *pbresource.ID + ListenAddr isUpstream_ListenAddr + UpstreamConfig *UpstreamConfig + func (*Upstream) Descriptor() ([]byte, []int) + func (*Upstream) ProtoMessage() + func (m *Upstream) GetListenAddr() isUpstream_ListenAddr + func (msg *Upstream) MarshalBinary() ([]byte, error) + func (msg *Upstream) UnmarshalBinary(b []byte) error + func (x *Upstream) GetDatacenter() string + func (x *Upstream) GetDestinationPort() string + func (x *Upstream) GetDestinationRef() *pbresource.ID + func (x *Upstream) GetTcp() *TCPAddress + func (x *Upstream) GetUnix() *UnixSocketAddress + func (x *Upstream) GetUpstreamConfig() *UpstreamConfig + func (x *Upstream) ProtoReflect() protoreflect.Message + func (x *Upstream) Reset() + func (x *Upstream) String() string + type UpstreamConfig struct + BalanceInboundConnections BalanceInboundConnections + ConnectTimeoutMs uint64 + Limits *UpstreamLimits + MeshGatewayMode MeshGatewayMode + PassiveHealthCheck *PassiveHealthCheck + func (*UpstreamConfig) Descriptor() ([]byte, []int) + func (*UpstreamConfig) ProtoMessage() + func (msg *UpstreamConfig) MarshalBinary() ([]byte, error) + func (msg *UpstreamConfig) UnmarshalBinary(b []byte) error + func (x *UpstreamConfig) GetBalanceInboundConnections() BalanceInboundConnections + func (x *UpstreamConfig) GetConnectTimeoutMs() uint64 + func (x *UpstreamConfig) GetLimits() *UpstreamLimits + func (x *UpstreamConfig) GetMeshGatewayMode() MeshGatewayMode + func (x *UpstreamConfig) GetPassiveHealthCheck() *PassiveHealthCheck + func (x *UpstreamConfig) ProtoReflect() protoreflect.Message + func (x *UpstreamConfig) Reset() + func (x *UpstreamConfig) String() string + type UpstreamLimits struct + MaxConcurrentRequests int32 + MaxConnections int32 + MaxPendingRequests int32 + func (*UpstreamLimits) Descriptor() ([]byte, []int) + func (*UpstreamLimits) ProtoMessage() + func (msg *UpstreamLimits) MarshalBinary() ([]byte, error) + func (msg *UpstreamLimits) UnmarshalBinary(b []byte) error + func (x *UpstreamLimits) GetMaxConcurrentRequests() int32 + func (x *UpstreamLimits) GetMaxConnections() int32 + func (x *UpstreamLimits) GetMaxPendingRequests() int32 + func (x *UpstreamLimits) ProtoReflect() protoreflect.Message + func (x *UpstreamLimits) Reset() + func (x *UpstreamLimits) String() string + type Upstream_Tcp struct + Tcp *TCPAddress + type Upstream_Unix struct + Unix *UnixSocketAddress + type Upstreams struct + PqUpstreams []*PreparedQueryUpstream + UpstreamConfig *UpstreamConfig + Upstreams []*Upstream + Workloads *v1alpha1.WorkloadSelector + func (*Upstreams) Descriptor() ([]byte, []int) + func (*Upstreams) ProtoMessage() + func (msg *Upstreams) MarshalBinary() ([]byte, error) + func (msg *Upstreams) UnmarshalBinary(b []byte) error + func (x *Upstreams) GetPqUpstreams() []*PreparedQueryUpstream + func (x *Upstreams) GetUpstreamConfig() *UpstreamConfig + func (x *Upstreams) GetUpstreams() []*Upstream + func (x *Upstreams) GetWorkloads() *v1alpha1.WorkloadSelector + func (x *Upstreams) ProtoReflect() protoreflect.Message + func (x *Upstreams) Reset() + func (x *Upstreams) String() string
Go to main page