v2

package

Go to main page

Versions in this module

v0

v0.9.9

Apr 21, 2021

Changes in this version

+ var Cluster_LbSubsetConfig_LbSubsetSelector_LbSubsetSelectorFallbackPolicy_name = map[int32]string

+ var Cluster_LbSubsetConfig_LbSubsetSelector_LbSubsetSelectorFallbackPolicy_value = map[string]int32

+ var File_envoy_api_v2_cds_proto protoreflect.FileDescriptor

+ var File_envoy_api_v2_cluster_proto protoreflect.FileDescriptor

+ var File_envoy_api_v2_discovery_proto protoreflect.FileDescriptor

+ var File_envoy_api_v2_eds_proto protoreflect.FileDescriptor

+ var File_envoy_api_v2_endpoint_proto protoreflect.FileDescriptor

+ var File_envoy_api_v2_lds_proto protoreflect.FileDescriptor

+ var File_envoy_api_v2_listener_proto protoreflect.FileDescriptor

+ var File_envoy_api_v2_rds_proto protoreflect.FileDescriptor

+ var File_envoy_api_v2_route_proto protoreflect.FileDescriptor

+ var File_envoy_api_v2_scoped_route_proto protoreflect.FileDescriptor

+ var File_envoy_api_v2_srds_proto protoreflect.FileDescriptor

+ func RegisterScopedRoutesDiscoveryServiceServer(s *grpc.Server, srv ScopedRoutesDiscoveryServiceServer)

+ type CdsDummy struct

+ func (*CdsDummy) Descriptor() ([]byte, []int)

+ func (*CdsDummy) ProtoMessage()

+ func (m *CdsDummy) Validate() error

+ func (x *CdsDummy) ProtoReflect() protoreflect.Message

+ func (x *CdsDummy) Reset()

+ func (x *CdsDummy) String() string

+ type CdsDummyValidationError struct

+ func (e CdsDummyValidationError) Cause() error

+ func (e CdsDummyValidationError) Error() string

+ func (e CdsDummyValidationError) ErrorName() string

+ func (e CdsDummyValidationError) Field() string

+ func (e CdsDummyValidationError) Key() bool

+ func (e CdsDummyValidationError) Reason() string

type Cluster

+ DnsFailureRefreshRate *Cluster_RefreshRate

+ Filters []*cluster.Filter

+ LoadBalancingPolicy *LoadBalancingPolicy

+ LrsServer *core.ConfigSource

+ RespectDnsTtl bool

+ TrackTimeoutBudgets bool

+ TransportSocketMatches []*Cluster_TransportSocketMatch

+ UpstreamHttpProtocolOptions *core.UpstreamHttpProtocolOptions

+ UseTcpForDnsLookups bool

+ func (x *Cluster) GetDnsFailureRefreshRate() *Cluster_RefreshRate

+ func (x *Cluster) GetFilters() []*cluster.Filter

+ func (x *Cluster) GetLoadBalancingPolicy() *LoadBalancingPolicy

+ func (x *Cluster) GetLrsServer() *core.ConfigSource

+ func (x *Cluster) GetRespectDnsTtl() bool

+ func (x *Cluster) GetTrackTimeoutBudgets() bool

+ func (x *Cluster) GetTransportSocketMatches() []*Cluster_TransportSocketMatch

+ func (x *Cluster) GetUpstreamHttpProtocolOptions() *core.UpstreamHttpProtocolOptions

+ func (x *Cluster) GetUseTcpForDnsLookups() bool

+ func (x *Cluster) ProtoReflect() protoreflect.Message

type ClusterLoadAssignment

+ func (x *ClusterLoadAssignment) ProtoReflect() protoreflect.Message

type ClusterLoadAssignment_Policy

+ DisableOverprovisioning bool

+ func (x *ClusterLoadAssignment_Policy) GetDisableOverprovisioning() bool

+ func (x *ClusterLoadAssignment_Policy) ProtoReflect() protoreflect.Message

type ClusterLoadAssignment_Policy_DropOverload

+ func (x *ClusterLoadAssignment_Policy_DropOverload) ProtoReflect() protoreflect.Message

type Cluster_ClusterProtocolSelection

+ func (Cluster_ClusterProtocolSelection) Descriptor() protoreflect.EnumDescriptor

+ func (Cluster_ClusterProtocolSelection) Type() protoreflect.EnumType

+ func (x Cluster_ClusterProtocolSelection) Enum() *Cluster_ClusterProtocolSelection

+ func (x Cluster_ClusterProtocolSelection) Number() protoreflect.EnumNumber

type Cluster_CommonLbConfig

+ CloseConnectionsOnHostSetChange bool

+ ConsistentHashingLbConfig *Cluster_CommonLbConfig_ConsistentHashingLbConfig

+ IgnoreNewHostsUntilFirstHc bool

+ func (x *Cluster_CommonLbConfig) GetCloseConnectionsOnHostSetChange() bool

+ func (x *Cluster_CommonLbConfig) GetConsistentHashingLbConfig() *Cluster_CommonLbConfig_ConsistentHashingLbConfig

+ func (x *Cluster_CommonLbConfig) GetIgnoreNewHostsUntilFirstHc() bool

+ func (x *Cluster_CommonLbConfig) ProtoReflect() protoreflect.Message

+ type Cluster_CommonLbConfig_ConsistentHashingLbConfig struct

+ UseHostnameForHashing bool

+ func (*Cluster_CommonLbConfig_ConsistentHashingLbConfig) Descriptor() ([]byte, []int)

+ func (*Cluster_CommonLbConfig_ConsistentHashingLbConfig) ProtoMessage()

+ func (m *Cluster_CommonLbConfig_ConsistentHashingLbConfig) Validate() error

+ func (x *Cluster_CommonLbConfig_ConsistentHashingLbConfig) GetUseHostnameForHashing() bool

+ func (x *Cluster_CommonLbConfig_ConsistentHashingLbConfig) ProtoReflect() protoreflect.Message

+ func (x *Cluster_CommonLbConfig_ConsistentHashingLbConfig) Reset()

+ func (x *Cluster_CommonLbConfig_ConsistentHashingLbConfig) String() string

+ type Cluster_CommonLbConfig_ConsistentHashingLbConfigValidationError struct

+ func (e Cluster_CommonLbConfig_ConsistentHashingLbConfigValidationError) Cause() error

+ func (e Cluster_CommonLbConfig_ConsistentHashingLbConfigValidationError) Error() string

+ func (e Cluster_CommonLbConfig_ConsistentHashingLbConfigValidationError) ErrorName() string

+ func (e Cluster_CommonLbConfig_ConsistentHashingLbConfigValidationError) Field() string

+ func (e Cluster_CommonLbConfig_ConsistentHashingLbConfigValidationError) Key() bool

+ func (e Cluster_CommonLbConfig_ConsistentHashingLbConfigValidationError) Reason() string

type Cluster_CommonLbConfig_LocalityWeightedLbConfig

+ func (x *Cluster_CommonLbConfig_LocalityWeightedLbConfig) ProtoReflect() protoreflect.Message

type Cluster_CommonLbConfig_ZoneAwareLbConfig

+ FailTrafficOnPanic bool

+ func (x *Cluster_CommonLbConfig_ZoneAwareLbConfig) GetFailTrafficOnPanic() bool

+ func (x *Cluster_CommonLbConfig_ZoneAwareLbConfig) ProtoReflect() protoreflect.Message

type Cluster_CustomClusterType

+ func (x *Cluster_CustomClusterType) ProtoReflect() protoreflect.Message

type Cluster_DiscoveryType

+ func (Cluster_DiscoveryType) Descriptor() protoreflect.EnumDescriptor

+ func (Cluster_DiscoveryType) Type() protoreflect.EnumType

+ func (x Cluster_DiscoveryType) Enum() *Cluster_DiscoveryType

+ func (x Cluster_DiscoveryType) Number() protoreflect.EnumNumber

type Cluster_DnsLookupFamily

+ func (Cluster_DnsLookupFamily) Descriptor() protoreflect.EnumDescriptor

+ func (Cluster_DnsLookupFamily) Type() protoreflect.EnumType

+ func (x Cluster_DnsLookupFamily) Enum() *Cluster_DnsLookupFamily

+ func (x Cluster_DnsLookupFamily) Number() protoreflect.EnumNumber

type Cluster_EdsClusterConfig

+ func (x *Cluster_EdsClusterConfig) ProtoReflect() protoreflect.Message

type Cluster_LbPolicy

+ const Cluster_CLUSTER_PROVIDED

+ const Cluster_LOAD_BALANCING_POLICY_CONFIG

+ func (Cluster_LbPolicy) Descriptor() protoreflect.EnumDescriptor

+ func (Cluster_LbPolicy) Type() protoreflect.EnumType

+ func (x Cluster_LbPolicy) Enum() *Cluster_LbPolicy

+ func (x Cluster_LbPolicy) Number() protoreflect.EnumNumber

type Cluster_LbSubsetConfig

+ ListAsAny bool

+ func (x *Cluster_LbSubsetConfig) GetListAsAny() bool

+ func (x *Cluster_LbSubsetConfig) ProtoReflect() protoreflect.Message

type Cluster_LbSubsetConfig_LbSubsetFallbackPolicy

+ func (Cluster_LbSubsetConfig_LbSubsetFallbackPolicy) Descriptor() protoreflect.EnumDescriptor

+ func (Cluster_LbSubsetConfig_LbSubsetFallbackPolicy) Type() protoreflect.EnumType

+ func (x Cluster_LbSubsetConfig_LbSubsetFallbackPolicy) Enum() *Cluster_LbSubsetConfig_LbSubsetFallbackPolicy

+ func (x Cluster_LbSubsetConfig_LbSubsetFallbackPolicy) Number() protoreflect.EnumNumber

type Cluster_LbSubsetConfig_LbSubsetSelector

+ FallbackKeysSubset []string

+ FallbackPolicy Cluster_LbSubsetConfig_LbSubsetSelector_LbSubsetSelectorFallbackPolicy

+ func (x *Cluster_LbSubsetConfig_LbSubsetSelector) GetFallbackKeysSubset() []string

+ func (x *Cluster_LbSubsetConfig_LbSubsetSelector) GetFallbackPolicy() Cluster_LbSubsetConfig_LbSubsetSelector_LbSubsetSelectorFallbackPolicy

+ func (x *Cluster_LbSubsetConfig_LbSubsetSelector) ProtoReflect() protoreflect.Message

+ type Cluster_LbSubsetConfig_LbSubsetSelector_LbSubsetSelectorFallbackPolicy int32

+ const Cluster_LbSubsetConfig_LbSubsetSelector_ANY_ENDPOINT

+ const Cluster_LbSubsetConfig_LbSubsetSelector_DEFAULT_SUBSET

+ const Cluster_LbSubsetConfig_LbSubsetSelector_KEYS_SUBSET

+ const Cluster_LbSubsetConfig_LbSubsetSelector_NOT_DEFINED

+ const Cluster_LbSubsetConfig_LbSubsetSelector_NO_FALLBACK

+ func (Cluster_LbSubsetConfig_LbSubsetSelector_LbSubsetSelectorFallbackPolicy) Descriptor() protoreflect.EnumDescriptor

+ func (Cluster_LbSubsetConfig_LbSubsetSelector_LbSubsetSelectorFallbackPolicy) EnumDescriptor() ([]byte, []int)

+ func (Cluster_LbSubsetConfig_LbSubsetSelector_LbSubsetSelectorFallbackPolicy) Type() protoreflect.EnumType

+ func (x Cluster_LbSubsetConfig_LbSubsetSelector_LbSubsetSelectorFallbackPolicy) Enum() *Cluster_LbSubsetConfig_LbSubsetSelector_LbSubsetSelectorFallbackPolicy

+ func (x Cluster_LbSubsetConfig_LbSubsetSelector_LbSubsetSelectorFallbackPolicy) Number() protoreflect.EnumNumber

+ func (x Cluster_LbSubsetConfig_LbSubsetSelector_LbSubsetSelectorFallbackPolicy) String() string

type Cluster_LeastRequestLbConfig

+ func (x *Cluster_LeastRequestLbConfig) ProtoReflect() protoreflect.Message

type Cluster_OriginalDstLbConfig

+ func (x *Cluster_OriginalDstLbConfig) ProtoReflect() protoreflect.Message

+ type Cluster_RefreshRate struct

+ BaseInterval *duration.Duration

+ MaxInterval *duration.Duration

+ func (*Cluster_RefreshRate) Descriptor() ([]byte, []int)

+ func (*Cluster_RefreshRate) ProtoMessage()

+ func (m *Cluster_RefreshRate) Validate() error

+ func (x *Cluster_RefreshRate) GetBaseInterval() *duration.Duration

+ func (x *Cluster_RefreshRate) GetMaxInterval() *duration.Duration

+ func (x *Cluster_RefreshRate) ProtoReflect() protoreflect.Message

+ func (x *Cluster_RefreshRate) Reset()

+ func (x *Cluster_RefreshRate) String() string

+ type Cluster_RefreshRateValidationError struct

+ func (e Cluster_RefreshRateValidationError) Cause() error

+ func (e Cluster_RefreshRateValidationError) Error() string

+ func (e Cluster_RefreshRateValidationError) ErrorName() string

+ func (e Cluster_RefreshRateValidationError) Field() string

+ func (e Cluster_RefreshRateValidationError) Key() bool

+ func (e Cluster_RefreshRateValidationError) Reason() string

type Cluster_RingHashLbConfig

+ func (x *Cluster_RingHashLbConfig) ProtoReflect() protoreflect.Message

type Cluster_RingHashLbConfig_HashFunction

+ func (Cluster_RingHashLbConfig_HashFunction) Descriptor() protoreflect.EnumDescriptor

+ func (Cluster_RingHashLbConfig_HashFunction) Type() protoreflect.EnumType

+ func (x Cluster_RingHashLbConfig_HashFunction) Enum() *Cluster_RingHashLbConfig_HashFunction

+ func (x Cluster_RingHashLbConfig_HashFunction) Number() protoreflect.EnumNumber

+ type Cluster_TransportSocketMatch struct

+ Match *_struct.Struct

+ Name string

+ TransportSocket *core.TransportSocket

+ func (*Cluster_TransportSocketMatch) Descriptor() ([]byte, []int)

+ func (*Cluster_TransportSocketMatch) ProtoMessage()

+ func (m *Cluster_TransportSocketMatch) Validate() error

+ func (x *Cluster_TransportSocketMatch) GetMatch() *_struct.Struct

+ func (x *Cluster_TransportSocketMatch) GetName() string

+ func (x *Cluster_TransportSocketMatch) GetTransportSocket() *core.TransportSocket

+ func (x *Cluster_TransportSocketMatch) ProtoReflect() protoreflect.Message

+ func (x *Cluster_TransportSocketMatch) Reset()

+ func (x *Cluster_TransportSocketMatch) String() string

+ type Cluster_TransportSocketMatchValidationError struct

+ func (e Cluster_TransportSocketMatchValidationError) Cause() error

+ func (e Cluster_TransportSocketMatchValidationError) Error() string

+ func (e Cluster_TransportSocketMatchValidationError) ErrorName() string

+ func (e Cluster_TransportSocketMatchValidationError) Field() string

+ func (e Cluster_TransportSocketMatchValidationError) Key() bool

+ func (e Cluster_TransportSocketMatchValidationError) Reason() string

type DeltaDiscoveryRequest

+ func (x *DeltaDiscoveryRequest) ProtoReflect() protoreflect.Message

type DeltaDiscoveryResponse

+ TypeUrl string

+ func (x *DeltaDiscoveryResponse) GetTypeUrl() string

+ func (x *DeltaDiscoveryResponse) ProtoReflect() protoreflect.Message

type DiscoveryRequest

+ func (x *DiscoveryRequest) ProtoReflect() protoreflect.Message

type DiscoveryResponse

+ func (x *DiscoveryResponse) ProtoReflect() protoreflect.Message

+ type EdsDummy struct

+ func (*EdsDummy) Descriptor() ([]byte, []int)

+ func (*EdsDummy) ProtoMessage()

+ func (m *EdsDummy) Validate() error

+ func (x *EdsDummy) ProtoReflect() protoreflect.Message

+ func (x *EdsDummy) Reset()

+ func (x *EdsDummy) String() string

+ type EdsDummyValidationError struct

+ func (e EdsDummyValidationError) Cause() error

+ func (e EdsDummyValidationError) Error() string

+ func (e EdsDummyValidationError) ErrorName() string

+ func (e EdsDummyValidationError) Field() string

+ func (e EdsDummyValidationError) Key() bool

+ func (e EdsDummyValidationError) Reason() string

type EndpointDiscoveryServiceClient

+ DeltaEndpoints func(ctx context.Context, opts ...grpc.CallOption) (EndpointDiscoveryService_DeltaEndpointsClient, error)

type EndpointDiscoveryServiceServer

+ DeltaEndpoints func(EndpointDiscoveryService_DeltaEndpointsServer) error

+ type EndpointDiscoveryService_DeltaEndpointsClient interface

+ Recv func() (*DeltaDiscoveryResponse, error)

+ Send func(*DeltaDiscoveryRequest) error

+ type EndpointDiscoveryService_DeltaEndpointsServer interface

+ Recv func() (*DeltaDiscoveryRequest, error)

+ Send func(*DeltaDiscoveryResponse) error

+ type LdsDummy struct

+ func (*LdsDummy) Descriptor() ([]byte, []int)

+ func (*LdsDummy) ProtoMessage()

+ func (m *LdsDummy) Validate() error

+ func (x *LdsDummy) ProtoReflect() protoreflect.Message

+ func (x *LdsDummy) Reset()

+ func (x *LdsDummy) String() string

+ type LdsDummyValidationError struct

+ func (e LdsDummyValidationError) Cause() error

+ func (e LdsDummyValidationError) Error() string

+ func (e LdsDummyValidationError) ErrorName() string

+ func (e LdsDummyValidationError) Field() string

+ func (e LdsDummyValidationError) Key() bool

+ func (e LdsDummyValidationError) Reason() string

type Listener

+ AccessLog []*v21.AccessLog

+ ApiListener *v2.ApiListener

+ ConnectionBalanceConfig *Listener_ConnectionBalanceConfig

+ ContinueOnListenerFiltersTimeout bool

+ ReusePort bool

+ TrafficDirection core.TrafficDirection

+ UdpListenerConfig *listener.UdpListenerConfig

+ func (x *Listener) GetAccessLog() []*v21.AccessLog

+ func (x *Listener) GetApiListener() *v2.ApiListener

+ func (x *Listener) GetConnectionBalanceConfig() *Listener_ConnectionBalanceConfig

+ func (x *Listener) GetContinueOnListenerFiltersTimeout() bool

+ func (x *Listener) GetReusePort() bool

+ func (x *Listener) GetTrafficDirection() core.TrafficDirection

+ func (x *Listener) GetUdpListenerConfig() *listener.UdpListenerConfig

+ func (x *Listener) ProtoReflect() protoreflect.Message

type ListenerDiscoveryServiceClient

+ DeltaListeners func(ctx context.Context, opts ...grpc.CallOption) (ListenerDiscoveryService_DeltaListenersClient, error)

type ListenerDiscoveryServiceServer

+ DeltaListeners func(ListenerDiscoveryService_DeltaListenersServer) error

+ type ListenerDiscoveryService_DeltaListenersClient interface

+ Recv func() (*DeltaDiscoveryResponse, error)

+ Send func(*DeltaDiscoveryRequest) error

+ type ListenerDiscoveryService_DeltaListenersServer interface

+ Recv func() (*DeltaDiscoveryRequest, error)

+ Send func(*DeltaDiscoveryResponse) error

+ type Listener_ConnectionBalanceConfig struct

+ BalanceType isListener_ConnectionBalanceConfig_BalanceType

+ func (*Listener_ConnectionBalanceConfig) Descriptor() ([]byte, []int)

+ func (*Listener_ConnectionBalanceConfig) ProtoMessage()

+ func (m *Listener_ConnectionBalanceConfig) GetBalanceType() isListener_ConnectionBalanceConfig_BalanceType

+ func (m *Listener_ConnectionBalanceConfig) Validate() error

+ func (x *Listener_ConnectionBalanceConfig) GetExactBalance() *Listener_ConnectionBalanceConfig_ExactBalance

+ func (x *Listener_ConnectionBalanceConfig) ProtoReflect() protoreflect.Message

+ func (x *Listener_ConnectionBalanceConfig) Reset()

+ func (x *Listener_ConnectionBalanceConfig) String() string

+ type Listener_ConnectionBalanceConfigValidationError struct

+ func (e Listener_ConnectionBalanceConfigValidationError) Cause() error

+ func (e Listener_ConnectionBalanceConfigValidationError) Error() string

+ func (e Listener_ConnectionBalanceConfigValidationError) ErrorName() string

+ func (e Listener_ConnectionBalanceConfigValidationError) Field() string

+ func (e Listener_ConnectionBalanceConfigValidationError) Key() bool

+ func (e Listener_ConnectionBalanceConfigValidationError) Reason() string

+ type Listener_ConnectionBalanceConfig_ExactBalance struct

+ func (*Listener_ConnectionBalanceConfig_ExactBalance) Descriptor() ([]byte, []int)

+ func (*Listener_ConnectionBalanceConfig_ExactBalance) ProtoMessage()

+ func (m *Listener_ConnectionBalanceConfig_ExactBalance) Validate() error

+ func (x *Listener_ConnectionBalanceConfig_ExactBalance) ProtoReflect() protoreflect.Message

+ func (x *Listener_ConnectionBalanceConfig_ExactBalance) Reset()

+ func (x *Listener_ConnectionBalanceConfig_ExactBalance) String() string

+ type Listener_ConnectionBalanceConfig_ExactBalanceValidationError struct

+ func (e Listener_ConnectionBalanceConfig_ExactBalanceValidationError) Cause() error

+ func (e Listener_ConnectionBalanceConfig_ExactBalanceValidationError) Error() string

+ func (e Listener_ConnectionBalanceConfig_ExactBalanceValidationError) ErrorName() string

+ func (e Listener_ConnectionBalanceConfig_ExactBalanceValidationError) Field() string

+ func (e Listener_ConnectionBalanceConfig_ExactBalanceValidationError) Key() bool

+ func (e Listener_ConnectionBalanceConfig_ExactBalanceValidationError) Reason() string

+ type Listener_ConnectionBalanceConfig_ExactBalance_ struct

+ ExactBalance *Listener_ConnectionBalanceConfig_ExactBalance

type Listener_DeprecatedV1

+ func (x *Listener_DeprecatedV1) ProtoReflect() protoreflect.Message

type Listener_DrainType

+ func (Listener_DrainType) Descriptor() protoreflect.EnumDescriptor

+ func (Listener_DrainType) Type() protoreflect.EnumType

+ func (x Listener_DrainType) Enum() *Listener_DrainType

+ func (x Listener_DrainType) Number() protoreflect.EnumNumber

+ type LoadBalancingPolicy struct

+ Policies []*LoadBalancingPolicy_Policy

+ func (*LoadBalancingPolicy) Descriptor() ([]byte, []int)

+ func (*LoadBalancingPolicy) ProtoMessage()

+ func (m *LoadBalancingPolicy) Validate() error

+ func (x *LoadBalancingPolicy) GetPolicies() []*LoadBalancingPolicy_Policy

+ func (x *LoadBalancingPolicy) ProtoReflect() protoreflect.Message

+ func (x *LoadBalancingPolicy) Reset()

+ func (x *LoadBalancingPolicy) String() string

+ type LoadBalancingPolicyValidationError struct

+ func (e LoadBalancingPolicyValidationError) Cause() error

+ func (e LoadBalancingPolicyValidationError) Error() string

+ func (e LoadBalancingPolicyValidationError) ErrorName() string

+ func (e LoadBalancingPolicyValidationError) Field() string

+ func (e LoadBalancingPolicyValidationError) Key() bool

+ func (e LoadBalancingPolicyValidationError) Reason() string

+ type LoadBalancingPolicy_Policy struct

+ Config *_struct.Struct

+ Name string

+ TypedConfig *any.Any

+ func (*LoadBalancingPolicy_Policy) Descriptor() ([]byte, []int)

+ func (*LoadBalancingPolicy_Policy) ProtoMessage()

+ func (m *LoadBalancingPolicy_Policy) Validate() error

+ func (x *LoadBalancingPolicy_Policy) GetConfig() *_struct.Struct

+ func (x *LoadBalancingPolicy_Policy) GetName() string

+ func (x *LoadBalancingPolicy_Policy) GetTypedConfig() *any.Any

+ func (x *LoadBalancingPolicy_Policy) ProtoReflect() protoreflect.Message

+ func (x *LoadBalancingPolicy_Policy) Reset()

+ func (x *LoadBalancingPolicy_Policy) String() string

+ type LoadBalancingPolicy_PolicyValidationError struct

+ func (e LoadBalancingPolicy_PolicyValidationError) Cause() error

+ func (e LoadBalancingPolicy_PolicyValidationError) Error() string

+ func (e LoadBalancingPolicy_PolicyValidationError) ErrorName() string

+ func (e LoadBalancingPolicy_PolicyValidationError) Field() string

+ func (e LoadBalancingPolicy_PolicyValidationError) Key() bool

+ func (e LoadBalancingPolicy_PolicyValidationError) Reason() string

+ type RdsDummy struct

+ func (*RdsDummy) Descriptor() ([]byte, []int)

+ func (*RdsDummy) ProtoMessage()

+ func (m *RdsDummy) Validate() error

+ func (x *RdsDummy) ProtoReflect() protoreflect.Message

+ func (x *RdsDummy) Reset()

+ func (x *RdsDummy) String() string

+ type RdsDummyValidationError struct

+ func (e RdsDummyValidationError) Cause() error

+ func (e RdsDummyValidationError) Error() string

+ func (e RdsDummyValidationError) ErrorName() string

+ func (e RdsDummyValidationError) Field() string

+ func (e RdsDummyValidationError) Key() bool

+ func (e RdsDummyValidationError) Reason() string

type Resource

+ func (x *Resource) ProtoReflect() protoreflect.Message

type RouteConfiguration

+ MostSpecificHeaderMutationsWins bool

+ func (x *RouteConfiguration) GetMostSpecificHeaderMutationsWins() bool

+ func (x *RouteConfiguration) ProtoReflect() protoreflect.Message

+ type ScopedRouteConfiguration struct

+ Key *ScopedRouteConfiguration_Key

+ Name string

+ RouteConfigurationName string

+ func (*ScopedRouteConfiguration) Descriptor() ([]byte, []int)

+ func (*ScopedRouteConfiguration) ProtoMessage()

+ func (m *ScopedRouteConfiguration) Validate() error

+ func (x *ScopedRouteConfiguration) GetKey() *ScopedRouteConfiguration_Key

+ func (x *ScopedRouteConfiguration) GetName() string

+ func (x *ScopedRouteConfiguration) GetRouteConfigurationName() string

+ func (x *ScopedRouteConfiguration) ProtoReflect() protoreflect.Message

+ func (x *ScopedRouteConfiguration) Reset()

+ func (x *ScopedRouteConfiguration) String() string

+ type ScopedRouteConfigurationValidationError struct

+ func (e ScopedRouteConfigurationValidationError) Cause() error

+ func (e ScopedRouteConfigurationValidationError) Error() string

+ func (e ScopedRouteConfigurationValidationError) ErrorName() string

+ func (e ScopedRouteConfigurationValidationError) Field() string

+ func (e ScopedRouteConfigurationValidationError) Key() bool

+ func (e ScopedRouteConfigurationValidationError) Reason() string

+ type ScopedRouteConfiguration_Key struct

+ Fragments []*ScopedRouteConfiguration_Key_Fragment

+ func (*ScopedRouteConfiguration_Key) Descriptor() ([]byte, []int)

+ func (*ScopedRouteConfiguration_Key) ProtoMessage()

+ func (m *ScopedRouteConfiguration_Key) Validate() error

+ func (x *ScopedRouteConfiguration_Key) GetFragments() []*ScopedRouteConfiguration_Key_Fragment

+ func (x *ScopedRouteConfiguration_Key) ProtoReflect() protoreflect.Message

+ func (x *ScopedRouteConfiguration_Key) Reset()

+ func (x *ScopedRouteConfiguration_Key) String() string

+ type ScopedRouteConfiguration_KeyValidationError struct

+ func (e ScopedRouteConfiguration_KeyValidationError) Cause() error

+ func (e ScopedRouteConfiguration_KeyValidationError) Error() string

+ func (e ScopedRouteConfiguration_KeyValidationError) ErrorName() string

+ func (e ScopedRouteConfiguration_KeyValidationError) Field() string

+ func (e ScopedRouteConfiguration_KeyValidationError) Key() bool

+ func (e ScopedRouteConfiguration_KeyValidationError) Reason() string

+ type ScopedRouteConfiguration_Key_Fragment struct

+ Type isScopedRouteConfiguration_Key_Fragment_Type

+ func (*ScopedRouteConfiguration_Key_Fragment) Descriptor() ([]byte, []int)

+ func (*ScopedRouteConfiguration_Key_Fragment) ProtoMessage()

+ func (m *ScopedRouteConfiguration_Key_Fragment) GetType() isScopedRouteConfiguration_Key_Fragment_Type

+ func (m *ScopedRouteConfiguration_Key_Fragment) Validate() error

+ func (x *ScopedRouteConfiguration_Key_Fragment) GetStringKey() string

+ func (x *ScopedRouteConfiguration_Key_Fragment) ProtoReflect() protoreflect.Message

+ func (x *ScopedRouteConfiguration_Key_Fragment) Reset()

+ func (x *ScopedRouteConfiguration_Key_Fragment) String() string

+ type ScopedRouteConfiguration_Key_FragmentValidationError struct

+ func (e ScopedRouteConfiguration_Key_FragmentValidationError) Cause() error

+ func (e ScopedRouteConfiguration_Key_FragmentValidationError) Error() string

+ func (e ScopedRouteConfiguration_Key_FragmentValidationError) ErrorName() string

+ func (e ScopedRouteConfiguration_Key_FragmentValidationError) Field() string

+ func (e ScopedRouteConfiguration_Key_FragmentValidationError) Key() bool

+ func (e ScopedRouteConfiguration_Key_FragmentValidationError) Reason() string

+ type ScopedRouteConfiguration_Key_Fragment_StringKey struct

+ StringKey string

+ type ScopedRoutesDiscoveryServiceClient interface

+ DeltaScopedRoutes func(ctx context.Context, opts ...grpc.CallOption) (ScopedRoutesDiscoveryService_DeltaScopedRoutesClient, error)

+ FetchScopedRoutes func(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error)

+ StreamScopedRoutes func(ctx context.Context, opts ...grpc.CallOption) (ScopedRoutesDiscoveryService_StreamScopedRoutesClient, error)

+ func NewScopedRoutesDiscoveryServiceClient(cc grpc.ClientConnInterface) ScopedRoutesDiscoveryServiceClient

+ type ScopedRoutesDiscoveryServiceServer interface

+ DeltaScopedRoutes func(ScopedRoutesDiscoveryService_DeltaScopedRoutesServer) error

+ FetchScopedRoutes func(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)

+ StreamScopedRoutes func(ScopedRoutesDiscoveryService_StreamScopedRoutesServer) error

+ type ScopedRoutesDiscoveryService_DeltaScopedRoutesClient interface

+ Recv func() (*DeltaDiscoveryResponse, error)

+ Send func(*DeltaDiscoveryRequest) error

+ type ScopedRoutesDiscoveryService_DeltaScopedRoutesServer interface

+ Recv func() (*DeltaDiscoveryRequest, error)

+ Send func(*DeltaDiscoveryResponse) error

+ type ScopedRoutesDiscoveryService_StreamScopedRoutesClient interface

+ Recv func() (*DiscoveryResponse, error)

+ Send func(*DiscoveryRequest) error

+ type ScopedRoutesDiscoveryService_StreamScopedRoutesServer interface

+ Recv func() (*DiscoveryRequest, error)

+ Send func(*DiscoveryResponse) error

+ type SrdsDummy struct

+ func (*SrdsDummy) Descriptor() ([]byte, []int)

+ func (*SrdsDummy) ProtoMessage()

+ func (m *SrdsDummy) Validate() error

+ func (x *SrdsDummy) ProtoReflect() protoreflect.Message

+ func (x *SrdsDummy) Reset()

+ func (x *SrdsDummy) String() string

+ type SrdsDummyValidationError struct

+ func (e SrdsDummyValidationError) Cause() error

+ func (e SrdsDummyValidationError) Error() string

+ func (e SrdsDummyValidationError) ErrorName() string

+ func (e SrdsDummyValidationError) Field() string

+ func (e SrdsDummyValidationError) Key() bool

+ func (e SrdsDummyValidationError) Reason() string

+ type UnimplementedClusterDiscoveryServiceServer struct

+ func (*UnimplementedClusterDiscoveryServiceServer) DeltaClusters(ClusterDiscoveryService_DeltaClustersServer) error

+ func (*UnimplementedClusterDiscoveryServiceServer) FetchClusters(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)

+ func (*UnimplementedClusterDiscoveryServiceServer) StreamClusters(ClusterDiscoveryService_StreamClustersServer) error

+ type UnimplementedEndpointDiscoveryServiceServer struct

+ func (*UnimplementedEndpointDiscoveryServiceServer) DeltaEndpoints(EndpointDiscoveryService_DeltaEndpointsServer) error

+ func (*UnimplementedEndpointDiscoveryServiceServer) FetchEndpoints(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)

+ func (*UnimplementedEndpointDiscoveryServiceServer) StreamEndpoints(EndpointDiscoveryService_StreamEndpointsServer) error

+ type UnimplementedListenerDiscoveryServiceServer struct

+ func (*UnimplementedListenerDiscoveryServiceServer) DeltaListeners(ListenerDiscoveryService_DeltaListenersServer) error

+ func (*UnimplementedListenerDiscoveryServiceServer) FetchListeners(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)

+ func (*UnimplementedListenerDiscoveryServiceServer) StreamListeners(ListenerDiscoveryService_StreamListenersServer) error

+ type UnimplementedRouteDiscoveryServiceServer struct

+ func (*UnimplementedRouteDiscoveryServiceServer) DeltaRoutes(RouteDiscoveryService_DeltaRoutesServer) error

+ func (*UnimplementedRouteDiscoveryServiceServer) FetchRoutes(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)

+ func (*UnimplementedRouteDiscoveryServiceServer) StreamRoutes(RouteDiscoveryService_StreamRoutesServer) error

+ type UnimplementedScopedRoutesDiscoveryServiceServer struct

+ func (*UnimplementedScopedRoutesDiscoveryServiceServer) DeltaScopedRoutes(ScopedRoutesDiscoveryService_DeltaScopedRoutesServer) error

+ func (*UnimplementedScopedRoutesDiscoveryServiceServer) FetchScopedRoutes(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)

+ func (*UnimplementedScopedRoutesDiscoveryServiceServer) StreamScopedRoutes(ScopedRoutesDiscoveryService_StreamScopedRoutesServer) error

+ type UnimplementedVirtualHostDiscoveryServiceServer struct

+ func (*UnimplementedVirtualHostDiscoveryServiceServer) DeltaVirtualHosts(VirtualHostDiscoveryService_DeltaVirtualHostsServer) error

type UpstreamBindConfig

+ func (x *UpstreamBindConfig) ProtoReflect() protoreflect.Message

type UpstreamConnectionOptions

+ func (x *UpstreamConnectionOptions) ProtoReflect() protoreflect.Message

type Vhds

+ func (x *Vhds) ProtoReflect() protoreflect.Message

v0.7.1

Apr 19, 2019

Changes in this version

type ClusterLoadAssignment_Policy

+ EndpointStaleAfter *types.Duration

+ func (m *ClusterLoadAssignment_Policy) GetEndpointStaleAfter() *types.Duration

v0.7.0

Apr 8, 2019

Changes in this version

+ func RegisterVirtualHostDiscoveryServiceServer(s *grpc.Server, srv VirtualHostDiscoveryServiceServer)

type ClusterLoadAssignmentValidationError

+ func (e ClusterLoadAssignmentValidationError) ErrorName() string

type ClusterLoadAssignment_PolicyValidationError

+ func (e ClusterLoadAssignment_PolicyValidationError) ErrorName() string

type ClusterLoadAssignment_Policy_DropOverloadValidationError

+ func (e ClusterLoadAssignment_Policy_DropOverloadValidationError) ErrorName() string

type ClusterValidationError

+ func (e ClusterValidationError) ErrorName() string

type Cluster_CommonLbConfigValidationError

+ func (e Cluster_CommonLbConfigValidationError) ErrorName() string

type Cluster_CommonLbConfig_LocalityWeightedLbConfigValidationError

+ func (e Cluster_CommonLbConfig_LocalityWeightedLbConfigValidationError) ErrorName() string

type Cluster_CommonLbConfig_ZoneAwareLbConfigValidationError

+ func (e Cluster_CommonLbConfig_ZoneAwareLbConfigValidationError) ErrorName() string

type Cluster_CustomClusterTypeValidationError

+ func (e Cluster_CustomClusterTypeValidationError) ErrorName() string

type Cluster_EdsClusterConfigValidationError

+ func (e Cluster_EdsClusterConfigValidationError) ErrorName() string

type Cluster_LbSubsetConfigValidationError

+ func (e Cluster_LbSubsetConfigValidationError) ErrorName() string

type Cluster_LbSubsetConfig_LbSubsetSelectorValidationError

+ func (e Cluster_LbSubsetConfig_LbSubsetSelectorValidationError) ErrorName() string

type Cluster_LeastRequestLbConfigValidationError

+ func (e Cluster_LeastRequestLbConfigValidationError) ErrorName() string

type Cluster_OriginalDstLbConfigValidationError

+ func (e Cluster_OriginalDstLbConfigValidationError) ErrorName() string

type Cluster_RingHashLbConfigValidationError

+ func (e Cluster_RingHashLbConfigValidationError) ErrorName() string

type DeltaDiscoveryRequestValidationError

+ func (e DeltaDiscoveryRequestValidationError) ErrorName() string

type DeltaDiscoveryResponseValidationError

+ func (e DeltaDiscoveryResponseValidationError) ErrorName() string

type DiscoveryRequestValidationError

+ func (e DiscoveryRequestValidationError) ErrorName() string

type DiscoveryResponseValidationError

+ func (e DiscoveryResponseValidationError) ErrorName() string

type ListenerValidationError

+ func (e ListenerValidationError) ErrorName() string

type Listener_DeprecatedV1ValidationError

+ func (e Listener_DeprecatedV1ValidationError) ErrorName() string

type Resource

+ Aliases []string

+ func (m *Resource) GetAliases() []string

type ResourceValidationError

+ func (e ResourceValidationError) ErrorName() string

type RouteConfiguration

+ Vhds *Vhds

+ func (m *RouteConfiguration) GetVhds() *Vhds

type RouteConfigurationValidationError

+ func (e RouteConfigurationValidationError) ErrorName() string

type UpstreamBindConfigValidationError

+ func (e UpstreamBindConfigValidationError) ErrorName() string

type UpstreamConnectionOptionsValidationError

+ func (e UpstreamConnectionOptionsValidationError) ErrorName() string

+ type Vhds struct

+ ConfigSource core.ConfigSource

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Vhds) Descriptor() ([]byte, []int)

+ func (*Vhds) ProtoMessage()

+ func (m *Vhds) GetConfigSource() core.ConfigSource

+ func (m *Vhds) Marshal() (dAtA []byte, err error)

+ func (m *Vhds) MarshalTo(dAtA []byte) (int, error)

+ func (m *Vhds) Reset()

+ func (m *Vhds) Size() (n int)

+ func (m *Vhds) String() string

+ func (m *Vhds) Unmarshal(dAtA []byte) error

+ func (m *Vhds) Validate() error

+ func (m *Vhds) XXX_DiscardUnknown()

+ func (m *Vhds) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Vhds) XXX_Merge(src proto.Message)

+ func (m *Vhds) XXX_Size() int

+ func (m *Vhds) XXX_Unmarshal(b []byte) error

+ func (this *Vhds) Equal(that interface{}) bool

+ type VhdsValidationError struct

+ func (e VhdsValidationError) Cause() error

+ func (e VhdsValidationError) Error() string

+ func (e VhdsValidationError) ErrorName() string

+ func (e VhdsValidationError) Field() string

+ func (e VhdsValidationError) Key() bool

+ func (e VhdsValidationError) Reason() string

+ type VirtualHostDiscoveryServiceClient interface

+ DeltaVirtualHosts func(ctx context.Context, opts ...grpc.CallOption) (VirtualHostDiscoveryService_DeltaVirtualHostsClient, error)

+ func NewVirtualHostDiscoveryServiceClient(cc *grpc.ClientConn) VirtualHostDiscoveryServiceClient

+ type VirtualHostDiscoveryServiceServer interface

+ DeltaVirtualHosts func(VirtualHostDiscoveryService_DeltaVirtualHostsServer) error

+ type VirtualHostDiscoveryService_DeltaVirtualHostsClient interface

+ Recv func() (*DeltaDiscoveryResponse, error)

+ Send func(*DeltaDiscoveryRequest) error

+ type VirtualHostDiscoveryService_DeltaVirtualHostsServer interface

+ Recv func() (*DeltaDiscoveryRequest, error)

+ Send func(*DeltaDiscoveryResponse) error

v0.6.9

Mar 11, 2019

Changes in this version

type Cluster

+ ClusterDiscoveryType isCluster_ClusterDiscoveryType

+ func (m *Cluster) GetClusterDiscoveryType() isCluster_ClusterDiscoveryType

+ func (m *Cluster) GetClusterType() *Cluster_CustomClusterType

type ClusterDiscoveryServiceClient

+ DeltaClusters func(ctx context.Context, opts ...grpc.CallOption) (ClusterDiscoveryService_DeltaClustersClient, error)

type ClusterDiscoveryServiceServer

+ DeltaClusters func(ClusterDiscoveryService_DeltaClustersServer) error

+ type ClusterDiscoveryService_DeltaClustersClient interface

+ Recv func() (*DeltaDiscoveryResponse, error)

+ Send func(*DeltaDiscoveryRequest) error

+ type ClusterDiscoveryService_DeltaClustersServer interface

+ Recv func() (*DeltaDiscoveryRequest, error)

+ Send func(*DeltaDiscoveryResponse) error

+ type Cluster_ClusterType struct

+ ClusterType *Cluster_CustomClusterType

+ func (m *Cluster_ClusterType) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_ClusterType) Size() (n int)

+ func (this *Cluster_ClusterType) Equal(that interface{}) bool

+ type Cluster_CustomClusterType struct

+ Name string

+ TypedConfig *types.Any

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cluster_CustomClusterType) Descriptor() ([]byte, []int)

+ func (*Cluster_CustomClusterType) ProtoMessage()

+ func (m *Cluster_CustomClusterType) GetName() string

+ func (m *Cluster_CustomClusterType) GetTypedConfig() *types.Any

+ func (m *Cluster_CustomClusterType) Marshal() (dAtA []byte, err error)

+ func (m *Cluster_CustomClusterType) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_CustomClusterType) Reset()

+ func (m *Cluster_CustomClusterType) Size() (n int)

+ func (m *Cluster_CustomClusterType) String() string

+ func (m *Cluster_CustomClusterType) Unmarshal(dAtA []byte) error

+ func (m *Cluster_CustomClusterType) Validate() error

+ func (m *Cluster_CustomClusterType) XXX_DiscardUnknown()

+ func (m *Cluster_CustomClusterType) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster_CustomClusterType) XXX_Merge(src proto.Message)

+ func (m *Cluster_CustomClusterType) XXX_Size() int

+ func (m *Cluster_CustomClusterType) XXX_Unmarshal(b []byte) error

+ func (this *Cluster_CustomClusterType) Equal(that interface{}) bool

+ type Cluster_CustomClusterTypeValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e Cluster_CustomClusterTypeValidationError) Error() string

type Cluster_LbSubsetConfig

+ PanicModeAny bool

+ func (m *Cluster_LbSubsetConfig) GetPanicModeAny() bool

+ type Cluster_Type struct

+ Type Cluster_DiscoveryType

+ func (m *Cluster_Type) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_Type) Size() (n int)

+ func (this *Cluster_Type) Equal(that interface{}) bool

+ type DeltaDiscoveryRequest struct

+ ErrorDetail *rpc.Status

+ InitialResourceVersions map[string]string

+ Node *core.Node

+ ResourceNamesSubscribe []string

+ ResourceNamesUnsubscribe []string

+ ResponseNonce string

+ TypeUrl string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeltaDiscoveryRequest) Descriptor() ([]byte, []int)

+ func (*DeltaDiscoveryRequest) ProtoMessage()

+ func (m *DeltaDiscoveryRequest) GetErrorDetail() *rpc.Status

+ func (m *DeltaDiscoveryRequest) GetInitialResourceVersions() map[string]string

+ func (m *DeltaDiscoveryRequest) GetNode() *core.Node

+ func (m *DeltaDiscoveryRequest) GetResourceNamesSubscribe() []string

+ func (m *DeltaDiscoveryRequest) GetResourceNamesUnsubscribe() []string

+ func (m *DeltaDiscoveryRequest) GetResponseNonce() string

+ func (m *DeltaDiscoveryRequest) GetTypeUrl() string

+ func (m *DeltaDiscoveryRequest) Marshal() (dAtA []byte, err error)

+ func (m *DeltaDiscoveryRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeltaDiscoveryRequest) Reset()

+ func (m *DeltaDiscoveryRequest) Size() (n int)

+ func (m *DeltaDiscoveryRequest) String() string

+ func (m *DeltaDiscoveryRequest) Unmarshal(dAtA []byte) error

+ func (m *DeltaDiscoveryRequest) Validate() error

+ func (m *DeltaDiscoveryRequest) XXX_DiscardUnknown()

+ func (m *DeltaDiscoveryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeltaDiscoveryRequest) XXX_Merge(src proto.Message)

+ func (m *DeltaDiscoveryRequest) XXX_Size() int

+ func (m *DeltaDiscoveryRequest) XXX_Unmarshal(b []byte) error

+ func (this *DeltaDiscoveryRequest) Equal(that interface{}) bool

+ type DeltaDiscoveryRequestValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e DeltaDiscoveryRequestValidationError) Error() string

+ type DeltaDiscoveryResponse struct

+ Nonce string

+ RemovedResources []string

+ Resources []Resource

+ SystemVersionInfo string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DeltaDiscoveryResponse) Descriptor() ([]byte, []int)

+ func (*DeltaDiscoveryResponse) ProtoMessage()

+ func (m *DeltaDiscoveryResponse) GetNonce() string

+ func (m *DeltaDiscoveryResponse) GetRemovedResources() []string

+ func (m *DeltaDiscoveryResponse) GetResources() []Resource

+ func (m *DeltaDiscoveryResponse) GetSystemVersionInfo() string

+ func (m *DeltaDiscoveryResponse) Marshal() (dAtA []byte, err error)

+ func (m *DeltaDiscoveryResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DeltaDiscoveryResponse) Reset()

+ func (m *DeltaDiscoveryResponse) Size() (n int)

+ func (m *DeltaDiscoveryResponse) String() string

+ func (m *DeltaDiscoveryResponse) Unmarshal(dAtA []byte) error

+ func (m *DeltaDiscoveryResponse) Validate() error

+ func (m *DeltaDiscoveryResponse) XXX_DiscardUnknown()

+ func (m *DeltaDiscoveryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DeltaDiscoveryResponse) XXX_Merge(src proto.Message)

+ func (m *DeltaDiscoveryResponse) XXX_Size() int

+ func (m *DeltaDiscoveryResponse) XXX_Unmarshal(b []byte) error

+ func (this *DeltaDiscoveryResponse) Equal(that interface{}) bool

+ type DeltaDiscoveryResponseValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e DeltaDiscoveryResponseValidationError) Error() string

type Resource

+ Name string

+ func (m *Resource) GetName() string

type RouteDiscoveryServiceClient

+ DeltaRoutes func(ctx context.Context, opts ...grpc.CallOption) (RouteDiscoveryService_DeltaRoutesClient, error)

type RouteDiscoveryServiceServer

+ DeltaRoutes func(RouteDiscoveryService_DeltaRoutesServer) error

+ type RouteDiscoveryService_DeltaRoutesClient interface

+ Recv func() (*DeltaDiscoveryResponse, error)

+ Send func(*DeltaDiscoveryRequest) error

+ type RouteDiscoveryService_DeltaRoutesServer interface

+ Recv func() (*DeltaDiscoveryRequest, error)

+ Send func(*DeltaDiscoveryResponse) error

v0.6.8

Mar 1, 2019

Changes in this version

type Cluster_RingHashLbConfig

+ MaximumRingSize *types.UInt64Value

+ func (m *Cluster_RingHashLbConfig) GetMaximumRingSize() *types.UInt64Value

type DiscoveryResponse

+ ControlPlane *core.ControlPlane

+ func (m *DiscoveryResponse) GetControlPlane() *core.ControlPlane

v0.6.7

Jan 25, 2019

Changes in this version

+ var Cluster_RingHashLbConfig_HashFunction_name = map[int32]string

+ var Cluster_RingHashLbConfig_HashFunction_value = map[string]int32

type ClusterLoadAssignment

+ NamedEndpoints map[string]*endpoint.Endpoint

+ func (m *ClusterLoadAssignment) GetNamedEndpoints() map[string]*endpoint.Endpoint

type Cluster_RingHashLbConfig

+ HashFunction Cluster_RingHashLbConfig_HashFunction

+ func (m *Cluster_RingHashLbConfig) GetHashFunction() Cluster_RingHashLbConfig_HashFunction

+ type Cluster_RingHashLbConfig_HashFunction int32

+ const Cluster_RingHashLbConfig_MURMUR_HASH_2

+ const Cluster_RingHashLbConfig_XX_HASH

+ func (Cluster_RingHashLbConfig_HashFunction) EnumDescriptor() ([]byte, []int)

+ func (x Cluster_RingHashLbConfig_HashFunction) String() string

v0.6.6

Jan 4, 2019

v0.6.5

Dec 21, 2018

v0.6.4

Dec 21, 2018

Changes in this version

type Cluster

+ func (m *Cluster) GetLeastRequestLbConfig() *Cluster_LeastRequestLbConfig

type Cluster_LbSubsetConfig

+ ScaleLocalityWeight bool

+ func (m *Cluster_LbSubsetConfig) GetScaleLocalityWeight() bool

+ type Cluster_LeastRequestLbConfig struct

+ ChoiceCount *types.UInt32Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cluster_LeastRequestLbConfig) Descriptor() ([]byte, []int)

+ func (*Cluster_LeastRequestLbConfig) ProtoMessage()

+ func (dst *Cluster_LeastRequestLbConfig) XXX_Merge(src proto.Message)

+ func (m *Cluster_LeastRequestLbConfig) GetChoiceCount() *types.UInt32Value

+ func (m *Cluster_LeastRequestLbConfig) Marshal() (dAtA []byte, err error)

+ func (m *Cluster_LeastRequestLbConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_LeastRequestLbConfig) Reset()

+ func (m *Cluster_LeastRequestLbConfig) Size() (n int)

+ func (m *Cluster_LeastRequestLbConfig) String() string

+ func (m *Cluster_LeastRequestLbConfig) Unmarshal(dAtA []byte) error

+ func (m *Cluster_LeastRequestLbConfig) Validate() error

+ func (m *Cluster_LeastRequestLbConfig) XXX_DiscardUnknown()

+ func (m *Cluster_LeastRequestLbConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster_LeastRequestLbConfig) XXX_Size() int

+ func (m *Cluster_LeastRequestLbConfig) XXX_Unmarshal(b []byte) error

+ func (this *Cluster_LeastRequestLbConfig) Equal(that interface{}) bool

+ type Cluster_LeastRequestLbConfigValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e Cluster_LeastRequestLbConfigValidationError) Error() string

+ type Cluster_LeastRequestLbConfig_ struct

+ LeastRequestLbConfig *Cluster_LeastRequestLbConfig

+ func (m *Cluster_LeastRequestLbConfig_) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_LeastRequestLbConfig_) Size() (n int)

+ func (this *Cluster_LeastRequestLbConfig_) Equal(that interface{}) bool

type Listener

+ ListenerFiltersTimeout *time.Duration

+ func (m *Listener) GetListenerFiltersTimeout() *time.Duration

v0.6.3

Nov 12, 2018

Changes in this version

type Cluster

+ TypedExtensionProtocolOptions map[string]*types.Any

+ func (m *Cluster) GetTypedExtensionProtocolOptions() map[string]*types.Any

type Listener

+ BugfixReverseWriteFilterOrder *types.BoolValue

+ func (m *Listener) GetBugfixReverseWriteFilterOrder() *types.BoolValue

v0.6.2

Nov 6, 2018

v0.6.1

Oct 15, 2018

v0.6.0

Sep 25, 2018

Changes in this version

type ClusterLoadAssignment_Policy

+ OverprovisioningFactor *types.UInt32Value

+ func (m *ClusterLoadAssignment_Policy) GetOverprovisioningFactor() *types.UInt32Value

type RouteConfiguration

+ RequestHeadersToRemove []string

+ func (m *RouteConfiguration) GetRequestHeadersToRemove() []string

v0.5.0

Aug 14, 2018

Changes in this version

+ var Cluster_ClusterProtocolSelection_name = map[int32]string

+ var Cluster_ClusterProtocolSelection_value = map[string]int32

+ var Cluster_DiscoveryType_name = map[int32]string

+ var Cluster_DiscoveryType_value = map[string]int32

+ var Cluster_DnsLookupFamily_name = map[int32]string

+ var Cluster_DnsLookupFamily_value = map[string]int32

+ var Cluster_LbPolicy_name = map[int32]string

+ var Cluster_LbPolicy_value = map[string]int32

+ var Cluster_LbSubsetConfig_LbSubsetFallbackPolicy_name = map[int32]string

+ var Cluster_LbSubsetConfig_LbSubsetFallbackPolicy_value = map[string]int32

+ var ErrIntOverflowCds = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowDiscovery = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowEds = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowLds = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowRds = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthCds = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthDiscovery = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthEds = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthLds = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthRds = fmt.Errorf("proto: negative length found during unmarshaling")

+ var Listener_DrainType_name = map[int32]string

+ var Listener_DrainType_value = map[string]int32

+ func RegisterClusterDiscoveryServiceServer(s *grpc.Server, srv ClusterDiscoveryServiceServer)

+ func RegisterEndpointDiscoveryServiceServer(s *grpc.Server, srv EndpointDiscoveryServiceServer)

+ func RegisterListenerDiscoveryServiceServer(s *grpc.Server, srv ListenerDiscoveryServiceServer)

+ func RegisterRouteDiscoveryServiceServer(s *grpc.Server, srv RouteDiscoveryServiceServer)

+ type Cluster struct

+ AltStatName string

+ CircuitBreakers *cluster.CircuitBreakers

+ CleanupInterval *time.Duration

+ CloseConnectionsOnHostHealthFailure bool

+ CommonHttpProtocolOptions *core.HttpProtocolOptions

+ CommonLbConfig *Cluster_CommonLbConfig

+ ConnectTimeout time.Duration

+ DnsLookupFamily Cluster_DnsLookupFamily

+ DnsRefreshRate *time.Duration

+ DnsResolvers []*core.Address

+ DrainConnectionsOnHostRemoval bool

+ EdsClusterConfig *Cluster_EdsClusterConfig

+ ExtensionProtocolOptions map[string]*types.Struct

+ HealthChecks []*core.HealthCheck

+ Hosts []*core.Address

+ Http2ProtocolOptions *core.Http2ProtocolOptions

+ HttpProtocolOptions *core.Http1ProtocolOptions

+ LbConfig isCluster_LbConfig

+ LbPolicy Cluster_LbPolicy

+ LbSubsetConfig *Cluster_LbSubsetConfig

+ LoadAssignment *ClusterLoadAssignment

+ MaxRequestsPerConnection *types.UInt32Value

+ Metadata *core.Metadata

+ Name string

+ OutlierDetection *cluster.OutlierDetection

+ PerConnectionBufferLimitBytes *types.UInt32Value

+ ProtocolSelection Cluster_ClusterProtocolSelection

+ TlsContext *auth.UpstreamTlsContext

+ TransportSocket *core.TransportSocket

+ Type Cluster_DiscoveryType

+ UpstreamBindConfig *core.BindConfig

+ UpstreamConnectionOptions *UpstreamConnectionOptions

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cluster) Descriptor() ([]byte, []int)

+ func (*Cluster) ProtoMessage()

+ func (*Cluster) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *Cluster) XXX_Merge(src proto.Message)

+ func (m *Cluster) GetAltStatName() string

+ func (m *Cluster) GetCircuitBreakers() *cluster.CircuitBreakers

+ func (m *Cluster) GetCleanupInterval() *time.Duration

+ func (m *Cluster) GetCloseConnectionsOnHostHealthFailure() bool

+ func (m *Cluster) GetCommonHttpProtocolOptions() *core.HttpProtocolOptions

+ func (m *Cluster) GetCommonLbConfig() *Cluster_CommonLbConfig

+ func (m *Cluster) GetConnectTimeout() time.Duration

+ func (m *Cluster) GetDnsLookupFamily() Cluster_DnsLookupFamily

+ func (m *Cluster) GetDnsRefreshRate() *time.Duration

+ func (m *Cluster) GetDnsResolvers() []*core.Address

+ func (m *Cluster) GetDrainConnectionsOnHostRemoval() bool

+ func (m *Cluster) GetEdsClusterConfig() *Cluster_EdsClusterConfig

+ func (m *Cluster) GetExtensionProtocolOptions() map[string]*types.Struct

+ func (m *Cluster) GetHealthChecks() []*core.HealthCheck

+ func (m *Cluster) GetHosts() []*core.Address

+ func (m *Cluster) GetHttp2ProtocolOptions() *core.Http2ProtocolOptions

+ func (m *Cluster) GetHttpProtocolOptions() *core.Http1ProtocolOptions

+ func (m *Cluster) GetLbConfig() isCluster_LbConfig

+ func (m *Cluster) GetLbPolicy() Cluster_LbPolicy

+ func (m *Cluster) GetLbSubsetConfig() *Cluster_LbSubsetConfig

+ func (m *Cluster) GetLoadAssignment() *ClusterLoadAssignment

+ func (m *Cluster) GetMaxRequestsPerConnection() *types.UInt32Value

+ func (m *Cluster) GetMetadata() *core.Metadata

+ func (m *Cluster) GetName() string

+ func (m *Cluster) GetOriginalDstLbConfig() *Cluster_OriginalDstLbConfig

+ func (m *Cluster) GetOutlierDetection() *cluster.OutlierDetection

+ func (m *Cluster) GetPerConnectionBufferLimitBytes() *types.UInt32Value

+ func (m *Cluster) GetProtocolSelection() Cluster_ClusterProtocolSelection

+ func (m *Cluster) GetRingHashLbConfig() *Cluster_RingHashLbConfig

+ func (m *Cluster) GetTlsContext() *auth.UpstreamTlsContext

+ func (m *Cluster) GetTransportSocket() *core.TransportSocket

+ func (m *Cluster) GetType() Cluster_DiscoveryType

+ func (m *Cluster) GetUpstreamBindConfig() *core.BindConfig

+ func (m *Cluster) GetUpstreamConnectionOptions() *UpstreamConnectionOptions

+ func (m *Cluster) Marshal() (dAtA []byte, err error)

+ func (m *Cluster) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster) Reset()

+ func (m *Cluster) Size() (n int)

+ func (m *Cluster) String() string

+ func (m *Cluster) Unmarshal(dAtA []byte) error

+ func (m *Cluster) Validate() error

+ func (m *Cluster) XXX_DiscardUnknown()

+ func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster) XXX_Size() int

+ func (m *Cluster) XXX_Unmarshal(b []byte) error

+ func (this *Cluster) Equal(that interface{}) bool

+ type ClusterDiscoveryServiceClient interface

+ FetchClusters func(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error)

+ IncrementalClusters func(ctx context.Context, opts ...grpc.CallOption) (ClusterDiscoveryService_IncrementalClustersClient, error)

+ StreamClusters func(ctx context.Context, opts ...grpc.CallOption) (ClusterDiscoveryService_StreamClustersClient, error)

+ func NewClusterDiscoveryServiceClient(cc *grpc.ClientConn) ClusterDiscoveryServiceClient

+ type ClusterDiscoveryServiceServer interface

+ FetchClusters func(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)

+ IncrementalClusters func(ClusterDiscoveryService_IncrementalClustersServer) error

+ StreamClusters func(ClusterDiscoveryService_StreamClustersServer) error

+ type ClusterDiscoveryService_IncrementalClustersClient interface

+ Recv func() (*IncrementalDiscoveryResponse, error)

+ Send func(*IncrementalDiscoveryRequest) error

+ type ClusterDiscoveryService_IncrementalClustersServer interface

+ Recv func() (*IncrementalDiscoveryRequest, error)

+ Send func(*IncrementalDiscoveryResponse) error

+ type ClusterDiscoveryService_StreamClustersClient interface

+ Recv func() (*DiscoveryResponse, error)

+ Send func(*DiscoveryRequest) error

+ type ClusterDiscoveryService_StreamClustersServer interface

+ Recv func() (*DiscoveryRequest, error)

+ Send func(*DiscoveryResponse) error

+ type ClusterLoadAssignment struct

+ ClusterName string

+ Endpoints []endpoint.LocalityLbEndpoints

+ Policy *ClusterLoadAssignment_Policy

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClusterLoadAssignment) Descriptor() ([]byte, []int)

+ func (*ClusterLoadAssignment) ProtoMessage()

+ func (dst *ClusterLoadAssignment) XXX_Merge(src proto.Message)

+ func (m *ClusterLoadAssignment) GetClusterName() string

+ func (m *ClusterLoadAssignment) GetEndpoints() []endpoint.LocalityLbEndpoints

+ func (m *ClusterLoadAssignment) GetPolicy() *ClusterLoadAssignment_Policy

+ func (m *ClusterLoadAssignment) Marshal() (dAtA []byte, err error)

+ func (m *ClusterLoadAssignment) MarshalTo(dAtA []byte) (int, error)

+ func (m *ClusterLoadAssignment) Reset()

+ func (m *ClusterLoadAssignment) Size() (n int)

+ func (m *ClusterLoadAssignment) String() string

+ func (m *ClusterLoadAssignment) Unmarshal(dAtA []byte) error

+ func (m *ClusterLoadAssignment) Validate() error

+ func (m *ClusterLoadAssignment) XXX_DiscardUnknown()

+ func (m *ClusterLoadAssignment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ClusterLoadAssignment) XXX_Size() int

+ func (m *ClusterLoadAssignment) XXX_Unmarshal(b []byte) error

+ func (this *ClusterLoadAssignment) Equal(that interface{}) bool

+ type ClusterLoadAssignmentValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e ClusterLoadAssignmentValidationError) Error() string

+ type ClusterLoadAssignment_Policy struct

+ DropOverloads []*ClusterLoadAssignment_Policy_DropOverload

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClusterLoadAssignment_Policy) Descriptor() ([]byte, []int)

+ func (*ClusterLoadAssignment_Policy) ProtoMessage()

+ func (dst *ClusterLoadAssignment_Policy) XXX_Merge(src proto.Message)

+ func (m *ClusterLoadAssignment_Policy) GetDropOverloads() []*ClusterLoadAssignment_Policy_DropOverload

+ func (m *ClusterLoadAssignment_Policy) Marshal() (dAtA []byte, err error)

+ func (m *ClusterLoadAssignment_Policy) MarshalTo(dAtA []byte) (int, error)

+ func (m *ClusterLoadAssignment_Policy) Reset()

+ func (m *ClusterLoadAssignment_Policy) Size() (n int)

+ func (m *ClusterLoadAssignment_Policy) String() string

+ func (m *ClusterLoadAssignment_Policy) Unmarshal(dAtA []byte) error

+ func (m *ClusterLoadAssignment_Policy) Validate() error

+ func (m *ClusterLoadAssignment_Policy) XXX_DiscardUnknown()

+ func (m *ClusterLoadAssignment_Policy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ClusterLoadAssignment_Policy) XXX_Size() int

+ func (m *ClusterLoadAssignment_Policy) XXX_Unmarshal(b []byte) error

+ func (this *ClusterLoadAssignment_Policy) Equal(that interface{}) bool

+ type ClusterLoadAssignment_PolicyValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e ClusterLoadAssignment_PolicyValidationError) Error() string

+ type ClusterLoadAssignment_Policy_DropOverload struct

+ Category string

+ DropPercentage *_type.FractionalPercent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*ClusterLoadAssignment_Policy_DropOverload) Descriptor() ([]byte, []int)

+ func (*ClusterLoadAssignment_Policy_DropOverload) ProtoMessage()

+ func (dst *ClusterLoadAssignment_Policy_DropOverload) XXX_Merge(src proto.Message)

+ func (m *ClusterLoadAssignment_Policy_DropOverload) GetCategory() string

+ func (m *ClusterLoadAssignment_Policy_DropOverload) GetDropPercentage() *_type.FractionalPercent

+ func (m *ClusterLoadAssignment_Policy_DropOverload) Marshal() (dAtA []byte, err error)

+ func (m *ClusterLoadAssignment_Policy_DropOverload) MarshalTo(dAtA []byte) (int, error)

+ func (m *ClusterLoadAssignment_Policy_DropOverload) Reset()

+ func (m *ClusterLoadAssignment_Policy_DropOverload) Size() (n int)

+ func (m *ClusterLoadAssignment_Policy_DropOverload) String() string

+ func (m *ClusterLoadAssignment_Policy_DropOverload) Unmarshal(dAtA []byte) error

+ func (m *ClusterLoadAssignment_Policy_DropOverload) Validate() error

+ func (m *ClusterLoadAssignment_Policy_DropOverload) XXX_DiscardUnknown()

+ func (m *ClusterLoadAssignment_Policy_DropOverload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ClusterLoadAssignment_Policy_DropOverload) XXX_Size() int

+ func (m *ClusterLoadAssignment_Policy_DropOverload) XXX_Unmarshal(b []byte) error

+ func (this *ClusterLoadAssignment_Policy_DropOverload) Equal(that interface{}) bool

+ type ClusterLoadAssignment_Policy_DropOverloadValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e ClusterLoadAssignment_Policy_DropOverloadValidationError) Error() string

+ type ClusterValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e ClusterValidationError) Error() string

+ type Cluster_ClusterProtocolSelection int32

+ const Cluster_USE_CONFIGURED_PROTOCOL

+ const Cluster_USE_DOWNSTREAM_PROTOCOL

+ func (Cluster_ClusterProtocolSelection) EnumDescriptor() ([]byte, []int)

+ func (x Cluster_ClusterProtocolSelection) String() string

+ type Cluster_CommonLbConfig struct

+ HealthyPanicThreshold *_type.Percent

+ LocalityConfigSpecifier isCluster_CommonLbConfig_LocalityConfigSpecifier

+ UpdateMergeWindow *types.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cluster_CommonLbConfig) Descriptor() ([]byte, []int)

+ func (*Cluster_CommonLbConfig) ProtoMessage()

+ func (*Cluster_CommonLbConfig) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (dst *Cluster_CommonLbConfig) XXX_Merge(src proto.Message)

+ func (m *Cluster_CommonLbConfig) GetHealthyPanicThreshold() *_type.Percent

+ func (m *Cluster_CommonLbConfig) GetLocalityConfigSpecifier() isCluster_CommonLbConfig_LocalityConfigSpecifier

+ func (m *Cluster_CommonLbConfig) GetLocalityWeightedLbConfig() *Cluster_CommonLbConfig_LocalityWeightedLbConfig

+ func (m *Cluster_CommonLbConfig) GetUpdateMergeWindow() *types.Duration

+ func (m *Cluster_CommonLbConfig) GetZoneAwareLbConfig() *Cluster_CommonLbConfig_ZoneAwareLbConfig

+ func (m *Cluster_CommonLbConfig) Marshal() (dAtA []byte, err error)

+ func (m *Cluster_CommonLbConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_CommonLbConfig) Reset()

+ func (m *Cluster_CommonLbConfig) Size() (n int)

+ func (m *Cluster_CommonLbConfig) String() string

+ func (m *Cluster_CommonLbConfig) Unmarshal(dAtA []byte) error

+ func (m *Cluster_CommonLbConfig) Validate() error

+ func (m *Cluster_CommonLbConfig) XXX_DiscardUnknown()

+ func (m *Cluster_CommonLbConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster_CommonLbConfig) XXX_Size() int

+ func (m *Cluster_CommonLbConfig) XXX_Unmarshal(b []byte) error

+ func (this *Cluster_CommonLbConfig) Equal(that interface{}) bool

+ type Cluster_CommonLbConfigValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e Cluster_CommonLbConfigValidationError) Error() string

+ type Cluster_CommonLbConfig_LocalityWeightedLbConfig struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cluster_CommonLbConfig_LocalityWeightedLbConfig) Descriptor() ([]byte, []int)

+ func (*Cluster_CommonLbConfig_LocalityWeightedLbConfig) ProtoMessage()

+ func (dst *Cluster_CommonLbConfig_LocalityWeightedLbConfig) XXX_Merge(src proto.Message)

+ func (m *Cluster_CommonLbConfig_LocalityWeightedLbConfig) Marshal() (dAtA []byte, err error)

+ func (m *Cluster_CommonLbConfig_LocalityWeightedLbConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_CommonLbConfig_LocalityWeightedLbConfig) Reset()

+ func (m *Cluster_CommonLbConfig_LocalityWeightedLbConfig) Size() (n int)

+ func (m *Cluster_CommonLbConfig_LocalityWeightedLbConfig) String() string

+ func (m *Cluster_CommonLbConfig_LocalityWeightedLbConfig) Unmarshal(dAtA []byte) error

+ func (m *Cluster_CommonLbConfig_LocalityWeightedLbConfig) Validate() error

+ func (m *Cluster_CommonLbConfig_LocalityWeightedLbConfig) XXX_DiscardUnknown()

+ func (m *Cluster_CommonLbConfig_LocalityWeightedLbConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster_CommonLbConfig_LocalityWeightedLbConfig) XXX_Size() int

+ func (m *Cluster_CommonLbConfig_LocalityWeightedLbConfig) XXX_Unmarshal(b []byte) error

+ func (this *Cluster_CommonLbConfig_LocalityWeightedLbConfig) Equal(that interface{}) bool

+ type Cluster_CommonLbConfig_LocalityWeightedLbConfigValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e Cluster_CommonLbConfig_LocalityWeightedLbConfigValidationError) Error() string

+ type Cluster_CommonLbConfig_LocalityWeightedLbConfig_ struct

+ LocalityWeightedLbConfig *Cluster_CommonLbConfig_LocalityWeightedLbConfig

+ func (m *Cluster_CommonLbConfig_LocalityWeightedLbConfig_) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_CommonLbConfig_LocalityWeightedLbConfig_) Size() (n int)

+ func (this *Cluster_CommonLbConfig_LocalityWeightedLbConfig_) Equal(that interface{}) bool

+ type Cluster_CommonLbConfig_ZoneAwareLbConfig struct

+ MinClusterSize *types.UInt64Value

+ RoutingEnabled *_type.Percent

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cluster_CommonLbConfig_ZoneAwareLbConfig) Descriptor() ([]byte, []int)

+ func (*Cluster_CommonLbConfig_ZoneAwareLbConfig) ProtoMessage()

+ func (dst *Cluster_CommonLbConfig_ZoneAwareLbConfig) XXX_Merge(src proto.Message)

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig) GetMinClusterSize() *types.UInt64Value

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig) GetRoutingEnabled() *_type.Percent

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig) Marshal() (dAtA []byte, err error)

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig) Reset()

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig) Size() (n int)

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig) String() string

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig) Unmarshal(dAtA []byte) error

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig) Validate() error

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig) XXX_DiscardUnknown()

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig) XXX_Size() int

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig) XXX_Unmarshal(b []byte) error

+ func (this *Cluster_CommonLbConfig_ZoneAwareLbConfig) Equal(that interface{}) bool

+ type Cluster_CommonLbConfig_ZoneAwareLbConfigValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e Cluster_CommonLbConfig_ZoneAwareLbConfigValidationError) Error() string

+ type Cluster_CommonLbConfig_ZoneAwareLbConfig_ struct

+ ZoneAwareLbConfig *Cluster_CommonLbConfig_ZoneAwareLbConfig

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig_) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_CommonLbConfig_ZoneAwareLbConfig_) Size() (n int)

+ func (this *Cluster_CommonLbConfig_ZoneAwareLbConfig_) Equal(that interface{}) bool

+ type Cluster_DiscoveryType int32

+ const Cluster_EDS

+ const Cluster_LOGICAL_DNS

+ const Cluster_ORIGINAL_DST

+ const Cluster_STATIC

+ const Cluster_STRICT_DNS

+ func (Cluster_DiscoveryType) EnumDescriptor() ([]byte, []int)

+ func (x Cluster_DiscoveryType) String() string

+ type Cluster_DnsLookupFamily int32

+ const Cluster_AUTO

+ const Cluster_V4_ONLY

+ const Cluster_V6_ONLY

+ func (Cluster_DnsLookupFamily) EnumDescriptor() ([]byte, []int)

+ func (x Cluster_DnsLookupFamily) String() string

+ type Cluster_EdsClusterConfig struct

+ EdsConfig *core.ConfigSource

+ ServiceName string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cluster_EdsClusterConfig) Descriptor() ([]byte, []int)

+ func (*Cluster_EdsClusterConfig) ProtoMessage()

+ func (dst *Cluster_EdsClusterConfig) XXX_Merge(src proto.Message)

+ func (m *Cluster_EdsClusterConfig) GetEdsConfig() *core.ConfigSource

+ func (m *Cluster_EdsClusterConfig) GetServiceName() string

+ func (m *Cluster_EdsClusterConfig) Marshal() (dAtA []byte, err error)

+ func (m *Cluster_EdsClusterConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_EdsClusterConfig) Reset()

+ func (m *Cluster_EdsClusterConfig) Size() (n int)

+ func (m *Cluster_EdsClusterConfig) String() string

+ func (m *Cluster_EdsClusterConfig) Unmarshal(dAtA []byte) error

+ func (m *Cluster_EdsClusterConfig) Validate() error

+ func (m *Cluster_EdsClusterConfig) XXX_DiscardUnknown()

+ func (m *Cluster_EdsClusterConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster_EdsClusterConfig) XXX_Size() int

+ func (m *Cluster_EdsClusterConfig) XXX_Unmarshal(b []byte) error

+ func (this *Cluster_EdsClusterConfig) Equal(that interface{}) bool

+ type Cluster_EdsClusterConfigValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e Cluster_EdsClusterConfigValidationError) Error() string

+ type Cluster_LbPolicy int32

+ const Cluster_LEAST_REQUEST

+ const Cluster_MAGLEV

+ const Cluster_ORIGINAL_DST_LB

+ const Cluster_RANDOM

+ const Cluster_RING_HASH

+ const Cluster_ROUND_ROBIN

+ func (Cluster_LbPolicy) EnumDescriptor() ([]byte, []int)

+ func (x Cluster_LbPolicy) String() string

+ type Cluster_LbSubsetConfig struct

+ DefaultSubset *types.Struct

+ FallbackPolicy Cluster_LbSubsetConfig_LbSubsetFallbackPolicy

+ LocalityWeightAware bool

+ SubsetSelectors []*Cluster_LbSubsetConfig_LbSubsetSelector

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cluster_LbSubsetConfig) Descriptor() ([]byte, []int)

+ func (*Cluster_LbSubsetConfig) ProtoMessage()

+ func (dst *Cluster_LbSubsetConfig) XXX_Merge(src proto.Message)

+ func (m *Cluster_LbSubsetConfig) GetDefaultSubset() *types.Struct

+ func (m *Cluster_LbSubsetConfig) GetFallbackPolicy() Cluster_LbSubsetConfig_LbSubsetFallbackPolicy

+ func (m *Cluster_LbSubsetConfig) GetLocalityWeightAware() bool

+ func (m *Cluster_LbSubsetConfig) GetSubsetSelectors() []*Cluster_LbSubsetConfig_LbSubsetSelector

+ func (m *Cluster_LbSubsetConfig) Marshal() (dAtA []byte, err error)

+ func (m *Cluster_LbSubsetConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_LbSubsetConfig) Reset()

+ func (m *Cluster_LbSubsetConfig) Size() (n int)

+ func (m *Cluster_LbSubsetConfig) String() string

+ func (m *Cluster_LbSubsetConfig) Unmarshal(dAtA []byte) error

+ func (m *Cluster_LbSubsetConfig) Validate() error

+ func (m *Cluster_LbSubsetConfig) XXX_DiscardUnknown()

+ func (m *Cluster_LbSubsetConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster_LbSubsetConfig) XXX_Size() int

+ func (m *Cluster_LbSubsetConfig) XXX_Unmarshal(b []byte) error

+ func (this *Cluster_LbSubsetConfig) Equal(that interface{}) bool

+ type Cluster_LbSubsetConfigValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e Cluster_LbSubsetConfigValidationError) Error() string

+ type Cluster_LbSubsetConfig_LbSubsetFallbackPolicy int32

+ const Cluster_LbSubsetConfig_ANY_ENDPOINT

+ const Cluster_LbSubsetConfig_DEFAULT_SUBSET

+ const Cluster_LbSubsetConfig_NO_FALLBACK

+ func (Cluster_LbSubsetConfig_LbSubsetFallbackPolicy) EnumDescriptor() ([]byte, []int)

+ func (x Cluster_LbSubsetConfig_LbSubsetFallbackPolicy) String() string

+ type Cluster_LbSubsetConfig_LbSubsetSelector struct

+ Keys []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cluster_LbSubsetConfig_LbSubsetSelector) Descriptor() ([]byte, []int)

+ func (*Cluster_LbSubsetConfig_LbSubsetSelector) ProtoMessage()

+ func (dst *Cluster_LbSubsetConfig_LbSubsetSelector) XXX_Merge(src proto.Message)

+ func (m *Cluster_LbSubsetConfig_LbSubsetSelector) GetKeys() []string

+ func (m *Cluster_LbSubsetConfig_LbSubsetSelector) Marshal() (dAtA []byte, err error)

+ func (m *Cluster_LbSubsetConfig_LbSubsetSelector) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_LbSubsetConfig_LbSubsetSelector) Reset()

+ func (m *Cluster_LbSubsetConfig_LbSubsetSelector) Size() (n int)

+ func (m *Cluster_LbSubsetConfig_LbSubsetSelector) String() string

+ func (m *Cluster_LbSubsetConfig_LbSubsetSelector) Unmarshal(dAtA []byte) error

+ func (m *Cluster_LbSubsetConfig_LbSubsetSelector) Validate() error

+ func (m *Cluster_LbSubsetConfig_LbSubsetSelector) XXX_DiscardUnknown()

+ func (m *Cluster_LbSubsetConfig_LbSubsetSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster_LbSubsetConfig_LbSubsetSelector) XXX_Size() int

+ func (m *Cluster_LbSubsetConfig_LbSubsetSelector) XXX_Unmarshal(b []byte) error

+ func (this *Cluster_LbSubsetConfig_LbSubsetSelector) Equal(that interface{}) bool

+ type Cluster_LbSubsetConfig_LbSubsetSelectorValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e Cluster_LbSubsetConfig_LbSubsetSelectorValidationError) Error() string

+ type Cluster_OriginalDstLbConfig struct

+ UseHttpHeader bool

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cluster_OriginalDstLbConfig) Descriptor() ([]byte, []int)

+ func (*Cluster_OriginalDstLbConfig) ProtoMessage()

+ func (dst *Cluster_OriginalDstLbConfig) XXX_Merge(src proto.Message)

+ func (m *Cluster_OriginalDstLbConfig) GetUseHttpHeader() bool

+ func (m *Cluster_OriginalDstLbConfig) Marshal() (dAtA []byte, err error)

+ func (m *Cluster_OriginalDstLbConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_OriginalDstLbConfig) Reset()

+ func (m *Cluster_OriginalDstLbConfig) Size() (n int)

+ func (m *Cluster_OriginalDstLbConfig) String() string

+ func (m *Cluster_OriginalDstLbConfig) Unmarshal(dAtA []byte) error

+ func (m *Cluster_OriginalDstLbConfig) Validate() error

+ func (m *Cluster_OriginalDstLbConfig) XXX_DiscardUnknown()

+ func (m *Cluster_OriginalDstLbConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster_OriginalDstLbConfig) XXX_Size() int

+ func (m *Cluster_OriginalDstLbConfig) XXX_Unmarshal(b []byte) error

+ func (this *Cluster_OriginalDstLbConfig) Equal(that interface{}) bool

+ type Cluster_OriginalDstLbConfigValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e Cluster_OriginalDstLbConfigValidationError) Error() string

+ type Cluster_OriginalDstLbConfig_ struct

+ OriginalDstLbConfig *Cluster_OriginalDstLbConfig

+ func (m *Cluster_OriginalDstLbConfig_) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_OriginalDstLbConfig_) Size() (n int)

+ func (this *Cluster_OriginalDstLbConfig_) Equal(that interface{}) bool

+ type Cluster_RingHashLbConfig struct

+ DeprecatedV1 *Cluster_RingHashLbConfig_DeprecatedV1

+ MinimumRingSize *types.UInt64Value

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cluster_RingHashLbConfig) Descriptor() ([]byte, []int)

+ func (*Cluster_RingHashLbConfig) ProtoMessage()

+ func (dst *Cluster_RingHashLbConfig) XXX_Merge(src proto.Message)

+ func (m *Cluster_RingHashLbConfig) GetDeprecatedV1() *Cluster_RingHashLbConfig_DeprecatedV1

+ func (m *Cluster_RingHashLbConfig) GetMinimumRingSize() *types.UInt64Value

+ func (m *Cluster_RingHashLbConfig) Marshal() (dAtA []byte, err error)

+ func (m *Cluster_RingHashLbConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_RingHashLbConfig) Reset()

+ func (m *Cluster_RingHashLbConfig) Size() (n int)

+ func (m *Cluster_RingHashLbConfig) String() string

+ func (m *Cluster_RingHashLbConfig) Unmarshal(dAtA []byte) error

+ func (m *Cluster_RingHashLbConfig) Validate() error

+ func (m *Cluster_RingHashLbConfig) XXX_DiscardUnknown()

+ func (m *Cluster_RingHashLbConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster_RingHashLbConfig) XXX_Size() int

+ func (m *Cluster_RingHashLbConfig) XXX_Unmarshal(b []byte) error

+ func (this *Cluster_RingHashLbConfig) Equal(that interface{}) bool

+ type Cluster_RingHashLbConfigValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e Cluster_RingHashLbConfigValidationError) Error() string

+ type Cluster_RingHashLbConfig_ struct

+ RingHashLbConfig *Cluster_RingHashLbConfig

+ func (m *Cluster_RingHashLbConfig_) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_RingHashLbConfig_) Size() (n int)

+ func (this *Cluster_RingHashLbConfig_) Equal(that interface{}) bool

+ type Cluster_RingHashLbConfig_DeprecatedV1 struct

+ UseStdHash *types.BoolValue

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Cluster_RingHashLbConfig_DeprecatedV1) Descriptor() ([]byte, []int)

+ func (*Cluster_RingHashLbConfig_DeprecatedV1) ProtoMessage()

+ func (dst *Cluster_RingHashLbConfig_DeprecatedV1) XXX_Merge(src proto.Message)

+ func (m *Cluster_RingHashLbConfig_DeprecatedV1) GetUseStdHash() *types.BoolValue

+ func (m *Cluster_RingHashLbConfig_DeprecatedV1) Marshal() (dAtA []byte, err error)

+ func (m *Cluster_RingHashLbConfig_DeprecatedV1) MarshalTo(dAtA []byte) (int, error)

+ func (m *Cluster_RingHashLbConfig_DeprecatedV1) Reset()

+ func (m *Cluster_RingHashLbConfig_DeprecatedV1) Size() (n int)

+ func (m *Cluster_RingHashLbConfig_DeprecatedV1) String() string

+ func (m *Cluster_RingHashLbConfig_DeprecatedV1) Unmarshal(dAtA []byte) error

+ func (m *Cluster_RingHashLbConfig_DeprecatedV1) Validate() error

+ func (m *Cluster_RingHashLbConfig_DeprecatedV1) XXX_DiscardUnknown()

+ func (m *Cluster_RingHashLbConfig_DeprecatedV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Cluster_RingHashLbConfig_DeprecatedV1) XXX_Size() int

+ func (m *Cluster_RingHashLbConfig_DeprecatedV1) XXX_Unmarshal(b []byte) error

+ func (this *Cluster_RingHashLbConfig_DeprecatedV1) Equal(that interface{}) bool

+ type Cluster_RingHashLbConfig_DeprecatedV1ValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e Cluster_RingHashLbConfig_DeprecatedV1ValidationError) Error() string

+ type DiscoveryRequest struct

+ ErrorDetail *rpc.Status

+ Node *core.Node

+ ResourceNames []string

+ ResponseNonce string

+ TypeUrl string

+ VersionInfo string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DiscoveryRequest) Descriptor() ([]byte, []int)

+ func (*DiscoveryRequest) ProtoMessage()

+ func (dst *DiscoveryRequest) XXX_Merge(src proto.Message)

+ func (m *DiscoveryRequest) GetErrorDetail() *rpc.Status

+ func (m *DiscoveryRequest) GetNode() *core.Node

+ func (m *DiscoveryRequest) GetResourceNames() []string

+ func (m *DiscoveryRequest) GetResponseNonce() string

+ func (m *DiscoveryRequest) GetTypeUrl() string

+ func (m *DiscoveryRequest) GetVersionInfo() string

+ func (m *DiscoveryRequest) Marshal() (dAtA []byte, err error)

+ func (m *DiscoveryRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *DiscoveryRequest) Reset()

+ func (m *DiscoveryRequest) Size() (n int)

+ func (m *DiscoveryRequest) String() string

+ func (m *DiscoveryRequest) Unmarshal(dAtA []byte) error

+ func (m *DiscoveryRequest) Validate() error

+ func (m *DiscoveryRequest) XXX_DiscardUnknown()

+ func (m *DiscoveryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DiscoveryRequest) XXX_Size() int

+ func (m *DiscoveryRequest) XXX_Unmarshal(b []byte) error

+ func (this *DiscoveryRequest) Equal(that interface{}) bool

+ type DiscoveryRequestValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e DiscoveryRequestValidationError) Error() string

+ type DiscoveryResponse struct

+ Canary bool

+ Nonce string

+ Resources []types.Any

+ TypeUrl string

+ VersionInfo string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DiscoveryResponse) Descriptor() ([]byte, []int)

+ func (*DiscoveryResponse) ProtoMessage()

+ func (dst *DiscoveryResponse) XXX_Merge(src proto.Message)

+ func (m *DiscoveryResponse) GetCanary() bool

+ func (m *DiscoveryResponse) GetNonce() string

+ func (m *DiscoveryResponse) GetResources() []types.Any

+ func (m *DiscoveryResponse) GetTypeUrl() string

+ func (m *DiscoveryResponse) GetVersionInfo() string

+ func (m *DiscoveryResponse) Marshal() (dAtA []byte, err error)

+ func (m *DiscoveryResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *DiscoveryResponse) Reset()

+ func (m *DiscoveryResponse) Size() (n int)

+ func (m *DiscoveryResponse) String() string

+ func (m *DiscoveryResponse) Unmarshal(dAtA []byte) error

+ func (m *DiscoveryResponse) Validate() error

+ func (m *DiscoveryResponse) XXX_DiscardUnknown()

+ func (m *DiscoveryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DiscoveryResponse) XXX_Size() int

+ func (m *DiscoveryResponse) XXX_Unmarshal(b []byte) error

+ func (this *DiscoveryResponse) Equal(that interface{}) bool

+ type DiscoveryResponseValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e DiscoveryResponseValidationError) Error() string

+ type EndpointDiscoveryServiceClient interface

+ FetchEndpoints func(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error)

+ StreamEndpoints func(ctx context.Context, opts ...grpc.CallOption) (EndpointDiscoveryService_StreamEndpointsClient, error)

+ func NewEndpointDiscoveryServiceClient(cc *grpc.ClientConn) EndpointDiscoveryServiceClient

+ type EndpointDiscoveryServiceServer interface

+ FetchEndpoints func(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)

+ StreamEndpoints func(EndpointDiscoveryService_StreamEndpointsServer) error

+ type EndpointDiscoveryService_StreamEndpointsClient interface

+ Recv func() (*DiscoveryResponse, error)

+ Send func(*DiscoveryRequest) error

+ type EndpointDiscoveryService_StreamEndpointsServer interface

+ Recv func() (*DiscoveryRequest, error)

+ Send func(*DiscoveryResponse) error

+ type IncrementalDiscoveryRequest struct

+ ErrorDetail *rpc.Status

+ InitialResourceVersions map[string]string

+ Node *core.Node

+ ResourceNamesSubscribe []string

+ ResourceNamesUnsubscribe []string

+ ResponseNonce string

+ TypeUrl string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IncrementalDiscoveryRequest) Descriptor() ([]byte, []int)

+ func (*IncrementalDiscoveryRequest) ProtoMessage()

+ func (dst *IncrementalDiscoveryRequest) XXX_Merge(src proto.Message)

+ func (m *IncrementalDiscoveryRequest) GetErrorDetail() *rpc.Status

+ func (m *IncrementalDiscoveryRequest) GetInitialResourceVersions() map[string]string

+ func (m *IncrementalDiscoveryRequest) GetNode() *core.Node

+ func (m *IncrementalDiscoveryRequest) GetResourceNamesSubscribe() []string

+ func (m *IncrementalDiscoveryRequest) GetResourceNamesUnsubscribe() []string

+ func (m *IncrementalDiscoveryRequest) GetResponseNonce() string

+ func (m *IncrementalDiscoveryRequest) GetTypeUrl() string

+ func (m *IncrementalDiscoveryRequest) Marshal() (dAtA []byte, err error)

+ func (m *IncrementalDiscoveryRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *IncrementalDiscoveryRequest) Reset()

+ func (m *IncrementalDiscoveryRequest) Size() (n int)

+ func (m *IncrementalDiscoveryRequest) String() string

+ func (m *IncrementalDiscoveryRequest) Unmarshal(dAtA []byte) error

+ func (m *IncrementalDiscoveryRequest) Validate() error

+ func (m *IncrementalDiscoveryRequest) XXX_DiscardUnknown()

+ func (m *IncrementalDiscoveryRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IncrementalDiscoveryRequest) XXX_Size() int

+ func (m *IncrementalDiscoveryRequest) XXX_Unmarshal(b []byte) error

+ func (this *IncrementalDiscoveryRequest) Equal(that interface{}) bool

+ type IncrementalDiscoveryRequestValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e IncrementalDiscoveryRequestValidationError) Error() string

+ type IncrementalDiscoveryResponse struct

+ Nonce string

+ RemovedResources []string

+ Resources []Resource

+ SystemVersionInfo string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IncrementalDiscoveryResponse) Descriptor() ([]byte, []int)

+ func (*IncrementalDiscoveryResponse) ProtoMessage()

+ func (dst *IncrementalDiscoveryResponse) XXX_Merge(src proto.Message)

+ func (m *IncrementalDiscoveryResponse) GetNonce() string

+ func (m *IncrementalDiscoveryResponse) GetRemovedResources() []string

+ func (m *IncrementalDiscoveryResponse) GetResources() []Resource

+ func (m *IncrementalDiscoveryResponse) GetSystemVersionInfo() string

+ func (m *IncrementalDiscoveryResponse) Marshal() (dAtA []byte, err error)

+ func (m *IncrementalDiscoveryResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *IncrementalDiscoveryResponse) Reset()

+ func (m *IncrementalDiscoveryResponse) Size() (n int)

+ func (m *IncrementalDiscoveryResponse) String() string

+ func (m *IncrementalDiscoveryResponse) Unmarshal(dAtA []byte) error

+ func (m *IncrementalDiscoveryResponse) Validate() error

+ func (m *IncrementalDiscoveryResponse) XXX_DiscardUnknown()

+ func (m *IncrementalDiscoveryResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IncrementalDiscoveryResponse) XXX_Size() int

+ func (m *IncrementalDiscoveryResponse) XXX_Unmarshal(b []byte) error

+ func (this *IncrementalDiscoveryResponse) Equal(that interface{}) bool

+ type IncrementalDiscoveryResponseValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e IncrementalDiscoveryResponseValidationError) Error() string

+ type Listener struct

+ Address core.Address

+ DeprecatedV1 *Listener_DeprecatedV1

+ DrainType Listener_DrainType

+ FilterChains []listener.FilterChain

+ Freebind *types.BoolValue

+ ListenerFilters []listener.ListenerFilter

+ Metadata *core.Metadata

+ Name string

+ PerConnectionBufferLimitBytes *types.UInt32Value

+ SocketOptions []*core.SocketOption

+ TcpFastOpenQueueLength *types.UInt32Value

+ Transparent *types.BoolValue

+ UseOriginalDst *types.BoolValue

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Listener) Descriptor() ([]byte, []int)

+ func (*Listener) ProtoMessage()

+ func (dst *Listener) XXX_Merge(src proto.Message)

+ func (m *Listener) GetAddress() core.Address

+ func (m *Listener) GetDeprecatedV1() *Listener_DeprecatedV1

+ func (m *Listener) GetDrainType() Listener_DrainType

+ func (m *Listener) GetFilterChains() []listener.FilterChain

+ func (m *Listener) GetFreebind() *types.BoolValue

+ func (m *Listener) GetListenerFilters() []listener.ListenerFilter

+ func (m *Listener) GetMetadata() *core.Metadata

+ func (m *Listener) GetName() string

+ func (m *Listener) GetPerConnectionBufferLimitBytes() *types.UInt32Value

+ func (m *Listener) GetSocketOptions() []*core.SocketOption

+ func (m *Listener) GetTcpFastOpenQueueLength() *types.UInt32Value

+ func (m *Listener) GetTransparent() *types.BoolValue

+ func (m *Listener) GetUseOriginalDst() *types.BoolValue

+ func (m *Listener) Marshal() (dAtA []byte, err error)

+ func (m *Listener) MarshalTo(dAtA []byte) (int, error)

+ func (m *Listener) Reset()

+ func (m *Listener) Size() (n int)

+ func (m *Listener) String() string

+ func (m *Listener) Unmarshal(dAtA []byte) error

+ func (m *Listener) Validate() error

+ func (m *Listener) XXX_DiscardUnknown()

+ func (m *Listener) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Listener) XXX_Size() int

+ func (m *Listener) XXX_Unmarshal(b []byte) error

+ func (this *Listener) Equal(that interface{}) bool

+ type ListenerDiscoveryServiceClient interface

+ FetchListeners func(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error)

+ StreamListeners func(ctx context.Context, opts ...grpc.CallOption) (ListenerDiscoveryService_StreamListenersClient, error)

+ func NewListenerDiscoveryServiceClient(cc *grpc.ClientConn) ListenerDiscoveryServiceClient

+ type ListenerDiscoveryServiceServer interface

+ FetchListeners func(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)

+ StreamListeners func(ListenerDiscoveryService_StreamListenersServer) error

+ type ListenerDiscoveryService_StreamListenersClient interface

+ Recv func() (*DiscoveryResponse, error)

+ Send func(*DiscoveryRequest) error

+ type ListenerDiscoveryService_StreamListenersServer interface

+ Recv func() (*DiscoveryRequest, error)

+ Send func(*DiscoveryResponse) error

+ type ListenerValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e ListenerValidationError) Error() string

+ type Listener_DeprecatedV1 struct

+ BindToPort *types.BoolValue

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Listener_DeprecatedV1) Descriptor() ([]byte, []int)

+ func (*Listener_DeprecatedV1) ProtoMessage()

+ func (dst *Listener_DeprecatedV1) XXX_Merge(src proto.Message)

+ func (m *Listener_DeprecatedV1) GetBindToPort() *types.BoolValue

+ func (m *Listener_DeprecatedV1) Marshal() (dAtA []byte, err error)

+ func (m *Listener_DeprecatedV1) MarshalTo(dAtA []byte) (int, error)

+ func (m *Listener_DeprecatedV1) Reset()

+ func (m *Listener_DeprecatedV1) Size() (n int)

+ func (m *Listener_DeprecatedV1) String() string

+ func (m *Listener_DeprecatedV1) Unmarshal(dAtA []byte) error

+ func (m *Listener_DeprecatedV1) Validate() error

+ func (m *Listener_DeprecatedV1) XXX_DiscardUnknown()

+ func (m *Listener_DeprecatedV1) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Listener_DeprecatedV1) XXX_Size() int

+ func (m *Listener_DeprecatedV1) XXX_Unmarshal(b []byte) error

+ func (this *Listener_DeprecatedV1) Equal(that interface{}) bool

+ type Listener_DeprecatedV1ValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e Listener_DeprecatedV1ValidationError) Error() string

+ type Listener_DrainType int32

+ const Listener_DEFAULT

+ const Listener_MODIFY_ONLY

+ func (Listener_DrainType) EnumDescriptor() ([]byte, []int)

+ func (x Listener_DrainType) String() string

+ type Resource struct

+ Resource *types.Any

+ Version string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Resource) Descriptor() ([]byte, []int)

+ func (*Resource) ProtoMessage()

+ func (dst *Resource) XXX_Merge(src proto.Message)

+ func (m *Resource) GetResource() *types.Any

+ func (m *Resource) GetVersion() string

+ func (m *Resource) Marshal() (dAtA []byte, err error)

+ func (m *Resource) MarshalTo(dAtA []byte) (int, error)

+ func (m *Resource) Reset()

+ func (m *Resource) Size() (n int)

+ func (m *Resource) String() string

+ func (m *Resource) Unmarshal(dAtA []byte) error

+ func (m *Resource) Validate() error

+ func (m *Resource) XXX_DiscardUnknown()

+ func (m *Resource) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Resource) XXX_Size() int

+ func (m *Resource) XXX_Unmarshal(b []byte) error

+ func (this *Resource) Equal(that interface{}) bool

+ type ResourceValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e ResourceValidationError) Error() string

+ type RouteConfiguration struct

+ InternalOnlyHeaders []string

+ Name string

+ RequestHeadersToAdd []*core.HeaderValueOption

+ ResponseHeadersToAdd []*core.HeaderValueOption

+ ResponseHeadersToRemove []string

+ ValidateClusters *types.BoolValue

+ VirtualHosts []route.VirtualHost

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RouteConfiguration) Descriptor() ([]byte, []int)

+ func (*RouteConfiguration) ProtoMessage()

+ func (dst *RouteConfiguration) XXX_Merge(src proto.Message)

+ func (m *RouteConfiguration) GetInternalOnlyHeaders() []string

+ func (m *RouteConfiguration) GetName() string

+ func (m *RouteConfiguration) GetRequestHeadersToAdd() []*core.HeaderValueOption

+ func (m *RouteConfiguration) GetResponseHeadersToAdd() []*core.HeaderValueOption

+ func (m *RouteConfiguration) GetResponseHeadersToRemove() []string

+ func (m *RouteConfiguration) GetValidateClusters() *types.BoolValue

+ func (m *RouteConfiguration) GetVirtualHosts() []route.VirtualHost

+ func (m *RouteConfiguration) Marshal() (dAtA []byte, err error)

+ func (m *RouteConfiguration) MarshalTo(dAtA []byte) (int, error)

+ func (m *RouteConfiguration) Reset()

+ func (m *RouteConfiguration) Size() (n int)

+ func (m *RouteConfiguration) String() string

+ func (m *RouteConfiguration) Unmarshal(dAtA []byte) error

+ func (m *RouteConfiguration) Validate() error

+ func (m *RouteConfiguration) XXX_DiscardUnknown()

+ func (m *RouteConfiguration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RouteConfiguration) XXX_Size() int

+ func (m *RouteConfiguration) XXX_Unmarshal(b []byte) error

+ func (this *RouteConfiguration) Equal(that interface{}) bool

+ type RouteConfigurationValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e RouteConfigurationValidationError) Error() string

+ type RouteDiscoveryServiceClient interface

+ FetchRoutes func(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error)

+ IncrementalRoutes func(ctx context.Context, opts ...grpc.CallOption) (RouteDiscoveryService_IncrementalRoutesClient, error)

+ StreamRoutes func(ctx context.Context, opts ...grpc.CallOption) (RouteDiscoveryService_StreamRoutesClient, error)

+ func NewRouteDiscoveryServiceClient(cc *grpc.ClientConn) RouteDiscoveryServiceClient

+ type RouteDiscoveryServiceServer interface

+ FetchRoutes func(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)

+ IncrementalRoutes func(RouteDiscoveryService_IncrementalRoutesServer) error

+ StreamRoutes func(RouteDiscoveryService_StreamRoutesServer) error

+ type RouteDiscoveryService_IncrementalRoutesClient interface

+ Recv func() (*IncrementalDiscoveryResponse, error)

+ Send func(*IncrementalDiscoveryRequest) error

+ type RouteDiscoveryService_IncrementalRoutesServer interface

+ Recv func() (*IncrementalDiscoveryRequest, error)

+ Send func(*IncrementalDiscoveryResponse) error

+ type RouteDiscoveryService_StreamRoutesClient interface

+ Recv func() (*DiscoveryResponse, error)

+ Send func(*DiscoveryRequest) error

+ type RouteDiscoveryService_StreamRoutesServer interface

+ Recv func() (*DiscoveryRequest, error)

+ Send func(*DiscoveryResponse) error

+ type UpstreamBindConfig struct

+ SourceAddress *core.Address

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UpstreamBindConfig) Descriptor() ([]byte, []int)

+ func (*UpstreamBindConfig) ProtoMessage()

+ func (dst *UpstreamBindConfig) XXX_Merge(src proto.Message)

+ func (m *UpstreamBindConfig) GetSourceAddress() *core.Address

+ func (m *UpstreamBindConfig) Marshal() (dAtA []byte, err error)

+ func (m *UpstreamBindConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *UpstreamBindConfig) Reset()

+ func (m *UpstreamBindConfig) Size() (n int)

+ func (m *UpstreamBindConfig) String() string

+ func (m *UpstreamBindConfig) Unmarshal(dAtA []byte) error

+ func (m *UpstreamBindConfig) Validate() error

+ func (m *UpstreamBindConfig) XXX_DiscardUnknown()

+ func (m *UpstreamBindConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpstreamBindConfig) XXX_Size() int

+ func (m *UpstreamBindConfig) XXX_Unmarshal(b []byte) error

+ func (this *UpstreamBindConfig) Equal(that interface{}) bool

+ type UpstreamBindConfigValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e UpstreamBindConfigValidationError) Error() string

+ type UpstreamConnectionOptions struct

+ TcpKeepalive *core.TcpKeepalive

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*UpstreamConnectionOptions) Descriptor() ([]byte, []int)

+ func (*UpstreamConnectionOptions) ProtoMessage()

+ func (dst *UpstreamConnectionOptions) XXX_Merge(src proto.Message)

+ func (m *UpstreamConnectionOptions) GetTcpKeepalive() *core.TcpKeepalive

+ func (m *UpstreamConnectionOptions) Marshal() (dAtA []byte, err error)

+ func (m *UpstreamConnectionOptions) MarshalTo(dAtA []byte) (int, error)

+ func (m *UpstreamConnectionOptions) Reset()

+ func (m *UpstreamConnectionOptions) Size() (n int)

+ func (m *UpstreamConnectionOptions) String() string

+ func (m *UpstreamConnectionOptions) Unmarshal(dAtA []byte) error

+ func (m *UpstreamConnectionOptions) Validate() error

+ func (m *UpstreamConnectionOptions) XXX_DiscardUnknown()

+ func (m *UpstreamConnectionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *UpstreamConnectionOptions) XXX_Size() int

+ func (m *UpstreamConnectionOptions) XXX_Unmarshal(b []byte) error

+ func (this *UpstreamConnectionOptions) Equal(that interface{}) bool

+ type UpstreamConnectionOptionsValidationError struct

+ Cause error

+ Field string

+ Key bool

+ Reason string

+ func (e UpstreamConnectionOptionsValidationError) Error() string

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