Documentation
¶
Index ¶
- Variables
- type BalanceInboundConnections
- func (BalanceInboundConnections) Descriptor() protoreflect.EnumDescriptor
- func (x BalanceInboundConnections) Enum() *BalanceInboundConnections
- func (BalanceInboundConnections) EnumDescriptor() ([]byte, []int)deprecated
- func (x BalanceInboundConnections) Number() protoreflect.EnumNumber
- func (x BalanceInboundConnections) String() string
- func (BalanceInboundConnections) Type() protoreflect.EnumType
- type BootstrapConfig
- func (*BootstrapConfig) Descriptor() ([]byte, []int)deprecated
- 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 (msg *BootstrapConfig) MarshalBinary() ([]byte, error)
- func (*BootstrapConfig) ProtoMessage()
- func (x *BootstrapConfig) ProtoReflect() protoreflect.Message
- func (x *BootstrapConfig) Reset()
- func (x *BootstrapConfig) String() string
- func (msg *BootstrapConfig) UnmarshalBinary(b []byte) error
- type ConnectionConfig
- func (*ConnectionConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectionConfig) GetConnectTimeoutMs() uint64
- func (x *ConnectionConfig) GetRequestTimeoutMs() uint64
- func (msg *ConnectionConfig) MarshalBinary() ([]byte, error)
- func (*ConnectionConfig) ProtoMessage()
- func (x *ConnectionConfig) ProtoReflect() protoreflect.Message
- func (x *ConnectionConfig) Reset()
- func (x *ConnectionConfig) String() string
- func (msg *ConnectionConfig) UnmarshalBinary(b []byte) error
- type DynamicConfig
- func (*DynamicConfig) Descriptor() ([]byte, []int)deprecated
- 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() stringdeprecated
- func (x *DynamicConfig) GetLocalWorkloadPort() uint32deprecated
- func (x *DynamicConfig) GetLocalWorkloadSocketPath() stringdeprecated
- func (x *DynamicConfig) GetMeshGatewayMode() MeshGatewayMode
- func (x *DynamicConfig) GetMode() ProxyMode
- func (x *DynamicConfig) GetPublicListenerJson() string
- func (x *DynamicConfig) GetTransparentProxy() *TransparentProxy
- func (msg *DynamicConfig) MarshalBinary() ([]byte, error)
- func (*DynamicConfig) ProtoMessage()
- func (x *DynamicConfig) ProtoReflect() protoreflect.Message
- func (x *DynamicConfig) Reset()
- func (x *DynamicConfig) String() string
- func (msg *DynamicConfig) UnmarshalBinary(b []byte) error
- type ExposeConfig
- func (*ExposeConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ExposeConfig) GetExposePaths() []*ExposePath
- func (msg *ExposeConfig) MarshalBinary() ([]byte, error)
- func (*ExposeConfig) ProtoMessage()
- func (x *ExposeConfig) ProtoReflect() protoreflect.Message
- func (x *ExposeConfig) Reset()
- func (x *ExposeConfig) String() string
- func (msg *ExposeConfig) UnmarshalBinary(b []byte) error
- type ExposePath
- func (*ExposePath) Descriptor() ([]byte, []int)deprecated
- func (x *ExposePath) GetListenerPort() uint32
- func (x *ExposePath) GetLocalPathPort() uint32
- func (x *ExposePath) GetPath() string
- func (x *ExposePath) GetProtocol() v1alpha1.Protocol
- func (msg *ExposePath) MarshalBinary() ([]byte, error)
- func (*ExposePath) ProtoMessage()
- func (x *ExposePath) ProtoReflect() protoreflect.Message
- func (x *ExposePath) Reset()
- func (x *ExposePath) String() string
- func (msg *ExposePath) UnmarshalBinary(b []byte) error
- type InboundConnectionsConfig
- func (*InboundConnectionsConfig) Descriptor() ([]byte, []int)deprecated
- func (x *InboundConnectionsConfig) GetBalanceInboundConnections() BalanceInboundConnections
- func (x *InboundConnectionsConfig) GetMaxInboundConnections() uint64
- func (msg *InboundConnectionsConfig) MarshalBinary() ([]byte, error)
- func (*InboundConnectionsConfig) ProtoMessage()
- func (x *InboundConnectionsConfig) ProtoReflect() protoreflect.Message
- func (x *InboundConnectionsConfig) Reset()
- func (x *InboundConnectionsConfig) String() string
- func (msg *InboundConnectionsConfig) UnmarshalBinary(b []byte) error
- type MeshGatewayMode
- func (MeshGatewayMode) Descriptor() protoreflect.EnumDescriptor
- func (x MeshGatewayMode) Enum() *MeshGatewayMode
- func (MeshGatewayMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x MeshGatewayMode) Number() protoreflect.EnumNumber
- func (x MeshGatewayMode) String() string
- func (MeshGatewayMode) Type() protoreflect.EnumType
- type PassiveHealthCheck
- func (*PassiveHealthCheck) Descriptor() ([]byte, []int)deprecated
- func (x *PassiveHealthCheck) GetEnforcingConsecutive_5Xx() uint32
- func (x *PassiveHealthCheck) GetInterval() *durationpb.Duration
- func (x *PassiveHealthCheck) GetMaxFailures() uint32
- func (msg *PassiveHealthCheck) MarshalBinary() ([]byte, error)
- func (*PassiveHealthCheck) ProtoMessage()
- func (x *PassiveHealthCheck) ProtoReflect() protoreflect.Message
- func (x *PassiveHealthCheck) Reset()
- func (x *PassiveHealthCheck) String() string
- func (msg *PassiveHealthCheck) UnmarshalBinary(b []byte) error
- type PreparedQueryUpstream
- func (*PreparedQueryUpstream) Descriptor() ([]byte, []int)deprecated
- func (x *PreparedQueryUpstream) GetDatacenter() string
- func (m *PreparedQueryUpstream) GetListenAddr() isPreparedQueryUpstream_ListenAddr
- func (x *PreparedQueryUpstream) GetName() string
- func (x *PreparedQueryUpstream) GetTcp() *TCPAddress
- func (x *PreparedQueryUpstream) GetUnix() *UnixSocketAddress
- func (x *PreparedQueryUpstream) GetUpstreamConfig() *UpstreamConfig
- func (msg *PreparedQueryUpstream) MarshalBinary() ([]byte, error)
- func (*PreparedQueryUpstream) ProtoMessage()
- func (x *PreparedQueryUpstream) ProtoReflect() protoreflect.Message
- func (x *PreparedQueryUpstream) Reset()
- func (x *PreparedQueryUpstream) String() string
- func (msg *PreparedQueryUpstream) UnmarshalBinary(b []byte) error
- type PreparedQueryUpstream_Tcp
- type PreparedQueryUpstream_Unix
- type ProxyConfiguration
- func (*ProxyConfiguration) Descriptor() ([]byte, []int)deprecated
- func (x *ProxyConfiguration) GetBootstrapConfig() *BootstrapConfig
- func (x *ProxyConfiguration) GetDynamicConfig() *DynamicConfig
- func (x *ProxyConfiguration) GetOpaqueConfig() *structpb.Structdeprecated
- func (x *ProxyConfiguration) GetWorkloads() *v1alpha1.WorkloadSelector
- func (msg *ProxyConfiguration) MarshalBinary() ([]byte, error)
- func (*ProxyConfiguration) ProtoMessage()
- func (x *ProxyConfiguration) ProtoReflect() protoreflect.Message
- func (x *ProxyConfiguration) Reset()
- func (x *ProxyConfiguration) String() string
- func (msg *ProxyConfiguration) UnmarshalBinary(b []byte) error
- type ProxyMode
- type TCPAddress
- func (*TCPAddress) Descriptor() ([]byte, []int)deprecated
- func (x *TCPAddress) GetIp() string
- func (x *TCPAddress) GetPort() uint32
- func (msg *TCPAddress) MarshalBinary() ([]byte, error)
- func (*TCPAddress) ProtoMessage()
- func (x *TCPAddress) ProtoReflect() protoreflect.Message
- func (x *TCPAddress) Reset()
- func (x *TCPAddress) String() string
- func (msg *TCPAddress) UnmarshalBinary(b []byte) error
- type TransparentProxy
- func (*TransparentProxy) Descriptor() ([]byte, []int)deprecated
- func (x *TransparentProxy) GetDialedDirectly() bool
- func (x *TransparentProxy) GetOutboundListenerPort() uint32
- func (msg *TransparentProxy) MarshalBinary() ([]byte, error)
- func (*TransparentProxy) ProtoMessage()
- func (x *TransparentProxy) ProtoReflect() protoreflect.Message
- func (x *TransparentProxy) Reset()
- func (x *TransparentProxy) String() string
- func (msg *TransparentProxy) UnmarshalBinary(b []byte) error
- type UnixSocketAddress
- func (*UnixSocketAddress) Descriptor() ([]byte, []int)deprecated
- func (x *UnixSocketAddress) GetMode() string
- func (x *UnixSocketAddress) GetPath() string
- func (msg *UnixSocketAddress) MarshalBinary() ([]byte, error)
- func (*UnixSocketAddress) ProtoMessage()
- func (x *UnixSocketAddress) ProtoReflect() protoreflect.Message
- func (x *UnixSocketAddress) Reset()
- func (x *UnixSocketAddress) String() string
- func (msg *UnixSocketAddress) UnmarshalBinary(b []byte) error
- type Upstream
- func (*Upstream) Descriptor() ([]byte, []int)deprecated
- func (x *Upstream) GetDatacenter() string
- func (x *Upstream) GetDestinationPort() string
- func (x *Upstream) GetDestinationRef() *pbresource.ID
- func (m *Upstream) GetListenAddr() isUpstream_ListenAddr
- func (x *Upstream) GetTcp() *TCPAddress
- func (x *Upstream) GetUnix() *UnixSocketAddress
- func (x *Upstream) GetUpstreamConfig() *UpstreamConfig
- func (msg *Upstream) MarshalBinary() ([]byte, error)
- func (*Upstream) ProtoMessage()
- func (x *Upstream) ProtoReflect() protoreflect.Message
- func (x *Upstream) Reset()
- func (x *Upstream) String() string
- func (msg *Upstream) UnmarshalBinary(b []byte) error
- type UpstreamConfig
- func (*UpstreamConfig) Descriptor() ([]byte, []int)deprecated
- 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 (msg *UpstreamConfig) MarshalBinary() ([]byte, error)
- func (*UpstreamConfig) ProtoMessage()
- func (x *UpstreamConfig) ProtoReflect() protoreflect.Message
- func (x *UpstreamConfig) Reset()
- func (x *UpstreamConfig) String() string
- func (msg *UpstreamConfig) UnmarshalBinary(b []byte) error
- type UpstreamLimits
- func (*UpstreamLimits) Descriptor() ([]byte, []int)deprecated
- func (x *UpstreamLimits) GetMaxConcurrentRequests() int32
- func (x *UpstreamLimits) GetMaxConnections() int32
- func (x *UpstreamLimits) GetMaxPendingRequests() int32
- func (msg *UpstreamLimits) MarshalBinary() ([]byte, error)
- func (*UpstreamLimits) ProtoMessage()
- func (x *UpstreamLimits) ProtoReflect() protoreflect.Message
- func (x *UpstreamLimits) Reset()
- func (x *UpstreamLimits) String() string
- func (msg *UpstreamLimits) UnmarshalBinary(b []byte) error
- type Upstream_Tcp
- type Upstream_Unix
- type Upstreams
- func (*Upstreams) Descriptor() ([]byte, []int)deprecated
- func (x *Upstreams) GetPqUpstreams() []*PreparedQueryUpstream
- func (x *Upstreams) GetUpstreamConfig() *UpstreamConfig
- func (x *Upstreams) GetUpstreams() []*Upstream
- func (x *Upstreams) GetWorkloads() *v1alpha1.WorkloadSelector
- func (msg *Upstreams) MarshalBinary() ([]byte, error)
- func (*Upstreams) ProtoMessage()
- func (x *Upstreams) ProtoReflect() protoreflect.Message
- func (x *Upstreams) Reset()
- func (x *Upstreams) String() string
- func (msg *Upstreams) UnmarshalBinary(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( BalanceInboundConnections_name = map[int32]string{ 0: "BALANCE_INBOUND_CONNECTIONS_DEFAULT", 1: "BALANCE_INBOUND_CONNECTIONS_EXACT", } BalanceInboundConnections_value = map[string]int32{ "BALANCE_INBOUND_CONNECTIONS_DEFAULT": 0, "BALANCE_INBOUND_CONNECTIONS_EXACT": 1, } )
Enum value maps for BalanceInboundConnections.
var ( ProxyMode_name = map[int32]string{ 0: "PROXY_MODE_DEFAULT", 1: "PROXY_MODE_TRANSPARENT", 2: "PROXY_MODE_DIRECT", } ProxyMode_value = map[string]int32{ "PROXY_MODE_DEFAULT": 0, "PROXY_MODE_TRANSPARENT": 1, "PROXY_MODE_DIRECT": 2, } )
Enum value maps for ProxyMode.
var ( MeshGatewayMode_name = map[int32]string{ 0: "MESH_GATEWAY_MODE_UNSPECIFIED", 1: "MESH_GATEWAY_MODE_NONE", 2: "MESH_GATEWAY_MODE_LOCAL", 3: "MESH_GATEWAY_MODE_REMOTE", } MeshGatewayMode_value = map[string]int32{ "MESH_GATEWAY_MODE_UNSPECIFIED": 0, "MESH_GATEWAY_MODE_NONE": 1, "MESH_GATEWAY_MODE_LOCAL": 2, "MESH_GATEWAY_MODE_REMOTE": 3, } )
Enum value maps for MeshGatewayMode.
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
Functions ¶
This section is empty.
Types ¶
type BalanceInboundConnections ¶
type BalanceInboundConnections int32
const ( // buf:lint:ignore ENUM_ZERO_VALUE_SUFFIX BalanceInboundConnections_BALANCE_INBOUND_CONNECTIONS_DEFAULT BalanceInboundConnections = 0 BalanceInboundConnections_BALANCE_INBOUND_CONNECTIONS_EXACT BalanceInboundConnections = 1 )
func (BalanceInboundConnections) Descriptor ¶
func (BalanceInboundConnections) Descriptor() protoreflect.EnumDescriptor
func (BalanceInboundConnections) Enum ¶
func (x BalanceInboundConnections) Enum() *BalanceInboundConnections
func (BalanceInboundConnections) EnumDescriptor
deprecated
func (BalanceInboundConnections) EnumDescriptor() ([]byte, []int)
Deprecated: Use BalanceInboundConnections.Descriptor instead.
func (BalanceInboundConnections) Number ¶
func (x BalanceInboundConnections) Number() protoreflect.EnumNumber
func (BalanceInboundConnections) String ¶
func (x BalanceInboundConnections) String() string
func (BalanceInboundConnections) Type ¶
func (BalanceInboundConnections) Type() protoreflect.EnumType
type BootstrapConfig ¶
type BootstrapConfig struct { StatsdUrl string `protobuf:"bytes,1,opt,name=statsd_url,json=statsdUrl,proto3" json:"statsd_url,omitempty"` DogstatsdUrl string `protobuf:"bytes,2,opt,name=dogstatsd_url,json=dogstatsdUrl,proto3" json:"dogstatsd_url,omitempty"` StatsTags []string `protobuf:"bytes,3,rep,name=stats_tags,json=statsTags,proto3" json:"stats_tags,omitempty"` PrometheusBindAddr string `protobuf:"bytes,4,opt,name=prometheus_bind_addr,json=prometheusBindAddr,proto3" json:"prometheus_bind_addr,omitempty"` StatsBindAddr string `protobuf:"bytes,5,opt,name=stats_bind_addr,json=statsBindAddr,proto3" json:"stats_bind_addr,omitempty"` ReadyBindAddr string `protobuf:"bytes,6,opt,name=ready_bind_addr,json=readyBindAddr,proto3" json:"ready_bind_addr,omitempty"` OverrideJsonTpl string `protobuf:"bytes,7,opt,name=override_json_tpl,json=overrideJsonTpl,proto3" json:"override_json_tpl,omitempty"` StaticClustersJson string `protobuf:"bytes,8,opt,name=static_clusters_json,json=staticClustersJson,proto3" json:"static_clusters_json,omitempty"` StaticListenersJson string `protobuf:"bytes,9,opt,name=static_listeners_json,json=staticListenersJson,proto3" json:"static_listeners_json,omitempty"` StatsSinksJson string `protobuf:"bytes,10,opt,name=stats_sinks_json,json=statsSinksJson,proto3" json:"stats_sinks_json,omitempty"` StatsConfigJson string `protobuf:"bytes,11,opt,name=stats_config_json,json=statsConfigJson,proto3" json:"stats_config_json,omitempty"` StatsFlushInterval string `protobuf:"bytes,12,opt,name=stats_flush_interval,json=statsFlushInterval,proto3" json:"stats_flush_interval,omitempty"` TracingConfigJson string `protobuf:"bytes,13,opt,name=tracing_config_json,json=tracingConfigJson,proto3" json:"tracing_config_json,omitempty"` // contains filtered or unexported fields }
BootstrapConfig is equivalent to configuration defined in our docs.
func (*BootstrapConfig) Descriptor
deprecated
func (*BootstrapConfig) Descriptor() ([]byte, []int)
Deprecated: Use BootstrapConfig.ProtoReflect.Descriptor instead.
func (*BootstrapConfig) GetDogstatsdUrl ¶
func (x *BootstrapConfig) GetDogstatsdUrl() string
func (*BootstrapConfig) GetOverrideJsonTpl ¶
func (x *BootstrapConfig) GetOverrideJsonTpl() string
func (*BootstrapConfig) GetPrometheusBindAddr ¶
func (x *BootstrapConfig) GetPrometheusBindAddr() string
func (*BootstrapConfig) GetReadyBindAddr ¶
func (x *BootstrapConfig) GetReadyBindAddr() string
func (*BootstrapConfig) GetStaticClustersJson ¶
func (x *BootstrapConfig) GetStaticClustersJson() string
func (*BootstrapConfig) GetStaticListenersJson ¶
func (x *BootstrapConfig) GetStaticListenersJson() string
func (*BootstrapConfig) GetStatsBindAddr ¶
func (x *BootstrapConfig) GetStatsBindAddr() string
func (*BootstrapConfig) GetStatsConfigJson ¶
func (x *BootstrapConfig) GetStatsConfigJson() string
func (*BootstrapConfig) GetStatsFlushInterval ¶
func (x *BootstrapConfig) GetStatsFlushInterval() string
func (*BootstrapConfig) GetStatsSinksJson ¶
func (x *BootstrapConfig) GetStatsSinksJson() string
func (*BootstrapConfig) GetStatsTags ¶
func (x *BootstrapConfig) GetStatsTags() []string
func (*BootstrapConfig) GetStatsdUrl ¶
func (x *BootstrapConfig) GetStatsdUrl() string
func (*BootstrapConfig) GetTracingConfigJson ¶
func (x *BootstrapConfig) GetTracingConfigJson() string
func (*BootstrapConfig) MarshalBinary ¶
func (msg *BootstrapConfig) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*BootstrapConfig) ProtoMessage ¶
func (*BootstrapConfig) ProtoMessage()
func (*BootstrapConfig) ProtoReflect ¶
func (x *BootstrapConfig) ProtoReflect() protoreflect.Message
func (*BootstrapConfig) Reset ¶
func (x *BootstrapConfig) Reset()
func (*BootstrapConfig) String ¶
func (x *BootstrapConfig) String() string
func (*BootstrapConfig) UnmarshalBinary ¶
func (msg *BootstrapConfig) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type ConnectionConfig ¶
type ConnectionConfig struct { ConnectTimeoutMs uint64 `protobuf:"varint,2,opt,name=connect_timeout_ms,json=connectTimeoutMs,proto3" json:"connect_timeout_ms,omitempty"` RequestTimeoutMs uint64 `protobuf:"varint,3,opt,name=request_timeout_ms,json=requestTimeoutMs,proto3" json:"request_timeout_ms,omitempty"` // contains filtered or unexported fields }
func (*ConnectionConfig) Descriptor
deprecated
func (*ConnectionConfig) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionConfig.ProtoReflect.Descriptor instead.
func (*ConnectionConfig) GetConnectTimeoutMs ¶
func (x *ConnectionConfig) GetConnectTimeoutMs() uint64
func (*ConnectionConfig) GetRequestTimeoutMs ¶
func (x *ConnectionConfig) GetRequestTimeoutMs() uint64
func (*ConnectionConfig) MarshalBinary ¶
func (msg *ConnectionConfig) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*ConnectionConfig) ProtoMessage ¶
func (*ConnectionConfig) ProtoMessage()
func (*ConnectionConfig) ProtoReflect ¶
func (x *ConnectionConfig) ProtoReflect() protoreflect.Message
func (*ConnectionConfig) Reset ¶
func (x *ConnectionConfig) Reset()
func (*ConnectionConfig) String ¶
func (x *ConnectionConfig) String() string
func (*ConnectionConfig) UnmarshalBinary ¶
func (msg *ConnectionConfig) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type DynamicConfig ¶
type DynamicConfig struct { // mode indicates the proxy's mode. This will default to 'transparent'. Mode ProxyMode `protobuf:"varint,1,opt,name=mode,proto3,enum=hashicorp.consul.mesh.v1alpha1.ProxyMode" json:"mode,omitempty"` TransparentProxy *TransparentProxy `protobuf:"bytes,2,opt,name=transparent_proxy,json=transparentProxy,proto3" json:"transparent_proxy,omitempty"` // local_connection is the configuration that should be used // to connect to the local application provided per-port. // The map keys should correspond to port names on the workload. LocalConnection map[string]*ConnectionConfig `` /* 194-byte string literal not displayed */ // inbound_connections configures inbound connections to the proxy. InboundConnections *InboundConnectionsConfig `protobuf:"bytes,4,opt,name=inbound_connections,json=inboundConnections,proto3" json:"inbound_connections,omitempty"` MeshGatewayMode MeshGatewayMode `` /* 161-byte string literal not displayed */ ExposeConfig *ExposeConfig `protobuf:"bytes,6,opt,name=expose_config,json=exposeConfig,proto3" json:"expose_config,omitempty"` PublicListenerJson string `protobuf:"bytes,7,opt,name=public_listener_json,json=publicListenerJson,proto3" json:"public_listener_json,omitempty"` ListenerTracingJson string `protobuf:"bytes,8,opt,name=listener_tracing_json,json=listenerTracingJson,proto3" json:"listener_tracing_json,omitempty"` LocalClusterJson string `protobuf:"bytes,9,opt,name=local_cluster_json,json=localClusterJson,proto3" json:"local_cluster_json,omitempty"` // deprecated: // local_workload_address, local_workload_port, and local_workload_socket_path // are deprecated and are only needed for migration of existing resources. // // Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto. LocalWorkloadAddress string `protobuf:"bytes,10,opt,name=local_workload_address,json=localWorkloadAddress,proto3" json:"local_workload_address,omitempty"` // Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto. LocalWorkloadPort uint32 `protobuf:"varint,11,opt,name=local_workload_port,json=localWorkloadPort,proto3" json:"local_workload_port,omitempty"` // Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto. LocalWorkloadSocketPath string `` /* 135-byte string literal not displayed */ // contains filtered or unexported fields }
func (*DynamicConfig) Descriptor
deprecated
func (*DynamicConfig) Descriptor() ([]byte, []int)
Deprecated: Use DynamicConfig.ProtoReflect.Descriptor instead.
func (*DynamicConfig) GetExposeConfig ¶
func (x *DynamicConfig) GetExposeConfig() *ExposeConfig
func (*DynamicConfig) GetInboundConnections ¶
func (x *DynamicConfig) GetInboundConnections() *InboundConnectionsConfig
func (*DynamicConfig) GetListenerTracingJson ¶
func (x *DynamicConfig) GetListenerTracingJson() string
func (*DynamicConfig) GetLocalClusterJson ¶
func (x *DynamicConfig) GetLocalClusterJson() string
func (*DynamicConfig) GetLocalConnection ¶
func (x *DynamicConfig) GetLocalConnection() map[string]*ConnectionConfig
func (*DynamicConfig) GetLocalWorkloadAddress
deprecated
func (x *DynamicConfig) GetLocalWorkloadAddress() string
Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto.
func (*DynamicConfig) GetLocalWorkloadPort
deprecated
func (x *DynamicConfig) GetLocalWorkloadPort() uint32
Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto.
func (*DynamicConfig) GetLocalWorkloadSocketPath
deprecated
func (x *DynamicConfig) GetLocalWorkloadSocketPath() string
Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto.
func (*DynamicConfig) GetMeshGatewayMode ¶
func (x *DynamicConfig) GetMeshGatewayMode() MeshGatewayMode
func (*DynamicConfig) GetMode ¶
func (x *DynamicConfig) GetMode() ProxyMode
func (*DynamicConfig) GetPublicListenerJson ¶
func (x *DynamicConfig) GetPublicListenerJson() string
func (*DynamicConfig) GetTransparentProxy ¶
func (x *DynamicConfig) GetTransparentProxy() *TransparentProxy
func (*DynamicConfig) MarshalBinary ¶
func (msg *DynamicConfig) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*DynamicConfig) ProtoMessage ¶
func (*DynamicConfig) ProtoMessage()
func (*DynamicConfig) ProtoReflect ¶
func (x *DynamicConfig) ProtoReflect() protoreflect.Message
func (*DynamicConfig) Reset ¶
func (x *DynamicConfig) Reset()
func (*DynamicConfig) String ¶
func (x *DynamicConfig) String() string
func (*DynamicConfig) UnmarshalBinary ¶
func (msg *DynamicConfig) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type ExposeConfig ¶
type ExposeConfig struct { ExposePaths []*ExposePath `protobuf:"bytes,1,rep,name=expose_paths,json=exposePaths,proto3" json:"expose_paths,omitempty"` // contains filtered or unexported fields }
func (*ExposeConfig) Descriptor
deprecated
func (*ExposeConfig) Descriptor() ([]byte, []int)
Deprecated: Use ExposeConfig.ProtoReflect.Descriptor instead.
func (*ExposeConfig) GetExposePaths ¶
func (x *ExposeConfig) GetExposePaths() []*ExposePath
func (*ExposeConfig) MarshalBinary ¶
func (msg *ExposeConfig) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*ExposeConfig) ProtoMessage ¶
func (*ExposeConfig) ProtoMessage()
func (*ExposeConfig) ProtoReflect ¶
func (x *ExposeConfig) ProtoReflect() protoreflect.Message
func (*ExposeConfig) Reset ¶
func (x *ExposeConfig) Reset()
func (*ExposeConfig) String ¶
func (x *ExposeConfig) String() string
func (*ExposeConfig) UnmarshalBinary ¶
func (msg *ExposeConfig) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type ExposePath ¶
type ExposePath struct { ListenerPort uint32 `protobuf:"varint,1,opt,name=listener_port,json=listenerPort,proto3" json:"listener_port,omitempty"` Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` LocalPathPort uint32 `protobuf:"varint,3,opt,name=local_path_port,json=localPathPort,proto3" json:"local_path_port,omitempty"` Protocol v1alpha1.Protocol `protobuf:"varint,4,opt,name=protocol,proto3,enum=hashicorp.consul.catalog.v1alpha1.Protocol" json:"protocol,omitempty"` // contains filtered or unexported fields }
func (*ExposePath) Descriptor
deprecated
func (*ExposePath) Descriptor() ([]byte, []int)
Deprecated: Use ExposePath.ProtoReflect.Descriptor instead.
func (*ExposePath) GetListenerPort ¶
func (x *ExposePath) GetListenerPort() uint32
func (*ExposePath) GetLocalPathPort ¶
func (x *ExposePath) GetLocalPathPort() uint32
func (*ExposePath) GetPath ¶
func (x *ExposePath) GetPath() string
func (*ExposePath) GetProtocol ¶
func (x *ExposePath) GetProtocol() v1alpha1.Protocol
func (*ExposePath) MarshalBinary ¶
func (msg *ExposePath) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*ExposePath) ProtoMessage ¶
func (*ExposePath) ProtoMessage()
func (*ExposePath) ProtoReflect ¶
func (x *ExposePath) ProtoReflect() protoreflect.Message
func (*ExposePath) Reset ¶
func (x *ExposePath) Reset()
func (*ExposePath) String ¶
func (x *ExposePath) String() string
func (*ExposePath) UnmarshalBinary ¶
func (msg *ExposePath) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type InboundConnectionsConfig ¶
type InboundConnectionsConfig struct { MaxInboundConnections uint64 `` /* 128-byte string literal not displayed */ BalanceInboundConnections BalanceInboundConnections `` /* 202-byte string literal not displayed */ // contains filtered or unexported fields }
func (*InboundConnectionsConfig) Descriptor
deprecated
func (*InboundConnectionsConfig) Descriptor() ([]byte, []int)
Deprecated: Use InboundConnectionsConfig.ProtoReflect.Descriptor instead.
func (*InboundConnectionsConfig) GetBalanceInboundConnections ¶
func (x *InboundConnectionsConfig) GetBalanceInboundConnections() BalanceInboundConnections
func (*InboundConnectionsConfig) GetMaxInboundConnections ¶
func (x *InboundConnectionsConfig) GetMaxInboundConnections() uint64
func (*InboundConnectionsConfig) MarshalBinary ¶
func (msg *InboundConnectionsConfig) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*InboundConnectionsConfig) ProtoMessage ¶
func (*InboundConnectionsConfig) ProtoMessage()
func (*InboundConnectionsConfig) ProtoReflect ¶
func (x *InboundConnectionsConfig) ProtoReflect() protoreflect.Message
func (*InboundConnectionsConfig) Reset ¶
func (x *InboundConnectionsConfig) Reset()
func (*InboundConnectionsConfig) String ¶
func (x *InboundConnectionsConfig) String() string
func (*InboundConnectionsConfig) UnmarshalBinary ¶
func (msg *InboundConnectionsConfig) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type MeshGatewayMode ¶
type MeshGatewayMode int32
const ( // MESH_GATEWAY_MODE_UNSPECIFIED represents no specific mode and should be // used to indicate that a the decision on the mode will be made by other // configuration or default settings. MeshGatewayMode_MESH_GATEWAY_MODE_UNSPECIFIED MeshGatewayMode = 0 // MESH_GATEWAY_MODE_NONE is the mode to use when traffic should not be // routed through any gateway but instead be routed directly to the // destination. MeshGatewayMode_MESH_GATEWAY_MODE_NONE MeshGatewayMode = 1 // MESH_GATEWAY_MODE_LOCAL is the mode to use when traffic should be routed // to the local gateway. The local gateway will then ensure that the // connection is proxied correctly to its final destination. This mode will // most often be needed for workloads that are prevented from making outbound // requests outside of their local network/environment. In this case a // gateway will sit at the edge of sit at the edge of the network and will // proxy outbound connections potentially to other gateways in remote // environments. MeshGatewayMode_MESH_GATEWAY_MODE_LOCAL MeshGatewayMode = 2 // MESH_GATEWAY_MODE_REMOTE is the mode to use when traffic should be routed // to a remote mesh gateway. This mode will most often be used when workloads // can make outbound requests destined for a remote network/environment but // where the remote network/environment will not allow direct addressing. The // mesh gateway in the remote environment will sit at the edge and proxy // requests into that environment. MeshGatewayMode_MESH_GATEWAY_MODE_REMOTE MeshGatewayMode = 3 )
func (MeshGatewayMode) Descriptor ¶
func (MeshGatewayMode) Descriptor() protoreflect.EnumDescriptor
func (MeshGatewayMode) Enum ¶
func (x MeshGatewayMode) Enum() *MeshGatewayMode
func (MeshGatewayMode) EnumDescriptor
deprecated
func (MeshGatewayMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use MeshGatewayMode.Descriptor instead.
func (MeshGatewayMode) Number ¶
func (x MeshGatewayMode) Number() protoreflect.EnumNumber
func (MeshGatewayMode) String ¶
func (x MeshGatewayMode) String() string
func (MeshGatewayMode) Type ¶
func (MeshGatewayMode) Type() protoreflect.EnumType
type PassiveHealthCheck ¶
type PassiveHealthCheck struct { // Interval between health check analysis sweeps. Each sweep may remove // hosts or return hosts to the pool. Interval *durationpb.Duration `protobuf:"bytes,1,opt,name=interval,proto3" json:"interval,omitempty"` // MaxFailures is the count of consecutive failures that results in a host // being removed from the pool. MaxFailures uint32 `protobuf:"varint,2,opt,name=max_failures,json=maxFailures,proto3" json:"max_failures,omitempty"` // EnforcingConsecutive5xx is the % chance that a host will be actually ejected // when an outlier status is detected through consecutive 5xx. // This setting can be used to disable ejection or to ramp it up slowly. Defaults to 100. EnforcingConsecutive_5Xx uint32 `` /* 133-byte string literal not displayed */ // contains filtered or unexported fields }
func (*PassiveHealthCheck) Descriptor
deprecated
func (*PassiveHealthCheck) Descriptor() ([]byte, []int)
Deprecated: Use PassiveHealthCheck.ProtoReflect.Descriptor instead.
func (*PassiveHealthCheck) GetEnforcingConsecutive_5Xx ¶
func (x *PassiveHealthCheck) GetEnforcingConsecutive_5Xx() uint32
func (*PassiveHealthCheck) GetInterval ¶
func (x *PassiveHealthCheck) GetInterval() *durationpb.Duration
func (*PassiveHealthCheck) GetMaxFailures ¶
func (x *PassiveHealthCheck) GetMaxFailures() uint32
func (*PassiveHealthCheck) MarshalBinary ¶
func (msg *PassiveHealthCheck) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*PassiveHealthCheck) ProtoMessage ¶
func (*PassiveHealthCheck) ProtoMessage()
func (*PassiveHealthCheck) ProtoReflect ¶
func (x *PassiveHealthCheck) ProtoReflect() protoreflect.Message
func (*PassiveHealthCheck) Reset ¶
func (x *PassiveHealthCheck) Reset()
func (*PassiveHealthCheck) String ¶
func (x *PassiveHealthCheck) String() string
func (*PassiveHealthCheck) UnmarshalBinary ¶
func (msg *PassiveHealthCheck) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type PreparedQueryUpstream ¶
type PreparedQueryUpstream struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Datacenter string `protobuf:"bytes,2,opt,name=datacenter,proto3" json:"datacenter,omitempty"` // Types that are assignable to ListenAddr: // // *PreparedQueryUpstream_Tcp // *PreparedQueryUpstream_Unix ListenAddr isPreparedQueryUpstream_ListenAddr `protobuf_oneof:"listen_addr"` UpstreamConfig *UpstreamConfig `protobuf:"bytes,6,opt,name=upstream_config,json=upstreamConfig,proto3" json:"upstream_config,omitempty"` // contains filtered or unexported fields }
func (*PreparedQueryUpstream) Descriptor
deprecated
func (*PreparedQueryUpstream) Descriptor() ([]byte, []int)
Deprecated: Use PreparedQueryUpstream.ProtoReflect.Descriptor instead.
func (*PreparedQueryUpstream) GetDatacenter ¶
func (x *PreparedQueryUpstream) GetDatacenter() string
func (*PreparedQueryUpstream) GetListenAddr ¶
func (m *PreparedQueryUpstream) GetListenAddr() isPreparedQueryUpstream_ListenAddr
func (*PreparedQueryUpstream) GetName ¶
func (x *PreparedQueryUpstream) GetName() string
func (*PreparedQueryUpstream) GetTcp ¶
func (x *PreparedQueryUpstream) GetTcp() *TCPAddress
func (*PreparedQueryUpstream) GetUnix ¶
func (x *PreparedQueryUpstream) GetUnix() *UnixSocketAddress
func (*PreparedQueryUpstream) GetUpstreamConfig ¶
func (x *PreparedQueryUpstream) GetUpstreamConfig() *UpstreamConfig
func (*PreparedQueryUpstream) MarshalBinary ¶
func (msg *PreparedQueryUpstream) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*PreparedQueryUpstream) ProtoMessage ¶
func (*PreparedQueryUpstream) ProtoMessage()
func (*PreparedQueryUpstream) ProtoReflect ¶
func (x *PreparedQueryUpstream) ProtoReflect() protoreflect.Message
func (*PreparedQueryUpstream) Reset ¶
func (x *PreparedQueryUpstream) Reset()
func (*PreparedQueryUpstream) String ¶
func (x *PreparedQueryUpstream) String() string
func (*PreparedQueryUpstream) UnmarshalBinary ¶
func (msg *PreparedQueryUpstream) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type PreparedQueryUpstream_Tcp ¶
type PreparedQueryUpstream_Tcp struct {
Tcp *TCPAddress `protobuf:"bytes,4,opt,name=tcp,proto3,oneof"`
}
type PreparedQueryUpstream_Unix ¶
type PreparedQueryUpstream_Unix struct {
Unix *UnixSocketAddress `protobuf:"bytes,5,opt,name=unix,proto3,oneof"`
}
type ProxyConfiguration ¶
type ProxyConfiguration struct { // Selection of workloads this proxy configuration should apply to. // These can be prefixes or specific workload names. Workloads *v1alpha1.WorkloadSelector `protobuf:"bytes,1,opt,name=workloads,proto3" json:"workloads,omitempty"` // dynamic_config is the configuration that could be changed // dynamically (i.e. without needing restart). DynamicConfig *DynamicConfig `protobuf:"bytes,2,opt,name=dynamic_config,json=dynamicConfig,proto3" json:"dynamic_config,omitempty"` // bootstrap_config is the configuration that requires proxies // to be restarted to be applied. BootstrapConfig *BootstrapConfig `protobuf:"bytes,3,opt,name=bootstrap_config,json=bootstrapConfig,proto3" json:"bootstrap_config,omitempty"` // deprecated: prevent usage when using v2 APIs directly. // needed for backwards compatibility // // Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto. OpaqueConfig *structpb.Struct `protobuf:"bytes,4,opt,name=opaque_config,json=opaqueConfig,proto3" json:"opaque_config,omitempty"` // contains filtered or unexported fields }
func (*ProxyConfiguration) Descriptor
deprecated
func (*ProxyConfiguration) Descriptor() ([]byte, []int)
Deprecated: Use ProxyConfiguration.ProtoReflect.Descriptor instead.
func (*ProxyConfiguration) GetBootstrapConfig ¶
func (x *ProxyConfiguration) GetBootstrapConfig() *BootstrapConfig
func (*ProxyConfiguration) GetDynamicConfig ¶
func (x *ProxyConfiguration) GetDynamicConfig() *DynamicConfig
func (*ProxyConfiguration) GetOpaqueConfig
deprecated
func (x *ProxyConfiguration) GetOpaqueConfig() *structpb.Struct
Deprecated: Marked as deprecated in pbmesh/v1alpha1/proxy.proto.
func (*ProxyConfiguration) GetWorkloads ¶
func (x *ProxyConfiguration) GetWorkloads() *v1alpha1.WorkloadSelector
func (*ProxyConfiguration) MarshalBinary ¶
func (msg *ProxyConfiguration) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*ProxyConfiguration) ProtoMessage ¶
func (*ProxyConfiguration) ProtoMessage()
func (*ProxyConfiguration) ProtoReflect ¶
func (x *ProxyConfiguration) ProtoReflect() protoreflect.Message
func (*ProxyConfiguration) Reset ¶
func (x *ProxyConfiguration) Reset()
func (*ProxyConfiguration) String ¶
func (x *ProxyConfiguration) String() string
func (*ProxyConfiguration) UnmarshalBinary ¶
func (msg *ProxyConfiguration) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type ProxyMode ¶
type ProxyMode int32
const ( // ProxyModeDefault represents no specific mode and should // be used to indicate that a different layer of the configuration // chain should take precedence // buf:lint:ignore ENUM_ZERO_VALUE_SUFFIX ProxyMode_PROXY_MODE_DEFAULT ProxyMode = 0 // ProxyModeTransparent represents that inbound and outbound application // traffic is being captured and redirected through the proxy. ProxyMode_PROXY_MODE_TRANSPARENT ProxyMode = 1 // ProxyModeDirect represents that the proxy's listeners must be dialed directly // by the local application and other proxies. ProxyMode_PROXY_MODE_DIRECT ProxyMode = 2 )
func (ProxyMode) Descriptor ¶
func (ProxyMode) Descriptor() protoreflect.EnumDescriptor
func (ProxyMode) EnumDescriptor
deprecated
func (ProxyMode) Number ¶
func (x ProxyMode) Number() protoreflect.EnumNumber
func (ProxyMode) Type ¶
func (ProxyMode) Type() protoreflect.EnumType
type TCPAddress ¶
type TCPAddress struct { Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"` Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` // contains filtered or unexported fields }
func (*TCPAddress) Descriptor
deprecated
func (*TCPAddress) Descriptor() ([]byte, []int)
Deprecated: Use TCPAddress.ProtoReflect.Descriptor instead.
func (*TCPAddress) GetIp ¶
func (x *TCPAddress) GetIp() string
func (*TCPAddress) GetPort ¶
func (x *TCPAddress) GetPort() uint32
func (*TCPAddress) MarshalBinary ¶
func (msg *TCPAddress) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*TCPAddress) ProtoMessage ¶
func (*TCPAddress) ProtoMessage()
func (*TCPAddress) ProtoReflect ¶
func (x *TCPAddress) ProtoReflect() protoreflect.Message
func (*TCPAddress) Reset ¶
func (x *TCPAddress) Reset()
func (*TCPAddress) String ¶
func (x *TCPAddress) String() string
func (*TCPAddress) UnmarshalBinary ¶
func (msg *TCPAddress) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type TransparentProxy ¶
type TransparentProxy struct { // outbound_listener_port is the port for the proxy's outbound listener. // This defaults to 15001. OutboundListenerPort uint32 `protobuf:"varint,1,opt,name=outbound_listener_port,json=outboundListenerPort,proto3" json:"outbound_listener_port,omitempty"` // dialed_directly indicates whether this proxy should be dialed using original destination IP // in the connection rather than load balance between all endpoints. DialedDirectly bool `protobuf:"varint,2,opt,name=dialed_directly,json=dialedDirectly,proto3" json:"dialed_directly,omitempty"` // contains filtered or unexported fields }
func (*TransparentProxy) Descriptor
deprecated
func (*TransparentProxy) Descriptor() ([]byte, []int)
Deprecated: Use TransparentProxy.ProtoReflect.Descriptor instead.
func (*TransparentProxy) GetDialedDirectly ¶
func (x *TransparentProxy) GetDialedDirectly() bool
func (*TransparentProxy) GetOutboundListenerPort ¶
func (x *TransparentProxy) GetOutboundListenerPort() uint32
func (*TransparentProxy) MarshalBinary ¶
func (msg *TransparentProxy) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*TransparentProxy) ProtoMessage ¶
func (*TransparentProxy) ProtoMessage()
func (*TransparentProxy) ProtoReflect ¶
func (x *TransparentProxy) ProtoReflect() protoreflect.Message
func (*TransparentProxy) Reset ¶
func (x *TransparentProxy) Reset()
func (*TransparentProxy) String ¶
func (x *TransparentProxy) String() string
func (*TransparentProxy) UnmarshalBinary ¶
func (msg *TransparentProxy) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type UnixSocketAddress ¶
type UnixSocketAddress struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Mode string `protobuf:"bytes,2,opt,name=mode,proto3" json:"mode,omitempty"` // contains filtered or unexported fields }
func (*UnixSocketAddress) Descriptor
deprecated
func (*UnixSocketAddress) Descriptor() ([]byte, []int)
Deprecated: Use UnixSocketAddress.ProtoReflect.Descriptor instead.
func (*UnixSocketAddress) GetMode ¶
func (x *UnixSocketAddress) GetMode() string
func (*UnixSocketAddress) GetPath ¶
func (x *UnixSocketAddress) GetPath() string
func (*UnixSocketAddress) MarshalBinary ¶
func (msg *UnixSocketAddress) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*UnixSocketAddress) ProtoMessage ¶
func (*UnixSocketAddress) ProtoMessage()
func (*UnixSocketAddress) ProtoReflect ¶
func (x *UnixSocketAddress) ProtoReflect() protoreflect.Message
func (*UnixSocketAddress) Reset ¶
func (x *UnixSocketAddress) Reset()
func (*UnixSocketAddress) String ¶
func (x *UnixSocketAddress) String() string
func (*UnixSocketAddress) UnmarshalBinary ¶
func (msg *UnixSocketAddress) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type Upstream ¶
type Upstream struct { DestinationRef *pbresource.ID `protobuf:"bytes,1,opt,name=destination_ref,json=destinationRef,proto3" json:"destination_ref,omitempty"` DestinationPort string `protobuf:"bytes,2,opt,name=destination_port,json=destinationPort,proto3" json:"destination_port,omitempty"` Datacenter string `protobuf:"bytes,3,opt,name=datacenter,proto3" json:"datacenter,omitempty"` // Types that are assignable to ListenAddr: // // *Upstream_Tcp // *Upstream_Unix ListenAddr isUpstream_ListenAddr `protobuf_oneof:"listen_addr"` UpstreamConfig *UpstreamConfig `protobuf:"bytes,7,opt,name=upstream_config,json=upstreamConfig,proto3" json:"upstream_config,omitempty"` // contains filtered or unexported fields }
func (*Upstream) Descriptor
deprecated
func (*Upstream) GetDatacenter ¶
func (*Upstream) GetDestinationPort ¶
func (*Upstream) GetDestinationRef ¶
func (x *Upstream) GetDestinationRef() *pbresource.ID
func (*Upstream) GetListenAddr ¶
func (m *Upstream) GetListenAddr() isUpstream_ListenAddr
func (*Upstream) GetTcp ¶
func (x *Upstream) GetTcp() *TCPAddress
func (*Upstream) GetUnix ¶
func (x *Upstream) GetUnix() *UnixSocketAddress
func (*Upstream) GetUpstreamConfig ¶
func (x *Upstream) GetUpstreamConfig() *UpstreamConfig
func (*Upstream) MarshalBinary ¶
MarshalBinary implements encoding.BinaryMarshaler
func (*Upstream) ProtoMessage ¶
func (*Upstream) ProtoMessage()
func (*Upstream) ProtoReflect ¶
func (x *Upstream) ProtoReflect() protoreflect.Message
func (*Upstream) UnmarshalBinary ¶
UnmarshalBinary implements encoding.BinaryUnmarshaler
type UpstreamConfig ¶
type UpstreamConfig struct { ConnectTimeoutMs uint64 `protobuf:"varint,2,opt,name=connect_timeout_ms,json=connectTimeoutMs,proto3" json:"connect_timeout_ms,omitempty"` Limits *UpstreamLimits `protobuf:"bytes,3,opt,name=limits,proto3" json:"limits,omitempty"` PassiveHealthCheck *PassiveHealthCheck `protobuf:"bytes,4,opt,name=passive_health_check,json=passiveHealthCheck,proto3" json:"passive_health_check,omitempty"` BalanceInboundConnections BalanceInboundConnections `` /* 201-byte string literal not displayed */ MeshGatewayMode MeshGatewayMode `` /* 161-byte string literal not displayed */ // contains filtered or unexported fields }
func (*UpstreamConfig) Descriptor
deprecated
func (*UpstreamConfig) Descriptor() ([]byte, []int)
Deprecated: Use UpstreamConfig.ProtoReflect.Descriptor instead.
func (*UpstreamConfig) GetBalanceInboundConnections ¶
func (x *UpstreamConfig) GetBalanceInboundConnections() BalanceInboundConnections
func (*UpstreamConfig) GetConnectTimeoutMs ¶
func (x *UpstreamConfig) GetConnectTimeoutMs() uint64
func (*UpstreamConfig) GetLimits ¶
func (x *UpstreamConfig) GetLimits() *UpstreamLimits
func (*UpstreamConfig) GetMeshGatewayMode ¶
func (x *UpstreamConfig) GetMeshGatewayMode() MeshGatewayMode
func (*UpstreamConfig) GetPassiveHealthCheck ¶
func (x *UpstreamConfig) GetPassiveHealthCheck() *PassiveHealthCheck
func (*UpstreamConfig) MarshalBinary ¶
func (msg *UpstreamConfig) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*UpstreamConfig) ProtoMessage ¶
func (*UpstreamConfig) ProtoMessage()
func (*UpstreamConfig) ProtoReflect ¶
func (x *UpstreamConfig) ProtoReflect() protoreflect.Message
func (*UpstreamConfig) Reset ¶
func (x *UpstreamConfig) Reset()
func (*UpstreamConfig) String ¶
func (x *UpstreamConfig) String() string
func (*UpstreamConfig) UnmarshalBinary ¶
func (msg *UpstreamConfig) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type UpstreamLimits ¶
type UpstreamLimits struct { // MaxConnections is the maximum number of connections the local proxy can // make to the upstream service. MaxConnections int32 `protobuf:"varint,1,opt,name=max_connections,json=maxConnections,proto3" json:"max_connections,omitempty"` // MaxPendingRequests is the maximum number of requests that will be queued // waiting for an available connection. This is mostly applicable to HTTP/1.1 // clusters since all HTTP/2 requests are streamed over a single // connection. MaxPendingRequests int32 `protobuf:"varint,2,opt,name=max_pending_requests,json=maxPendingRequests,proto3" json:"max_pending_requests,omitempty"` // MaxConcurrentRequests is the maximum number of in-flight requests that will be allowed // to the upstream cluster at a point in time. This is mostly applicable to HTTP/2 // clusters since all HTTP/1.1 requests are limited by MaxConnections. MaxConcurrentRequests int32 `` /* 127-byte string literal not displayed */ // contains filtered or unexported fields }
UpstreamLimits describes the limits that are associated with a specific upstream of a service instance.
func (*UpstreamLimits) Descriptor
deprecated
func (*UpstreamLimits) Descriptor() ([]byte, []int)
Deprecated: Use UpstreamLimits.ProtoReflect.Descriptor instead.
func (*UpstreamLimits) GetMaxConcurrentRequests ¶
func (x *UpstreamLimits) GetMaxConcurrentRequests() int32
func (*UpstreamLimits) GetMaxConnections ¶
func (x *UpstreamLimits) GetMaxConnections() int32
func (*UpstreamLimits) GetMaxPendingRequests ¶
func (x *UpstreamLimits) GetMaxPendingRequests() int32
func (*UpstreamLimits) MarshalBinary ¶
func (msg *UpstreamLimits) MarshalBinary() ([]byte, error)
MarshalBinary implements encoding.BinaryMarshaler
func (*UpstreamLimits) ProtoMessage ¶
func (*UpstreamLimits) ProtoMessage()
func (*UpstreamLimits) ProtoReflect ¶
func (x *UpstreamLimits) ProtoReflect() protoreflect.Message
func (*UpstreamLimits) Reset ¶
func (x *UpstreamLimits) Reset()
func (*UpstreamLimits) String ¶
func (x *UpstreamLimits) String() string
func (*UpstreamLimits) UnmarshalBinary ¶
func (msg *UpstreamLimits) UnmarshalBinary(b []byte) error
UnmarshalBinary implements encoding.BinaryUnmarshaler
type Upstream_Tcp ¶
type Upstream_Tcp struct {
Tcp *TCPAddress `protobuf:"bytes,4,opt,name=tcp,proto3,oneof"`
}
type Upstream_Unix ¶
type Upstream_Unix struct {
Unix *UnixSocketAddress `protobuf:"bytes,5,opt,name=unix,proto3,oneof"`
}
type Upstreams ¶
type Upstreams struct { // Selection of workloads these upstreams should apply to. // These can be prefixes or specific workload names. Workloads *v1alpha1.WorkloadSelector `protobuf:"bytes,1,opt,name=workloads,proto3" json:"workloads,omitempty"` Upstreams []*Upstream `protobuf:"bytes,2,rep,name=upstreams,proto3" json:"upstreams,omitempty"` PqUpstreams []*PreparedQueryUpstream `protobuf:"bytes,3,rep,name=pq_upstreams,json=pqUpstreams,proto3" json:"pq_upstreams,omitempty"` UpstreamConfig *UpstreamConfig `protobuf:"bytes,4,opt,name=upstream_config,json=upstreamConfig,proto3" json:"upstream_config,omitempty"` // contains filtered or unexported fields }
func (*Upstreams) Descriptor
deprecated
func (*Upstreams) GetPqUpstreams ¶
func (x *Upstreams) GetPqUpstreams() []*PreparedQueryUpstream
func (*Upstreams) GetUpstreamConfig ¶
func (x *Upstreams) GetUpstreamConfig() *UpstreamConfig
func (*Upstreams) GetUpstreams ¶
func (*Upstreams) GetWorkloads ¶
func (x *Upstreams) GetWorkloads() *v1alpha1.WorkloadSelector
func (*Upstreams) MarshalBinary ¶
MarshalBinary implements encoding.BinaryMarshaler
func (*Upstreams) ProtoMessage ¶
func (*Upstreams) ProtoMessage()
func (*Upstreams) ProtoReflect ¶
func (x *Upstreams) ProtoReflect() protoreflect.Message
func (*Upstreams) UnmarshalBinary ¶
UnmarshalBinary implements encoding.BinaryUnmarshaler