Documentation ¶
Overview ¶
Package v1alpha1 is a generated protocol buffer package.
It is generated from these files:
mesh/v1alpha1/config.proto mesh/v1alpha1/network.proto mesh/v1alpha1/proxy.proto
It has these top-level messages:
MeshConfig ConfigSource LocalityLoadBalancerSetting Network MeshNetworks Tracing ProxyConfig
Index ¶
- Variables
- type AuthenticationPolicy
- type ConfigSource
- func (*ConfigSource) Descriptor() ([]byte, []int)
- func (m *ConfigSource) GetAddress() string
- func (m *ConfigSource) GetTlsSettings() *istio_networking_v1alpha33.TLSSettings
- func (m *ConfigSource) Marshal() (dAtA []byte, err error)
- func (m *ConfigSource) MarshalTo(dAtA []byte) (int, error)
- func (*ConfigSource) ProtoMessage()
- func (m *ConfigSource) Reset()
- func (m *ConfigSource) Size() (n int)
- func (m *ConfigSource) String() string
- func (m *ConfigSource) Unmarshal(dAtA []byte) error
- type LocalityLoadBalancerSetting
- func (*LocalityLoadBalancerSetting) Descriptor() ([]byte, []int)
- func (m *LocalityLoadBalancerSetting) GetDistribute() []*LocalityLoadBalancerSetting_Distribute
- func (m *LocalityLoadBalancerSetting) GetFailover() []*LocalityLoadBalancerSetting_Failover
- func (m *LocalityLoadBalancerSetting) Marshal() (dAtA []byte, err error)
- func (m *LocalityLoadBalancerSetting) MarshalTo(dAtA []byte) (int, error)
- func (*LocalityLoadBalancerSetting) ProtoMessage()
- func (m *LocalityLoadBalancerSetting) Reset()
- func (m *LocalityLoadBalancerSetting) Size() (n int)
- func (m *LocalityLoadBalancerSetting) String() string
- func (m *LocalityLoadBalancerSetting) Unmarshal(dAtA []byte) error
- type LocalityLoadBalancerSetting_Distribute
- func (*LocalityLoadBalancerSetting_Distribute) Descriptor() ([]byte, []int)
- func (m *LocalityLoadBalancerSetting_Distribute) GetFrom() string
- func (m *LocalityLoadBalancerSetting_Distribute) GetTo() map[string]uint32
- func (m *LocalityLoadBalancerSetting_Distribute) Marshal() (dAtA []byte, err error)
- func (m *LocalityLoadBalancerSetting_Distribute) MarshalTo(dAtA []byte) (int, error)
- func (*LocalityLoadBalancerSetting_Distribute) ProtoMessage()
- func (m *LocalityLoadBalancerSetting_Distribute) Reset()
- func (m *LocalityLoadBalancerSetting_Distribute) Size() (n int)
- func (m *LocalityLoadBalancerSetting_Distribute) String() string
- func (m *LocalityLoadBalancerSetting_Distribute) Unmarshal(dAtA []byte) error
- type LocalityLoadBalancerSetting_Failover
- func (*LocalityLoadBalancerSetting_Failover) Descriptor() ([]byte, []int)
- func (m *LocalityLoadBalancerSetting_Failover) GetFrom() string
- func (m *LocalityLoadBalancerSetting_Failover) GetTo() string
- func (m *LocalityLoadBalancerSetting_Failover) Marshal() (dAtA []byte, err error)
- func (m *LocalityLoadBalancerSetting_Failover) MarshalTo(dAtA []byte) (int, error)
- func (*LocalityLoadBalancerSetting_Failover) ProtoMessage()
- func (m *LocalityLoadBalancerSetting_Failover) Reset()
- func (m *LocalityLoadBalancerSetting_Failover) Size() (n int)
- func (m *LocalityLoadBalancerSetting_Failover) String() string
- func (m *LocalityLoadBalancerSetting_Failover) Unmarshal(dAtA []byte) error
- type MeshConfig
- func (*MeshConfig) Descriptor() ([]byte, []int)
- func (m *MeshConfig) GetAccessLogEncoding() MeshConfig_AccessLogEncoding
- func (m *MeshConfig) GetAccessLogFile() string
- func (m *MeshConfig) GetAccessLogFormat() string
- func (m *MeshConfig) GetAuthPolicy() MeshConfig_AuthPolicy
- func (m *MeshConfig) GetConfigSources() []*ConfigSource
- func (m *MeshConfig) GetConnectTimeout() *google_protobuf.Duration
- func (m *MeshConfig) GetDefaultConfig() *ProxyConfig
- func (m *MeshConfig) GetDisablePolicyChecks() bool
- func (m *MeshConfig) GetEnableClientSidePolicyCheck() bool
- func (m *MeshConfig) GetEnableSdsTokenMount() bool
- func (m *MeshConfig) GetEnableTracing() bool
- func (m *MeshConfig) GetIngressClass() string
- func (m *MeshConfig) GetIngressControllerMode() MeshConfig_IngressControllerMode
- func (m *MeshConfig) GetIngressService() string
- func (m *MeshConfig) GetLocalityLbSetting() *LocalityLoadBalancerSetting
- func (m *MeshConfig) GetMixerAddress() string
- func (m *MeshConfig) GetMixerCheckServer() string
- func (m *MeshConfig) GetMixerReportServer() string
- func (m *MeshConfig) GetOutboundTrafficPolicy() *MeshConfig_OutboundTrafficPolicy
- func (m *MeshConfig) GetPolicyCheckFailOpen() bool
- func (m *MeshConfig) GetProxyHttpPort() int32
- func (m *MeshConfig) GetProxyListenPort() int32
- func (m *MeshConfig) GetRdsRefreshDelay() *google_protobuf.Duration
- func (m *MeshConfig) GetSdsRefreshDelay() *google_protobuf.Duration
- func (m *MeshConfig) GetSdsUdsPath() string
- func (m *MeshConfig) GetSdsUseK8SSaJwt() bool
- func (m *MeshConfig) GetSidecarToTelemetrySessionAffinity() bool
- func (m *MeshConfig) GetTcpKeepalive() *istio_networking_v1alpha33.ConnectionPoolSettings_TCPSettings_TcpKeepalive
- func (m *MeshConfig) GetTrustDomain() string
- func (m *MeshConfig) Marshal() (dAtA []byte, err error)
- func (m *MeshConfig) MarshalTo(dAtA []byte) (int, error)
- func (*MeshConfig) ProtoMessage()
- func (m *MeshConfig) Reset()
- func (m *MeshConfig) Size() (n int)
- func (m *MeshConfig) String() string
- func (m *MeshConfig) Unmarshal(dAtA []byte) error
- type MeshConfig_AccessLogEncoding
- type MeshConfig_AuthPolicy
- type MeshConfig_IngressControllerMode
- type MeshConfig_OutboundTrafficPolicy
- func (*MeshConfig_OutboundTrafficPolicy) Descriptor() ([]byte, []int)
- func (m *MeshConfig_OutboundTrafficPolicy) GetMode() MeshConfig_OutboundTrafficPolicy_Mode
- func (m *MeshConfig_OutboundTrafficPolicy) Marshal() (dAtA []byte, err error)
- func (m *MeshConfig_OutboundTrafficPolicy) MarshalTo(dAtA []byte) (int, error)
- func (*MeshConfig_OutboundTrafficPolicy) ProtoMessage()
- func (m *MeshConfig_OutboundTrafficPolicy) Reset()
- func (m *MeshConfig_OutboundTrafficPolicy) Size() (n int)
- func (m *MeshConfig_OutboundTrafficPolicy) String() string
- func (m *MeshConfig_OutboundTrafficPolicy) Unmarshal(dAtA []byte) error
- type MeshConfig_OutboundTrafficPolicy_Mode
- type MeshNetworks
- func (*MeshNetworks) Descriptor() ([]byte, []int)
- func (m *MeshNetworks) GetNetworks() map[string]*Network
- func (m *MeshNetworks) Marshal() (dAtA []byte, err error)
- func (m *MeshNetworks) MarshalTo(dAtA []byte) (int, error)
- func (*MeshNetworks) ProtoMessage()
- func (m *MeshNetworks) Reset()
- func (m *MeshNetworks) Size() (n int)
- func (m *MeshNetworks) String() string
- func (m *MeshNetworks) Unmarshal(dAtA []byte) error
- type Network
- func (*Network) Descriptor() ([]byte, []int)
- func (m *Network) GetEndpoints() []*Network_NetworkEndpoints
- func (m *Network) GetGateways() []*Network_IstioNetworkGateway
- func (m *Network) Marshal() (dAtA []byte, err error)
- func (m *Network) MarshalTo(dAtA []byte) (int, error)
- func (*Network) ProtoMessage()
- func (m *Network) Reset()
- func (m *Network) Size() (n int)
- func (m *Network) String() string
- func (m *Network) Unmarshal(dAtA []byte) error
- type Network_IstioNetworkGateway
- func (*Network_IstioNetworkGateway) Descriptor() ([]byte, []int)
- func (m *Network_IstioNetworkGateway) GetAddress() string
- func (m *Network_IstioNetworkGateway) GetGw() isNetwork_IstioNetworkGateway_Gw
- func (m *Network_IstioNetworkGateway) GetLocality() string
- func (m *Network_IstioNetworkGateway) GetPort() uint32
- func (m *Network_IstioNetworkGateway) GetRegistryServiceName() string
- func (m *Network_IstioNetworkGateway) Marshal() (dAtA []byte, err error)
- func (m *Network_IstioNetworkGateway) MarshalTo(dAtA []byte) (int, error)
- func (*Network_IstioNetworkGateway) ProtoMessage()
- func (m *Network_IstioNetworkGateway) Reset()
- func (m *Network_IstioNetworkGateway) Size() (n int)
- func (m *Network_IstioNetworkGateway) String() string
- func (m *Network_IstioNetworkGateway) Unmarshal(dAtA []byte) error
- func (*Network_IstioNetworkGateway) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type Network_IstioNetworkGateway_Address
- type Network_IstioNetworkGateway_RegistryServiceName
- type Network_NetworkEndpoints
- func (*Network_NetworkEndpoints) Descriptor() ([]byte, []int)
- func (m *Network_NetworkEndpoints) GetFromCidr() string
- func (m *Network_NetworkEndpoints) GetFromRegistry() string
- func (m *Network_NetworkEndpoints) GetNe() isNetwork_NetworkEndpoints_Ne
- func (m *Network_NetworkEndpoints) Marshal() (dAtA []byte, err error)
- func (m *Network_NetworkEndpoints) MarshalTo(dAtA []byte) (int, error)
- func (*Network_NetworkEndpoints) ProtoMessage()
- func (m *Network_NetworkEndpoints) Reset()
- func (m *Network_NetworkEndpoints) Size() (n int)
- func (m *Network_NetworkEndpoints) String() string
- func (m *Network_NetworkEndpoints) Unmarshal(dAtA []byte) error
- func (*Network_NetworkEndpoints) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type Network_NetworkEndpoints_FromCidr
- type Network_NetworkEndpoints_FromRegistry
- type ProxyConfig
- func (*ProxyConfig) Descriptor() ([]byte, []int)
- func (m *ProxyConfig) GetAvailabilityZone() string
- func (m *ProxyConfig) GetBinaryPath() string
- func (m *ProxyConfig) GetConcurrency() int32
- func (m *ProxyConfig) GetConfigPath() string
- func (m *ProxyConfig) GetConnectTimeout() *google_protobuf.Duration
- func (m *ProxyConfig) GetControlPlaneAuthPolicy() AuthenticationPolicy
- func (m *ProxyConfig) GetCustomConfigFile() string
- func (m *ProxyConfig) GetDiscoveryAddress() string
- func (m *ProxyConfig) GetDiscoveryRefreshDelay() *google_protobuf.Duration
- func (m *ProxyConfig) GetDrainDuration() *google_protobuf.Duration
- func (m *ProxyConfig) GetInterceptionMode() ProxyConfig_InboundInterceptionMode
- func (m *ProxyConfig) GetParentShutdownDuration() *google_protobuf.Duration
- func (m *ProxyConfig) GetProxyAdminPort() int32
- func (m *ProxyConfig) GetProxyBootstrapTemplatePath() string
- func (m *ProxyConfig) GetServiceCluster() string
- func (m *ProxyConfig) GetStatNameLength() int32
- func (m *ProxyConfig) GetStatsdUdpAddress() string
- func (m *ProxyConfig) GetTracing() *Tracing
- func (m *ProxyConfig) GetZipkinAddress() string
- func (m *ProxyConfig) Marshal() (dAtA []byte, err error)
- func (m *ProxyConfig) MarshalTo(dAtA []byte) (int, error)
- func (*ProxyConfig) ProtoMessage()
- func (m *ProxyConfig) Reset()
- func (m *ProxyConfig) Size() (n int)
- func (m *ProxyConfig) String() string
- func (m *ProxyConfig) Unmarshal(dAtA []byte) error
- type ProxyConfig_InboundInterceptionMode
- type Tracing
- func (*Tracing) Descriptor() ([]byte, []int)
- func (m *Tracing) GetDatadog() *Tracing_Datadog
- func (m *Tracing) GetLightstep() *Tracing_Lightstep
- func (m *Tracing) GetTracer() isTracing_Tracer
- func (m *Tracing) GetZipkin() *Tracing_Zipkin
- func (m *Tracing) Marshal() (dAtA []byte, err error)
- func (m *Tracing) MarshalTo(dAtA []byte) (int, error)
- func (*Tracing) ProtoMessage()
- func (m *Tracing) Reset()
- func (m *Tracing) Size() (n int)
- func (m *Tracing) String() string
- func (m *Tracing) Unmarshal(dAtA []byte) error
- func (*Tracing) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)
- type Tracing_Datadog
- func (*Tracing_Datadog) Descriptor() ([]byte, []int)
- func (m *Tracing_Datadog) GetAddress() string
- func (m *Tracing_Datadog) Marshal() (dAtA []byte, err error)
- func (m *Tracing_Datadog) MarshalTo(dAtA []byte) (int, error)
- func (*Tracing_Datadog) ProtoMessage()
- func (m *Tracing_Datadog) Reset()
- func (m *Tracing_Datadog) Size() (n int)
- func (m *Tracing_Datadog) String() string
- func (m *Tracing_Datadog) Unmarshal(dAtA []byte) error
- type Tracing_Datadog_
- type Tracing_Lightstep
- func (*Tracing_Lightstep) Descriptor() ([]byte, []int)
- func (m *Tracing_Lightstep) GetAccessToken() string
- func (m *Tracing_Lightstep) GetAddress() string
- func (m *Tracing_Lightstep) GetCacertPath() string
- func (m *Tracing_Lightstep) GetSecure() bool
- func (m *Tracing_Lightstep) Marshal() (dAtA []byte, err error)
- func (m *Tracing_Lightstep) MarshalTo(dAtA []byte) (int, error)
- func (*Tracing_Lightstep) ProtoMessage()
- func (m *Tracing_Lightstep) Reset()
- func (m *Tracing_Lightstep) Size() (n int)
- func (m *Tracing_Lightstep) String() string
- func (m *Tracing_Lightstep) Unmarshal(dAtA []byte) error
- type Tracing_Lightstep_
- type Tracing_Zipkin
- func (*Tracing_Zipkin) Descriptor() ([]byte, []int)
- func (m *Tracing_Zipkin) GetAddress() string
- func (m *Tracing_Zipkin) Marshal() (dAtA []byte, err error)
- func (m *Tracing_Zipkin) MarshalTo(dAtA []byte) (int, error)
- func (*Tracing_Zipkin) ProtoMessage()
- func (m *Tracing_Zipkin) Reset()
- func (m *Tracing_Zipkin) Size() (n int)
- func (m *Tracing_Zipkin) String() string
- func (m *Tracing_Zipkin) Unmarshal(dAtA []byte) error
- type Tracing_Zipkin_
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthConfig = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowConfig = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthNetwork = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowNetwork = fmt.Errorf("proto: integer overflow") )
var ( ErrInvalidLengthProxy = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowProxy = fmt.Errorf("proto: integer overflow") )
var AuthenticationPolicy_name = map[int32]string{
0: "NONE",
1: "MUTUAL_TLS",
1000: "INHERIT",
}
var AuthenticationPolicy_value = map[string]int32{
"NONE": 0,
"MUTUAL_TLS": 1,
"INHERIT": 1000,
}
var MeshConfig_AccessLogEncoding_name = map[int32]string{
0: "TEXT",
1: "JSON",
}
var MeshConfig_AccessLogEncoding_value = map[string]int32{
"TEXT": 0,
"JSON": 1,
}
var MeshConfig_AuthPolicy_name = map[int32]string{
0: "NONE",
1: "MUTUAL_TLS",
}
var MeshConfig_AuthPolicy_value = map[string]int32{
"NONE": 0,
"MUTUAL_TLS": 1,
}
var MeshConfig_IngressControllerMode_name = map[int32]string{
0: "OFF",
1: "DEFAULT",
2: "STRICT",
}
var MeshConfig_IngressControllerMode_value = map[string]int32{
"OFF": 0,
"DEFAULT": 1,
"STRICT": 2,
}
var MeshConfig_OutboundTrafficPolicy_Mode_name = map[int32]string{
0: "REGISTRY_ONLY",
1: "ALLOW_ANY",
}
var MeshConfig_OutboundTrafficPolicy_Mode_value = map[string]int32{
"REGISTRY_ONLY": 0,
"ALLOW_ANY": 1,
}
var ProxyConfig_InboundInterceptionMode_name = map[int32]string{
0: "REDIRECT",
1: "TPROXY",
}
var ProxyConfig_InboundInterceptionMode_value = map[string]int32{
"REDIRECT": 0,
"TPROXY": 1,
}
Functions ¶
This section is empty.
Types ¶
type AuthenticationPolicy ¶
type AuthenticationPolicy int32
AuthenticationPolicy defines authentication policy. It can be set for different scopes (mesh, service …), and the most narrow scope with non-INHERIT value will be used. Mesh policy cannot be INHERIT.
const ( // Do not encrypt Envoy to Envoy traffic. AuthenticationPolicy_NONE AuthenticationPolicy = 0 // Envoy to Envoy traffic is wrapped into mutual TLS connections. AuthenticationPolicy_MUTUAL_TLS AuthenticationPolicy = 1 // Use the policy defined by the parent scope. Should not be used for mesh // policy. AuthenticationPolicy_INHERIT AuthenticationPolicy = 1000 )
func (AuthenticationPolicy) EnumDescriptor ¶
func (AuthenticationPolicy) EnumDescriptor() ([]byte, []int)
func (AuthenticationPolicy) String ¶
func (x AuthenticationPolicy) String() string
type ConfigSource ¶
type ConfigSource struct { // Address of the server implementing the Istio Mesh Configuration // protocol (MCP). Can be IP address or a fully qualified DNS name. // Use fs:/// to specify a file-based backend with absolute path to the directory. Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // Use the tls_settings to specify the tls mode to use. If the MCP server // uses Istio MTLS and shares the root CA with Pilot, specify the TLS // mode as ISTIO_MUTUAL. TlsSettings *istio_networking_v1alpha33.TLSSettings `protobuf:"bytes,2,opt,name=tls_settings,json=tlsSettings" json:"tls_settings,omitempty"` }
ConfigSource describes information about a configuration store inside a mesh. A single control plane instance can interact with one or more data sources.
func (*ConfigSource) Descriptor ¶
func (*ConfigSource) Descriptor() ([]byte, []int)
func (*ConfigSource) GetAddress ¶
func (m *ConfigSource) GetAddress() string
func (*ConfigSource) GetTlsSettings ¶
func (m *ConfigSource) GetTlsSettings() *istio_networking_v1alpha33.TLSSettings
func (*ConfigSource) Marshal ¶
func (m *ConfigSource) Marshal() (dAtA []byte, err error)
func (*ConfigSource) ProtoMessage ¶
func (*ConfigSource) ProtoMessage()
func (*ConfigSource) Reset ¶
func (m *ConfigSource) Reset()
func (*ConfigSource) Size ¶
func (m *ConfigSource) Size() (n int)
func (*ConfigSource) String ¶
func (m *ConfigSource) String() string
func (*ConfigSource) Unmarshal ¶
func (m *ConfigSource) Unmarshal(dAtA []byte) error
type LocalityLoadBalancerSetting ¶
type LocalityLoadBalancerSetting struct { // Optional: only distribute or failover can be set. // Explicitly specify loadbalancing weight across different zones and geographical locations. // Refer to [Locality weighted load balancing](https://www.envoyproxy.io/docs/envoy/latest/intro/arch_overview/load_balancing.html?highlight=load_balancing_weight#locality-weighted-load-balancing) // If empty, the locality weight is set according to the endpoints number within it. Distribute []*LocalityLoadBalancerSetting_Distribute `protobuf:"bytes,1,rep,name=distribute" json:"distribute,omitempty"` // Optional: only failover or distribute can be set. // Explicitly specify the region traffic will land on when endpoints in local region becomes unhealthy. // Should be used together with OutlierDetection to detect unhealthy endpoints. // Note: if no OutlierDetection specified, this will not take effect. Failover []*LocalityLoadBalancerSetting_Failover `protobuf:"bytes,2,rep,name=failover" json:"failover,omitempty"` }
The following example sets up locality weight for mesh wide service Assume a service resides in "region1/zone1/*" and "region1/zone2/*", and originating clusters also reside in "region1/zone1/*" and "region1/zone2/*". This example specifies when clusters from "region1/zone1/*" accessing the service, 80% of the traffic is shipped to "region1/zone1/*" ratings service endpoints, and the rest 20% to "region1/zone2/*".
```yaml
distribute: - from: region1/zone1/* to: "region1/zone1/*": 80 "region1/zone2/*": 20 - from: region1/zone2/* to: "region1/zone1/*": 20 "region1/zone2/*": 80
```
The following example sets up locality failover policy for the ratings service Assume a service resides in "region1" "region2" and "region3", This example specifies when clusters from "region1/zone1" accessing the service, if endpoints in "region1" becomes unhealthy, traffic will begin to trickle to "region2".
```yaml
failover: - from: region1 to: region2
``` Locality load balancing settings.
func (*LocalityLoadBalancerSetting) Descriptor ¶
func (*LocalityLoadBalancerSetting) Descriptor() ([]byte, []int)
func (*LocalityLoadBalancerSetting) GetDistribute ¶
func (m *LocalityLoadBalancerSetting) GetDistribute() []*LocalityLoadBalancerSetting_Distribute
func (*LocalityLoadBalancerSetting) GetFailover ¶
func (m *LocalityLoadBalancerSetting) GetFailover() []*LocalityLoadBalancerSetting_Failover
func (*LocalityLoadBalancerSetting) Marshal ¶
func (m *LocalityLoadBalancerSetting) Marshal() (dAtA []byte, err error)
func (*LocalityLoadBalancerSetting) MarshalTo ¶
func (m *LocalityLoadBalancerSetting) MarshalTo(dAtA []byte) (int, error)
func (*LocalityLoadBalancerSetting) ProtoMessage ¶
func (*LocalityLoadBalancerSetting) ProtoMessage()
func (*LocalityLoadBalancerSetting) Reset ¶
func (m *LocalityLoadBalancerSetting) Reset()
func (*LocalityLoadBalancerSetting) Size ¶
func (m *LocalityLoadBalancerSetting) Size() (n int)
func (*LocalityLoadBalancerSetting) String ¶
func (m *LocalityLoadBalancerSetting) String() string
func (*LocalityLoadBalancerSetting) Unmarshal ¶
func (m *LocalityLoadBalancerSetting) Unmarshal(dAtA []byte) error
type LocalityLoadBalancerSetting_Distribute ¶
type LocalityLoadBalancerSetting_Distribute struct { // Originating locality, '/' separated, e.g. 'region/zone/sub_zone'. From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` // Upstream locality to loadbalancing weight map. The sum of all weights should be == 100. // Should assign load balancing weight for all localities, otherwise the traffic are not routed // following the percentage of weight. To map[string]uint32 `` /* 139-byte string literal not displayed */ }
Originating -> upstream cluster locality weight set, support wildcard matching '*' '*' matches all localities 'region1/*' matches all zones in region1
func (*LocalityLoadBalancerSetting_Distribute) Descriptor ¶
func (*LocalityLoadBalancerSetting_Distribute) Descriptor() ([]byte, []int)
func (*LocalityLoadBalancerSetting_Distribute) GetFrom ¶
func (m *LocalityLoadBalancerSetting_Distribute) GetFrom() string
func (*LocalityLoadBalancerSetting_Distribute) GetTo ¶
func (m *LocalityLoadBalancerSetting_Distribute) GetTo() map[string]uint32
func (*LocalityLoadBalancerSetting_Distribute) Marshal ¶
func (m *LocalityLoadBalancerSetting_Distribute) Marshal() (dAtA []byte, err error)
func (*LocalityLoadBalancerSetting_Distribute) MarshalTo ¶
func (m *LocalityLoadBalancerSetting_Distribute) MarshalTo(dAtA []byte) (int, error)
func (*LocalityLoadBalancerSetting_Distribute) ProtoMessage ¶
func (*LocalityLoadBalancerSetting_Distribute) ProtoMessage()
func (*LocalityLoadBalancerSetting_Distribute) Reset ¶
func (m *LocalityLoadBalancerSetting_Distribute) Reset()
func (*LocalityLoadBalancerSetting_Distribute) Size ¶
func (m *LocalityLoadBalancerSetting_Distribute) Size() (n int)
func (*LocalityLoadBalancerSetting_Distribute) String ¶
func (m *LocalityLoadBalancerSetting_Distribute) String() string
func (*LocalityLoadBalancerSetting_Distribute) Unmarshal ¶
func (m *LocalityLoadBalancerSetting_Distribute) Unmarshal(dAtA []byte) error
type LocalityLoadBalancerSetting_Failover ¶
type LocalityLoadBalancerSetting_Failover struct { // Originating region. From string `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"` // Destination region the traffic will fail over to when endpoints in local region becomes unhealthy. To string `protobuf:"bytes,2,opt,name=to,proto3" json:"to,omitempty"` }
Specify the traffic failover policy. As zone and sub_zone failover is supported by default, only region can be specified here.
func (*LocalityLoadBalancerSetting_Failover) Descriptor ¶
func (*LocalityLoadBalancerSetting_Failover) Descriptor() ([]byte, []int)
func (*LocalityLoadBalancerSetting_Failover) GetFrom ¶
func (m *LocalityLoadBalancerSetting_Failover) GetFrom() string
func (*LocalityLoadBalancerSetting_Failover) GetTo ¶
func (m *LocalityLoadBalancerSetting_Failover) GetTo() string
func (*LocalityLoadBalancerSetting_Failover) Marshal ¶
func (m *LocalityLoadBalancerSetting_Failover) Marshal() (dAtA []byte, err error)
func (*LocalityLoadBalancerSetting_Failover) MarshalTo ¶
func (m *LocalityLoadBalancerSetting_Failover) MarshalTo(dAtA []byte) (int, error)
func (*LocalityLoadBalancerSetting_Failover) ProtoMessage ¶
func (*LocalityLoadBalancerSetting_Failover) ProtoMessage()
func (*LocalityLoadBalancerSetting_Failover) Reset ¶
func (m *LocalityLoadBalancerSetting_Failover) Reset()
func (*LocalityLoadBalancerSetting_Failover) Size ¶
func (m *LocalityLoadBalancerSetting_Failover) Size() (n int)
func (*LocalityLoadBalancerSetting_Failover) String ¶
func (m *LocalityLoadBalancerSetting_Failover) String() string
func (*LocalityLoadBalancerSetting_Failover) Unmarshal ¶
func (m *LocalityLoadBalancerSetting_Failover) Unmarshal(dAtA []byte) error
type MeshConfig ¶
type MeshConfig struct { // Address of the server that will be used by the proxies for policy // check calls. By using different names for mixerCheckServer and // mixerReportServer, it is possible to have one set of mixer servers handle // policy check calls while another set of mixer servers handle telemetry // calls. // // NOTE: Omitting mixerCheckServer while specifying mixerReportServer is // equivalent to setting disablePolicyChecks to true. MixerCheckServer string `protobuf:"bytes,1,opt,name=mixer_check_server,json=mixerCheckServer,proto3" json:"mixer_check_server,omitempty"` // Address of the server that will be used by the proxies for policy report // calls. MixerReportServer string `protobuf:"bytes,2,opt,name=mixer_report_server,json=mixerReportServer,proto3" json:"mixer_report_server,omitempty"` // Disable policy checks by the mixer service. Default // is false, i.e. mixer policy check is enabled by default. DisablePolicyChecks bool `protobuf:"varint,3,opt,name=disable_policy_checks,json=disablePolicyChecks,proto3" json:"disable_policy_checks,omitempty"` // Allow all traffic in cases when the mixer policy service cannot be reached. // Default is false which means the traffic is denied when the client is unable // to connect to Mixer. PolicyCheckFailOpen bool `protobuf:"varint,25,opt,name=policy_check_fail_open,json=policyCheckFailOpen,proto3" json:"policy_check_fail_open,omitempty"` // Enable session affinity for envoy mixer reports so that calls from a proxy will // always target the same mixer instance. SidecarToTelemetrySessionAffinity bool `` /* 168-byte string literal not displayed */ // Port on which Envoy should listen for incoming connections from // other services. ProxyListenPort int32 `protobuf:"varint,4,opt,name=proxy_listen_port,json=proxyListenPort,proto3" json:"proxy_listen_port,omitempty"` // Port on which Envoy should listen for HTTP PROXY requests if set. ProxyHttpPort int32 `protobuf:"varint,5,opt,name=proxy_http_port,json=proxyHttpPort,proto3" json:"proxy_http_port,omitempty"` // Connection timeout used by Envoy. (MUST BE >=1ms) ConnectTimeout *google_protobuf.Duration `protobuf:"bytes,6,opt,name=connect_timeout,json=connectTimeout" json:"connect_timeout,omitempty"` // If set then set SO_KEEPALIVE on the socket to enable TCP Keepalives. TcpKeepalive *istio_networking_v1alpha33.ConnectionPoolSettings_TCPSettings_TcpKeepalive `protobuf:"bytes,28,opt,name=tcp_keepalive,json=tcpKeepalive" json:"tcp_keepalive,omitempty"` // Class of ingress resources to be processed by Istio ingress // controller. This corresponds to the value of // "kubernetes.io/ingress.class" annotation. IngressClass string `protobuf:"bytes,7,opt,name=ingress_class,json=ingressClass,proto3" json:"ingress_class,omitempty"` // Name of the kubernetes service used for the istio ingress controller. IngressService string `protobuf:"bytes,8,opt,name=ingress_service,json=ingressService,proto3" json:"ingress_service,omitempty"` // Defines whether to use Istio ingress controller for annotated or all ingress resources. IngressControllerMode MeshConfig_IngressControllerMode `` /* 185-byte string literal not displayed */ // $hide_from_docs AuthPolicy MeshConfig_AuthPolicy `` /* 140-byte string literal not displayed */ // $hide_from_docs RdsRefreshDelay *google_protobuf.Duration `protobuf:"bytes,11,opt,name=rds_refresh_delay,json=rdsRefreshDelay" json:"rds_refresh_delay,omitempty"` // Flag to control generation of trace spans and request IDs. // Requires a trace span collector defined in the proxy configuration. EnableTracing bool `protobuf:"varint,12,opt,name=enable_tracing,json=enableTracing,proto3" json:"enable_tracing,omitempty"` // File address for the proxy access log (e.g. /dev/stdout). // Empty value disables access logging. AccessLogFile string `protobuf:"bytes,13,opt,name=access_log_file,json=accessLogFile,proto3" json:"access_log_file,omitempty"` // Format for the proxy access log // Empty value results in proxy's default access log format AccessLogFormat string `protobuf:"bytes,24,opt,name=access_log_format,json=accessLogFormat,proto3" json:"access_log_format,omitempty"` // Encoding for the proxy access log (text or json). // Default value is text. AccessLogEncoding MeshConfig_AccessLogEncoding `` /* 170-byte string literal not displayed */ // Default proxy config used by the proxy injection mechanism operating in the mesh // (e.g. Kubernetes admission controller) // In case of Kubernetes, the proxy config is applied once during the injection process, // and remain constant for the duration of the pod. The rest of the mesh config can be changed // at runtime and config gets distributed dynamically. DefaultConfig *ProxyConfig `protobuf:"bytes,14,opt,name=default_config,json=defaultConfig" json:"default_config,omitempty"` // $hide_from_docs MixerAddress string `protobuf:"bytes,16,opt,name=mixer_address,json=mixerAddress,proto3" json:"mixer_address,omitempty"` // Set the default behavior of the sidecar for handling outbound traffic // from the application. If your application uses one or more external // services that are not known apriori, setting the policy to ALLOW_ANY // will cause the sidecars to route any unknown traffic originating from // the application to its requested destination. Users are strongly // encouraged to use ServiceEntries to explicitly declare any external // dependencies, instead of using allow_any, so that traffic to these // services can be monitored. OutboundTrafficPolicy *MeshConfig_OutboundTrafficPolicy `protobuf:"bytes,17,opt,name=outbound_traffic_policy,json=outboundTrafficPolicy" json:"outbound_traffic_policy,omitempty"` // Enables clide side policy checks. EnableClientSidePolicyCheck bool `` /* 150-byte string literal not displayed */ // Unix Domain Socket through which envoy communicates with NodeAgent SDS to get key/cert for mTLS. // Use secret-mount files instead of SDS if set to empty. SdsUdsPath string `protobuf:"bytes,20,opt,name=sds_uds_path,json=sdsUdsPath,proto3" json:"sds_uds_path,omitempty"` // $hide_from_docs SdsRefreshDelay *google_protobuf.Duration `protobuf:"bytes,21,opt,name=sds_refresh_delay,json=sdsRefreshDelay" json:"sds_refresh_delay,omitempty"` // ConfigSource describes a source of configuration data for networking // rules, and other Istio configuration artifacts. Multiple data sources // can be configured for a single control plane. ConfigSources []*ConfigSource `protobuf:"bytes,22,rep,name=config_sources,json=configSources" json:"config_sources,omitempty"` // Locality based load balancing distribution or failover settings. LocalityLbSetting *LocalityLoadBalancerSetting `protobuf:"bytes,31,opt,name=locality_lb_setting,json=localityLbSetting" json:"locality_lb_setting,omitempty"` // $hide_from_docs // This flag is used by secret discovery service(SDS). // If set to true(prerequisite: https://kubernetes.io/docs/concepts/storage/volumes/#projected), Istio will inject volumes mount // for k8s service account trustworthy JWT(which is avaialbe for k8s 1.12 or higher), so that K8s API server // mounts k8s service account trustworthy JWT to envoy container, which will be used to request key/cert eventually. // This isn't supported for non-k8s case. EnableSdsTokenMount bool `protobuf:"varint,23,opt,name=enable_sds_token_mount,json=enableSdsTokenMount,proto3" json:"enable_sds_token_mount,omitempty"` // $hide_from_docs // This flag is used by secret discovery service(SDS). // If set to true, envoy will fetch normal k8s service account JWT from '/var/run/secrets/kubernetes.io/serviceaccount/token' // (https://kubernetes.io/docs/tasks/access-application-cluster/access-cluster/#accessing-the-api-from-a-pod) // and pass to sds server, which will be used to request key/cert eventually. // If both enable_sds_token_mount and sds_use_k8s_sa_jwt are set to true, enable_sds_token_mount(trustworthy jwt) takes precedence. // This isn't supported for non-k8s case. SdsUseK8SSaJwt bool `protobuf:"varint,29,opt,name=sds_use_k8s_sa_jwt,json=sdsUseK8sSaJwt,proto3" json:"sds_use_k8s_sa_jwt,omitempty"` // The trust domain corresponds to the trust root of a system. // Refer to https://github.com/spiffe/spiffe/blob/master/standards/SPIFFE-ID.md#21-trust-domain // Fallback to old identity format(without trust domain) if not set. TrustDomain string `protobuf:"bytes,26,opt,name=trust_domain,json=trustDomain,proto3" json:"trust_domain,omitempty"` }
MeshConfig defines mesh-wide variables shared by all Envoy instances in the Istio service mesh.
NOTE: This configuration type should be used for the low-level global configuration, such as component addresses and port numbers. It should not be used for the features of the mesh that can be scoped by service or by namespace. Some of the fields in the mesh config are going to be deprecated and replaced with several individual configuration types (for example, tracing configuration).
func (*MeshConfig) Descriptor ¶
func (*MeshConfig) Descriptor() ([]byte, []int)
func (*MeshConfig) GetAccessLogEncoding ¶
func (m *MeshConfig) GetAccessLogEncoding() MeshConfig_AccessLogEncoding
func (*MeshConfig) GetAccessLogFile ¶
func (m *MeshConfig) GetAccessLogFile() string
func (*MeshConfig) GetAccessLogFormat ¶
func (m *MeshConfig) GetAccessLogFormat() string
func (*MeshConfig) GetAuthPolicy ¶
func (m *MeshConfig) GetAuthPolicy() MeshConfig_AuthPolicy
func (*MeshConfig) GetConfigSources ¶
func (m *MeshConfig) GetConfigSources() []*ConfigSource
func (*MeshConfig) GetConnectTimeout ¶
func (m *MeshConfig) GetConnectTimeout() *google_protobuf.Duration
func (*MeshConfig) GetDefaultConfig ¶
func (m *MeshConfig) GetDefaultConfig() *ProxyConfig
func (*MeshConfig) GetDisablePolicyChecks ¶
func (m *MeshConfig) GetDisablePolicyChecks() bool
func (*MeshConfig) GetEnableClientSidePolicyCheck ¶
func (m *MeshConfig) GetEnableClientSidePolicyCheck() bool
func (*MeshConfig) GetEnableSdsTokenMount ¶
func (m *MeshConfig) GetEnableSdsTokenMount() bool
func (*MeshConfig) GetEnableTracing ¶
func (m *MeshConfig) GetEnableTracing() bool
func (*MeshConfig) GetIngressClass ¶
func (m *MeshConfig) GetIngressClass() string
func (*MeshConfig) GetIngressControllerMode ¶
func (m *MeshConfig) GetIngressControllerMode() MeshConfig_IngressControllerMode
func (*MeshConfig) GetIngressService ¶
func (m *MeshConfig) GetIngressService() string
func (*MeshConfig) GetLocalityLbSetting ¶
func (m *MeshConfig) GetLocalityLbSetting() *LocalityLoadBalancerSetting
func (*MeshConfig) GetMixerAddress ¶
func (m *MeshConfig) GetMixerAddress() string
func (*MeshConfig) GetMixerCheckServer ¶
func (m *MeshConfig) GetMixerCheckServer() string
func (*MeshConfig) GetMixerReportServer ¶
func (m *MeshConfig) GetMixerReportServer() string
func (*MeshConfig) GetOutboundTrafficPolicy ¶
func (m *MeshConfig) GetOutboundTrafficPolicy() *MeshConfig_OutboundTrafficPolicy
func (*MeshConfig) GetPolicyCheckFailOpen ¶
func (m *MeshConfig) GetPolicyCheckFailOpen() bool
func (*MeshConfig) GetProxyHttpPort ¶
func (m *MeshConfig) GetProxyHttpPort() int32
func (*MeshConfig) GetProxyListenPort ¶
func (m *MeshConfig) GetProxyListenPort() int32
func (*MeshConfig) GetRdsRefreshDelay ¶
func (m *MeshConfig) GetRdsRefreshDelay() *google_protobuf.Duration
func (*MeshConfig) GetSdsRefreshDelay ¶
func (m *MeshConfig) GetSdsRefreshDelay() *google_protobuf.Duration
func (*MeshConfig) GetSdsUdsPath ¶
func (m *MeshConfig) GetSdsUdsPath() string
func (*MeshConfig) GetSdsUseK8SSaJwt ¶
func (m *MeshConfig) GetSdsUseK8SSaJwt() bool
func (*MeshConfig) GetSidecarToTelemetrySessionAffinity ¶
func (m *MeshConfig) GetSidecarToTelemetrySessionAffinity() bool
func (*MeshConfig) GetTcpKeepalive ¶
func (m *MeshConfig) GetTcpKeepalive() *istio_networking_v1alpha33.ConnectionPoolSettings_TCPSettings_TcpKeepalive
func (*MeshConfig) GetTrustDomain ¶
func (m *MeshConfig) GetTrustDomain() string
func (*MeshConfig) Marshal ¶
func (m *MeshConfig) Marshal() (dAtA []byte, err error)
func (*MeshConfig) ProtoMessage ¶
func (*MeshConfig) ProtoMessage()
func (*MeshConfig) Reset ¶
func (m *MeshConfig) Reset()
func (*MeshConfig) Size ¶
func (m *MeshConfig) Size() (n int)
func (*MeshConfig) String ¶
func (m *MeshConfig) String() string
func (*MeshConfig) Unmarshal ¶
func (m *MeshConfig) Unmarshal(dAtA []byte) error
type MeshConfig_AccessLogEncoding ¶
type MeshConfig_AccessLogEncoding int32
const ( MeshConfig_TEXT MeshConfig_AccessLogEncoding = 0 MeshConfig_JSON MeshConfig_AccessLogEncoding = 1 )
func (MeshConfig_AccessLogEncoding) EnumDescriptor ¶
func (MeshConfig_AccessLogEncoding) EnumDescriptor() ([]byte, []int)
func (MeshConfig_AccessLogEncoding) String ¶
func (x MeshConfig_AccessLogEncoding) String() string
type MeshConfig_AuthPolicy ¶
type MeshConfig_AuthPolicy int32
$hide_from_docs
const ( MeshConfig_NONE MeshConfig_AuthPolicy = 0 MeshConfig_MUTUAL_TLS MeshConfig_AuthPolicy = 1 )
func (MeshConfig_AuthPolicy) EnumDescriptor ¶
func (MeshConfig_AuthPolicy) EnumDescriptor() ([]byte, []int)
func (MeshConfig_AuthPolicy) String ¶
func (x MeshConfig_AuthPolicy) String() string
type MeshConfig_IngressControllerMode ¶
type MeshConfig_IngressControllerMode int32
const ( // Disables Istio ingress controller. MeshConfig_OFF MeshConfig_IngressControllerMode = 0 // Istio ingress controller will act on ingress resources that do not // contain any annotation or whose annotations match the value // specified in the ingress_class parameter described earlier. Use this // mode if Istio ingress controller will be the default ingress // controller for the entire kubernetes cluster. MeshConfig_DEFAULT MeshConfig_IngressControllerMode = 1 // Istio ingress controller will only act on ingress resources whose // annotations match the value specified in the ingress_class parameter // described earlier. Use this mode if Istio ingress controller will be // a secondary ingress controller (e.g., in addition to a // cloud-provided ingress controller). MeshConfig_STRICT MeshConfig_IngressControllerMode = 2 )
func (MeshConfig_IngressControllerMode) EnumDescriptor ¶
func (MeshConfig_IngressControllerMode) EnumDescriptor() ([]byte, []int)
func (MeshConfig_IngressControllerMode) String ¶
func (x MeshConfig_IngressControllerMode) String() string
type MeshConfig_OutboundTrafficPolicy ¶
type MeshConfig_OutboundTrafficPolicy struct {
Mode MeshConfig_OutboundTrafficPolicy_Mode `protobuf:"varint,1,opt,name=mode,proto3,enum=istio.mesh.v1alpha1.MeshConfig_OutboundTrafficPolicy_Mode" json:"mode,omitempty"`
}
func (*MeshConfig_OutboundTrafficPolicy) Descriptor ¶
func (*MeshConfig_OutboundTrafficPolicy) Descriptor() ([]byte, []int)
func (*MeshConfig_OutboundTrafficPolicy) GetMode ¶
func (m *MeshConfig_OutboundTrafficPolicy) GetMode() MeshConfig_OutboundTrafficPolicy_Mode
func (*MeshConfig_OutboundTrafficPolicy) Marshal ¶
func (m *MeshConfig_OutboundTrafficPolicy) Marshal() (dAtA []byte, err error)
func (*MeshConfig_OutboundTrafficPolicy) MarshalTo ¶
func (m *MeshConfig_OutboundTrafficPolicy) MarshalTo(dAtA []byte) (int, error)
func (*MeshConfig_OutboundTrafficPolicy) ProtoMessage ¶
func (*MeshConfig_OutboundTrafficPolicy) ProtoMessage()
func (*MeshConfig_OutboundTrafficPolicy) Reset ¶
func (m *MeshConfig_OutboundTrafficPolicy) Reset()
func (*MeshConfig_OutboundTrafficPolicy) Size ¶
func (m *MeshConfig_OutboundTrafficPolicy) Size() (n int)
func (*MeshConfig_OutboundTrafficPolicy) String ¶
func (m *MeshConfig_OutboundTrafficPolicy) String() string
func (*MeshConfig_OutboundTrafficPolicy) Unmarshal ¶
func (m *MeshConfig_OutboundTrafficPolicy) Unmarshal(dAtA []byte) error
type MeshConfig_OutboundTrafficPolicy_Mode ¶
type MeshConfig_OutboundTrafficPolicy_Mode int32
const ( // outbound traffic will be restricted to services defined in the // service registry as well as those defined through ServiceEntries MeshConfig_OutboundTrafficPolicy_REGISTRY_ONLY MeshConfig_OutboundTrafficPolicy_Mode = 0 // outbound traffic to unknown destinations will be allowed, in case // there are no services or ServiceEntries for the destination port MeshConfig_OutboundTrafficPolicy_ALLOW_ANY MeshConfig_OutboundTrafficPolicy_Mode = 1 )
func (MeshConfig_OutboundTrafficPolicy_Mode) EnumDescriptor ¶
func (MeshConfig_OutboundTrafficPolicy_Mode) EnumDescriptor() ([]byte, []int)
func (MeshConfig_OutboundTrafficPolicy_Mode) String ¶
func (x MeshConfig_OutboundTrafficPolicy_Mode) String() string
type MeshNetworks ¶
type MeshNetworks struct { // REQUIRED: The set of networks inside this mesh. Each network should // have a unique name and information about how to infer the endpoints in // the network as well as the gateways associated with the network. Networks map[string]*Network `` /* 143-byte string literal not displayed */ }
MeshNetworks (config map) provides information about the set of networks inside a mesh and how to route to endpoints in each network. For example
MeshNetworks(file/config map): networks: - network1:
- endpoints:
- fromRegistry: registry1 #must match secret name in kubernetes
- fromCidr: 192.168.100.0/22 #a VM network for example gateways:
- registryServiceName: istio-ingressgateway.istio-system.svc.cluster.local port: 15443 locality: us-east-1a
func (*MeshNetworks) Descriptor ¶
func (*MeshNetworks) Descriptor() ([]byte, []int)
func (*MeshNetworks) GetNetworks ¶
func (m *MeshNetworks) GetNetworks() map[string]*Network
func (*MeshNetworks) Marshal ¶
func (m *MeshNetworks) Marshal() (dAtA []byte, err error)
func (*MeshNetworks) ProtoMessage ¶
func (*MeshNetworks) ProtoMessage()
func (*MeshNetworks) Reset ¶
func (m *MeshNetworks) Reset()
func (*MeshNetworks) Size ¶
func (m *MeshNetworks) Size() (n int)
func (*MeshNetworks) String ¶
func (m *MeshNetworks) String() string
func (*MeshNetworks) Unmarshal ¶
func (m *MeshNetworks) Unmarshal(dAtA []byte) error
type Network ¶
type Network struct { // REQUIRED: The list of endpoints in the network (obtained through the // constituent service registries or from CIDR ranges). All endpoints in // the network are directly accessible to one another. Endpoints []*Network_NetworkEndpoints `protobuf:"bytes,2,rep,name=endpoints" json:"endpoints,omitempty"` // REQUIRED: Set of gateways associated with the network. Gateways []*Network_IstioNetworkGateway `protobuf:"bytes,3,rep,name=gateways" json:"gateways,omitempty"` }
Network provides information about the endpoints in a routable L3 network. A single routable L3 network can have one or more service registries. Note that the network has no relation to the locality of the endpoint. The endpoint locality will be obtained from the service registry.
func (*Network) Descriptor ¶
func (*Network) GetEndpoints ¶
func (m *Network) GetEndpoints() []*Network_NetworkEndpoints
func (*Network) GetGateways ¶
func (m *Network) GetGateways() []*Network_IstioNetworkGateway
func (*Network) ProtoMessage ¶
func (*Network) ProtoMessage()
type Network_IstioNetworkGateway ¶
type Network_IstioNetworkGateway struct { // Types that are valid to be assigned to Gw: // *Network_IstioNetworkGateway_RegistryServiceName // *Network_IstioNetworkGateway_Address Gw isNetwork_IstioNetworkGateway_Gw `protobuf_oneof:"gw"` // REQUIRED: The port associated with the gateway. Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` // The locality associated with an explicitly specified gateway (i.e. ip) Locality string `protobuf:"bytes,4,opt,name=locality,proto3" json:"locality,omitempty"` }
The gateway associated with this network. Traffic from remote networks will arrive at the specified gateway:port. All incoming traffic must use mTLS.
func (*Network_IstioNetworkGateway) Descriptor ¶
func (*Network_IstioNetworkGateway) Descriptor() ([]byte, []int)
func (*Network_IstioNetworkGateway) GetAddress ¶
func (m *Network_IstioNetworkGateway) GetAddress() string
func (*Network_IstioNetworkGateway) GetGw ¶
func (m *Network_IstioNetworkGateway) GetGw() isNetwork_IstioNetworkGateway_Gw
func (*Network_IstioNetworkGateway) GetLocality ¶
func (m *Network_IstioNetworkGateway) GetLocality() string
func (*Network_IstioNetworkGateway) GetPort ¶
func (m *Network_IstioNetworkGateway) GetPort() uint32
func (*Network_IstioNetworkGateway) GetRegistryServiceName ¶
func (m *Network_IstioNetworkGateway) GetRegistryServiceName() string
func (*Network_IstioNetworkGateway) Marshal ¶
func (m *Network_IstioNetworkGateway) Marshal() (dAtA []byte, err error)
func (*Network_IstioNetworkGateway) MarshalTo ¶
func (m *Network_IstioNetworkGateway) MarshalTo(dAtA []byte) (int, error)
func (*Network_IstioNetworkGateway) ProtoMessage ¶
func (*Network_IstioNetworkGateway) ProtoMessage()
func (*Network_IstioNetworkGateway) Reset ¶
func (m *Network_IstioNetworkGateway) Reset()
func (*Network_IstioNetworkGateway) Size ¶
func (m *Network_IstioNetworkGateway) Size() (n int)
func (*Network_IstioNetworkGateway) String ¶
func (m *Network_IstioNetworkGateway) String() string
func (*Network_IstioNetworkGateway) Unmarshal ¶
func (m *Network_IstioNetworkGateway) Unmarshal(dAtA []byte) error
func (*Network_IstioNetworkGateway) XXX_OneofFuncs ¶
func (*Network_IstioNetworkGateway) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type Network_IstioNetworkGateway_Address ¶
type Network_IstioNetworkGateway_Address struct {
Address string `protobuf:"bytes,2,opt,name=address,proto3,oneof"`
}
func (*Network_IstioNetworkGateway_Address) MarshalTo ¶
func (m *Network_IstioNetworkGateway_Address) MarshalTo(dAtA []byte) (int, error)
func (*Network_IstioNetworkGateway_Address) Size ¶
func (m *Network_IstioNetworkGateway_Address) Size() (n int)
type Network_IstioNetworkGateway_RegistryServiceName ¶
type Network_IstioNetworkGateway_RegistryServiceName struct {
RegistryServiceName string `protobuf:"bytes,1,opt,name=registry_service_name,json=registryServiceName,proto3,oneof"`
}
func (*Network_IstioNetworkGateway_RegistryServiceName) MarshalTo ¶
func (m *Network_IstioNetworkGateway_RegistryServiceName) MarshalTo(dAtA []byte) (int, error)
func (*Network_IstioNetworkGateway_RegistryServiceName) Size ¶
func (m *Network_IstioNetworkGateway_RegistryServiceName) Size() (n int)
type Network_NetworkEndpoints ¶
type Network_NetworkEndpoints struct { // Types that are valid to be assigned to Ne: // *Network_NetworkEndpoints_FromCidr // *Network_NetworkEndpoints_FromRegistry Ne isNetwork_NetworkEndpoints_Ne `protobuf_oneof:"ne"` }
NetworkEndpoints describes how the network associated with an endpoint should be inferred. An endpoint will be assigned to a network based on the following rules:
1. Implicitly: If the registry explicitly provides information about the network to which the endpoint belongs to. In some cases, its possible to indicate the network associated with the endpoint by adding ISTIO_META_NETWORK environment variable to the sidecar.
2. Explicitly:
a. By matching the registry name with one of the "from_registries" in the mesh config. A "from_registry" can only be assigned to a single network. b. By matching the IP against one of the CIDR ranges in a mesh config network. The CIDR ranges must not overlap and be assigned to a single network.
(2) will override (1) if both are present.
func (*Network_NetworkEndpoints) Descriptor ¶
func (*Network_NetworkEndpoints) Descriptor() ([]byte, []int)
func (*Network_NetworkEndpoints) GetFromCidr ¶
func (m *Network_NetworkEndpoints) GetFromCidr() string
func (*Network_NetworkEndpoints) GetFromRegistry ¶
func (m *Network_NetworkEndpoints) GetFromRegistry() string
func (*Network_NetworkEndpoints) GetNe ¶
func (m *Network_NetworkEndpoints) GetNe() isNetwork_NetworkEndpoints_Ne
func (*Network_NetworkEndpoints) Marshal ¶
func (m *Network_NetworkEndpoints) Marshal() (dAtA []byte, err error)
func (*Network_NetworkEndpoints) MarshalTo ¶
func (m *Network_NetworkEndpoints) MarshalTo(dAtA []byte) (int, error)
func (*Network_NetworkEndpoints) ProtoMessage ¶
func (*Network_NetworkEndpoints) ProtoMessage()
func (*Network_NetworkEndpoints) Reset ¶
func (m *Network_NetworkEndpoints) Reset()
func (*Network_NetworkEndpoints) Size ¶
func (m *Network_NetworkEndpoints) Size() (n int)
func (*Network_NetworkEndpoints) String ¶
func (m *Network_NetworkEndpoints) String() string
func (*Network_NetworkEndpoints) Unmarshal ¶
func (m *Network_NetworkEndpoints) Unmarshal(dAtA []byte) error
func (*Network_NetworkEndpoints) XXX_OneofFuncs ¶
func (*Network_NetworkEndpoints) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})
XXX_OneofFuncs is for the internal use of the proto package.
type Network_NetworkEndpoints_FromCidr ¶
type Network_NetworkEndpoints_FromCidr struct {
FromCidr string `protobuf:"bytes,1,opt,name=from_cidr,json=fromCidr,proto3,oneof"`
}
func (*Network_NetworkEndpoints_FromCidr) MarshalTo ¶
func (m *Network_NetworkEndpoints_FromCidr) MarshalTo(dAtA []byte) (int, error)
func (*Network_NetworkEndpoints_FromCidr) Size ¶
func (m *Network_NetworkEndpoints_FromCidr) Size() (n int)
type Network_NetworkEndpoints_FromRegistry ¶
type Network_NetworkEndpoints_FromRegistry struct {
FromRegistry string `protobuf:"bytes,2,opt,name=from_registry,json=fromRegistry,proto3,oneof"`
}
func (*Network_NetworkEndpoints_FromRegistry) MarshalTo ¶
func (m *Network_NetworkEndpoints_FromRegistry) MarshalTo(dAtA []byte) (int, error)
func (*Network_NetworkEndpoints_FromRegistry) Size ¶
func (m *Network_NetworkEndpoints_FromRegistry) Size() (n int)
type ProxyConfig ¶
type ProxyConfig struct { // Path to the generated configuration file directory. // Proxy agent generates the actual configuration and stores it in this directory. ConfigPath string `protobuf:"bytes,1,opt,name=config_path,json=configPath,proto3" json:"config_path,omitempty"` // Path to the proxy binary BinaryPath string `protobuf:"bytes,2,opt,name=binary_path,json=binaryPath,proto3" json:"binary_path,omitempty"` // Service cluster defines the name for the service_cluster that is // shared by all Envoy instances. This setting corresponds to // _--service-cluster_ flag in Envoy. In a typical Envoy deployment, the // _service-cluster_ flag is used to identify the caller, for // source-based routing scenarios. // // Since Istio does not assign a local service/service version to each // Envoy instance, the name is same for all of them. However, the // source/caller's identity (e.g., IP address) is encoded in the // _--service-node_ flag when launching Envoy. When the RDS service // receives API calls from Envoy, it uses the value of the _service-node_ // flag to compute routes that are relative to the service instances // located at that IP address. ServiceCluster string `protobuf:"bytes,3,opt,name=service_cluster,json=serviceCluster,proto3" json:"service_cluster,omitempty"` // The time in seconds that Envoy will drain connections during a hot // restart. MUST be >=1s (e.g., _1s/1m/1h_) DrainDuration *google_protobuf.Duration `protobuf:"bytes,4,opt,name=drain_duration,json=drainDuration" json:"drain_duration,omitempty"` // The time in seconds that Envoy will wait before shutting down the // parent process during a hot restart. MUST be >=1s (e.g., _1s/1m/1h_). // MUST BE greater than _drain_duration_ parameter. ParentShutdownDuration *google_protobuf.Duration `protobuf:"bytes,5,opt,name=parent_shutdown_duration,json=parentShutdownDuration" json:"parent_shutdown_duration,omitempty"` // Address of the discovery service exposing xDS with mTLS connection. DiscoveryAddress string `protobuf:"bytes,6,opt,name=discovery_address,json=discoveryAddress,proto3" json:"discovery_address,omitempty"` // $hide_from_docs DiscoveryRefreshDelay *google_protobuf.Duration `protobuf:"bytes,7,opt,name=discovery_refresh_delay,json=discoveryRefreshDelay" json:"discovery_refresh_delay,omitempty"` // Address of the Zipkin service (e.g. _zipkin:9411_). // DEPRECATED: Use [tracing][istio.mesh.v1alpha1.ProxyConfig.tracing] instead. ZipkinAddress string `protobuf:"bytes,8,opt,name=zipkin_address,json=zipkinAddress,proto3" json:"zipkin_address,omitempty"` // Connection timeout used by Envoy for supporting services. (MUST BE >=1ms) ConnectTimeout *google_protobuf.Duration `protobuf:"bytes,9,opt,name=connect_timeout,json=connectTimeout" json:"connect_timeout,omitempty"` // IP Address and Port of a statsd UDP listener (e.g. _10.75.241.127:9125_). StatsdUdpAddress string `protobuf:"bytes,10,opt,name=statsd_udp_address,json=statsdUdpAddress,proto3" json:"statsd_udp_address,omitempty"` // Port on which Envoy should listen for administrative commands. ProxyAdminPort int32 `protobuf:"varint,11,opt,name=proxy_admin_port,json=proxyAdminPort,proto3" json:"proxy_admin_port,omitempty"` // $hide_from_docs AvailabilityZone string `protobuf:"bytes,12,opt,name=availability_zone,json=availabilityZone,proto3" json:"availability_zone,omitempty"` // Authentication policy defines the global switch to control authentication // for Envoy-to-Envoy communication for istio components Mixer and Pilot. ControlPlaneAuthPolicy AuthenticationPolicy `` /* 179-byte string literal not displayed */ // File path of custom proxy configuration, currently used by proxies // in front of Mixer and Pilot. CustomConfigFile string `protobuf:"bytes,14,opt,name=custom_config_file,json=customConfigFile,proto3" json:"custom_config_file,omitempty"` // Maximum length of name field in Envoy's metrics. The length of the name field // is determined by the length of a name field in a service and the set of labels that // comprise a particular version of the service. The default value is set to 189 characters. // Envoy's internal metrics take up 67 characters, for a total of 256 character name per metric. // Increase the value of this field if you find that the metrics from Envoys are truncated. StatNameLength int32 `protobuf:"varint,15,opt,name=stat_name_length,json=statNameLength,proto3" json:"stat_name_length,omitempty"` // The number of worker threads to run. Default value is number of cores on the machine. Concurrency int32 `protobuf:"varint,16,opt,name=concurrency,proto3" json:"concurrency,omitempty"` // Path to the proxy bootstrap template file ProxyBootstrapTemplatePath string `` /* 144-byte string literal not displayed */ // The mode used to redirect inbound traffic to Envoy. InterceptionMode ProxyConfig_InboundInterceptionMode `` /* 172-byte string literal not displayed */ // Tracing configuration to be used by the proxy. Tracing *Tracing `protobuf:"bytes,19,opt,name=tracing" json:"tracing,omitempty"` }
ProxyConfig defines variables for individual Envoy instances.
func (*ProxyConfig) Descriptor ¶
func (*ProxyConfig) Descriptor() ([]byte, []int)
func (*ProxyConfig) GetAvailabilityZone ¶
func (m *ProxyConfig) GetAvailabilityZone() string
func (*ProxyConfig) GetBinaryPath ¶
func (m *ProxyConfig) GetBinaryPath() string
func (*ProxyConfig) GetConcurrency ¶
func (m *ProxyConfig) GetConcurrency() int32
func (*ProxyConfig) GetConfigPath ¶
func (m *ProxyConfig) GetConfigPath() string
func (*ProxyConfig) GetConnectTimeout ¶
func (m *ProxyConfig) GetConnectTimeout() *google_protobuf.Duration
func (*ProxyConfig) GetControlPlaneAuthPolicy ¶
func (m *ProxyConfig) GetControlPlaneAuthPolicy() AuthenticationPolicy
func (*ProxyConfig) GetCustomConfigFile ¶
func (m *ProxyConfig) GetCustomConfigFile() string
func (*ProxyConfig) GetDiscoveryAddress ¶
func (m *ProxyConfig) GetDiscoveryAddress() string
func (*ProxyConfig) GetDiscoveryRefreshDelay ¶
func (m *ProxyConfig) GetDiscoveryRefreshDelay() *google_protobuf.Duration
func (*ProxyConfig) GetDrainDuration ¶
func (m *ProxyConfig) GetDrainDuration() *google_protobuf.Duration
func (*ProxyConfig) GetInterceptionMode ¶
func (m *ProxyConfig) GetInterceptionMode() ProxyConfig_InboundInterceptionMode
func (*ProxyConfig) GetParentShutdownDuration ¶
func (m *ProxyConfig) GetParentShutdownDuration() *google_protobuf.Duration
func (*ProxyConfig) GetProxyAdminPort ¶
func (m *ProxyConfig) GetProxyAdminPort() int32
func (*ProxyConfig) GetProxyBootstrapTemplatePath ¶
func (m *ProxyConfig) GetProxyBootstrapTemplatePath() string
func (*ProxyConfig) GetServiceCluster ¶
func (m *ProxyConfig) GetServiceCluster() string
func (*ProxyConfig) GetStatNameLength ¶
func (m *ProxyConfig) GetStatNameLength() int32
func (*ProxyConfig) GetStatsdUdpAddress ¶
func (m *ProxyConfig) GetStatsdUdpAddress() string
func (*ProxyConfig) GetTracing ¶
func (m *ProxyConfig) GetTracing() *Tracing
func (*ProxyConfig) GetZipkinAddress ¶
func (m *ProxyConfig) GetZipkinAddress() string
func (*ProxyConfig) Marshal ¶
func (m *ProxyConfig) Marshal() (dAtA []byte, err error)
func (*ProxyConfig) ProtoMessage ¶
func (*ProxyConfig) ProtoMessage()
func (*ProxyConfig) Reset ¶
func (m *ProxyConfig) Reset()
func (*ProxyConfig) Size ¶
func (m *ProxyConfig) Size() (n int)
func (*ProxyConfig) String ¶
func (m *ProxyConfig) String() string
func (*ProxyConfig) Unmarshal ¶
func (m *ProxyConfig) Unmarshal(dAtA []byte) error
type ProxyConfig_InboundInterceptionMode ¶
type ProxyConfig_InboundInterceptionMode int32
The mode used to redirect inbound traffic to Envoy. This setting has no effect on outbound traffic: iptables REDIRECT is always used for outbound connections.
const ( // The REDIRECT mode uses iptables REDIRECT to NAT and redirect to Envoy. This mode loses // source IP addresses during redirection. ProxyConfig_REDIRECT ProxyConfig_InboundInterceptionMode = 0 // The TPROXY mode uses iptables TPROXY to redirect to Envoy. This mode preserves both the // source and destination IP addresses and ports, so that they can be used for advanced // filtering and manipulation. This mode also configures the sidecar to run with the // CAP_NET_ADMIN capability, which is required to use TPROXY. ProxyConfig_TPROXY ProxyConfig_InboundInterceptionMode = 1 )
func (ProxyConfig_InboundInterceptionMode) EnumDescriptor ¶
func (ProxyConfig_InboundInterceptionMode) EnumDescriptor() ([]byte, []int)
func (ProxyConfig_InboundInterceptionMode) String ¶
func (x ProxyConfig_InboundInterceptionMode) String() string
type Tracing ¶
type Tracing struct { // The tracer implementation to be used by Envoy. // // Types that are valid to be assigned to Tracer: // *Tracing_Zipkin_ // *Tracing_Lightstep_ // *Tracing_Datadog_ Tracer isTracing_Tracer `protobuf_oneof:"tracer"` }
Tracing defines configuration for the tracing performed by Envoy instances.
func (*Tracing) Descriptor ¶
func (*Tracing) GetDatadog ¶
func (m *Tracing) GetDatadog() *Tracing_Datadog
func (*Tracing) GetLightstep ¶
func (m *Tracing) GetLightstep() *Tracing_Lightstep
func (*Tracing) GetZipkin ¶
func (m *Tracing) GetZipkin() *Tracing_Zipkin
func (*Tracing) ProtoMessage ¶
func (*Tracing) ProtoMessage()
type Tracing_Datadog ¶
type Tracing_Datadog struct { // Address of the Datadog Agent. Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` }
Datadog defines configuration for a Datadog tracer.
func (*Tracing_Datadog) Descriptor ¶
func (*Tracing_Datadog) Descriptor() ([]byte, []int)
func (*Tracing_Datadog) GetAddress ¶
func (m *Tracing_Datadog) GetAddress() string
func (*Tracing_Datadog) Marshal ¶
func (m *Tracing_Datadog) Marshal() (dAtA []byte, err error)
func (*Tracing_Datadog) ProtoMessage ¶
func (*Tracing_Datadog) ProtoMessage()
func (*Tracing_Datadog) Reset ¶
func (m *Tracing_Datadog) Reset()
func (*Tracing_Datadog) Size ¶
func (m *Tracing_Datadog) Size() (n int)
func (*Tracing_Datadog) String ¶
func (m *Tracing_Datadog) String() string
func (*Tracing_Datadog) Unmarshal ¶
func (m *Tracing_Datadog) Unmarshal(dAtA []byte) error
type Tracing_Datadog_ ¶
type Tracing_Datadog_ struct {
Datadog *Tracing_Datadog `protobuf:"bytes,3,opt,name=datadog,oneof"`
}
func (*Tracing_Datadog_) Size ¶
func (m *Tracing_Datadog_) Size() (n int)
type Tracing_Lightstep ¶
type Tracing_Lightstep struct { // Address of the LightStep Satellite pool. Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // The LightStep access token. AccessToken string `protobuf:"bytes,2,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"` // True if a secure connection should be used when communicating with the pool. Secure bool `protobuf:"varint,3,opt,name=secure,proto3" json:"secure,omitempty"` // Path to the trusted cacert used to authenticate the pool. CacertPath string `protobuf:"bytes,4,opt,name=cacert_path,json=cacertPath,proto3" json:"cacert_path,omitempty"` }
Lightstep defines configuration for a LightStep tracer.
func (*Tracing_Lightstep) Descriptor ¶
func (*Tracing_Lightstep) Descriptor() ([]byte, []int)
func (*Tracing_Lightstep) GetAccessToken ¶
func (m *Tracing_Lightstep) GetAccessToken() string
func (*Tracing_Lightstep) GetAddress ¶
func (m *Tracing_Lightstep) GetAddress() string
func (*Tracing_Lightstep) GetCacertPath ¶
func (m *Tracing_Lightstep) GetCacertPath() string
func (*Tracing_Lightstep) GetSecure ¶
func (m *Tracing_Lightstep) GetSecure() bool
func (*Tracing_Lightstep) Marshal ¶
func (m *Tracing_Lightstep) Marshal() (dAtA []byte, err error)
func (*Tracing_Lightstep) MarshalTo ¶
func (m *Tracing_Lightstep) MarshalTo(dAtA []byte) (int, error)
func (*Tracing_Lightstep) ProtoMessage ¶
func (*Tracing_Lightstep) ProtoMessage()
func (*Tracing_Lightstep) Reset ¶
func (m *Tracing_Lightstep) Reset()
func (*Tracing_Lightstep) Size ¶
func (m *Tracing_Lightstep) Size() (n int)
func (*Tracing_Lightstep) String ¶
func (m *Tracing_Lightstep) String() string
func (*Tracing_Lightstep) Unmarshal ¶
func (m *Tracing_Lightstep) Unmarshal(dAtA []byte) error
type Tracing_Lightstep_ ¶
type Tracing_Lightstep_ struct {
Lightstep *Tracing_Lightstep `protobuf:"bytes,2,opt,name=lightstep,oneof"`
}
func (*Tracing_Lightstep_) MarshalTo ¶
func (m *Tracing_Lightstep_) MarshalTo(dAtA []byte) (int, error)
func (*Tracing_Lightstep_) Size ¶
func (m *Tracing_Lightstep_) Size() (n int)
type Tracing_Zipkin ¶
type Tracing_Zipkin struct { // Address of the Zipkin service (e.g. _zipkin:9411_). Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` }
Zipkin defines configuration for a Zipkin tracer.
func (*Tracing_Zipkin) Descriptor ¶
func (*Tracing_Zipkin) Descriptor() ([]byte, []int)
func (*Tracing_Zipkin) GetAddress ¶
func (m *Tracing_Zipkin) GetAddress() string
func (*Tracing_Zipkin) Marshal ¶
func (m *Tracing_Zipkin) Marshal() (dAtA []byte, err error)
func (*Tracing_Zipkin) ProtoMessage ¶
func (*Tracing_Zipkin) ProtoMessage()
func (*Tracing_Zipkin) Reset ¶
func (m *Tracing_Zipkin) Reset()
func (*Tracing_Zipkin) Size ¶
func (m *Tracing_Zipkin) Size() (n int)
func (*Tracing_Zipkin) String ¶
func (m *Tracing_Zipkin) String() string
func (*Tracing_Zipkin) Unmarshal ¶
func (m *Tracing_Zipkin) Unmarshal(dAtA []byte) error
type Tracing_Zipkin_ ¶
type Tracing_Zipkin_ struct {
Zipkin *Tracing_Zipkin `protobuf:"bytes,1,opt,name=zipkin,oneof"`
}
func (*Tracing_Zipkin_) Size ¶
func (m *Tracing_Zipkin_) Size() (n int)