Versions in this module Expand all Collapse all v0 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
Go to main page