xds

package

Go to main page

Versions in this module

v1

v1.8.1

Oct 5, 2022

Changes in this version

+ const FeatureTCPAccessLogViaNamedPipe

+ const FieldPrefixDependenciesVersion

+ type Attachment struct

+ Name string

+ Service string

+ Type AttachmentType

+ type AttachmentList []Attachment

+ func (a AttachmentList) Len() int

+ func (a AttachmentList) Less(i, j int) bool

+ func (a AttachmentList) Swap(i, j int)

+ type AttachmentMap map[Attachment]PoliciesByResourceType

+ func GroupByAttachment(matchedPolicies *MatchedPolicies, networking *mesh_proto.Dataplane_Networking) AttachmentMap

+ type AttachmentType int64

+ const Dataplane

+ const Inbound

+ const Outbound

+ const Service

+ func (s AttachmentType) String() string

+ type Attachments map[Attachment][]core_model.Resource

+ func BuildAttachments(matchedPolicies *MatchedPolicies, networking *mesh_proto.Dataplane_Networking) Attachments

+ type AttachmentsByPolicy map[PolicyKey]AttachmentList

+ func GroupByPolicy(matchedPolicies *MatchedPolicies, networking *mesh_proto.Dataplane_Networking) AttachmentsByPolicy

+ func (abp AttachmentsByPolicy) Merge(other AttachmentsByPolicy)

+ type CaRequest interface

+ MeshName func() []string

+ Name func() string

type DataplaneMetadata

+ Features Features

+ Resource model.Resource

+ func (m *DataplaneMetadata) GetZoneEgressResource() *core_mesh.ZoneEgressResource

type Endpoint

+ UnixDomainPath string

+ func (e Endpoint) IsReachableFromZone(localZone string) bool

type ExternalService

+ ServerName string

+ type ExternalServiceFaultInjectionMap map[ServiceName][]*core_mesh.FaultInjectionResource

+ type ExternalServicePermissionMap map[ServiceName]*core_mesh.TrafficPermissionResource

+ type ExternalServiceRateLimitMap map[ServiceName][]*core_mesh.RateLimitResource

+ type Features map[string]bool

+ func (f Features) HasFeature(feature string) bool

+ type IdentityCertRequest interface

+ Name func() string

+ type InboundRateLimitsMap map[mesh_proto.InboundInterface][]*core_mesh.RateLimitResource

type MatchedPolicies

+ CustomInboundPolicies []map[mesh_proto.InboundInterface]core_model.Resource

+ ProxyTemplate *core_mesh.ProxyTemplateResource

+ RateLimitsInbound InboundRateLimitsMap

+ RateLimitsOutbound OutboundRateLimitsMap

+ TrafficLogs TrafficLogMap

+ TrafficRoutes RouteMap

+ type MeshName = string

+ type MeshResources struct

+ EndpointMap EndpointMap

+ ExternalServiceFaultInjections ExternalServiceFaultInjectionMap

+ ExternalServicePermissionMap ExternalServicePermissionMap

+ ExternalServiceRateLimits ExternalServiceRateLimitMap

+ ExternalServices []*core_mesh.ExternalServiceResource

+ Mesh *core_mesh.MeshResource

+ TrafficRoutes []*core_mesh.TrafficRouteResource

+ type OutboundRateLimitsMap map[mesh_proto.OutboundInterface]*core_mesh.RateLimitResource

+ type PoliciesByResourceType map[core_model.ResourceType][]core_model.Resource

+ type PolicyKey struct

+ Key core_model.ResourceKey

+ Type core_model.ResourceType

type Proxy

+ EnvoyAdminMTLSCerts ServerSideMTLSCerts

+ SecretsTracker SecretsTracker

+ ZoneEgressProxy *ZoneEgressProxy

+ ZoneIngressProxy *ZoneIngressProxy

type RateLimitsMap

+ Inbound InboundRateLimitsMap

+ Outbound OutboundRateLimitsMap

type ResourceSet

+ func (s *ResourceSet) ResourceTypes() []string

+ type SecretsTracker interface

+ RequestAllInOneCa func() CaRequest

+ RequestCa func(mesh string) CaRequest

+ RequestIdentityCert func() IdentityCertRequest

+ UsedAllInOne func() bool

+ UsedCas func() map[string]struct{}

+ UsedIdentity func() bool

+ func NewSecretsTracker(ownMesh string, allMeshes []string) SecretsTracker

+ type ServerSideMTLSCerts struct

+ CaPEM []byte

+ ServerPair util_tls.KeyPair

+ type TrafficLogMap map[ServiceName]*core_mesh.TrafficLogResource

+ type VIPDomains struct

+ Address string

+ Domains []string

+ type ZoneEgressProxy struct

+ MeshResourcesList []*MeshResources

+ ZoneEgressResource *core_mesh.ZoneEgressResource

+ ZoneIngresses []*core_mesh.ZoneIngressResource

+ type ZoneIngressProxy struct

+ GatewayRoutes *core_mesh.MeshGatewayRouteResourceList

+ MeshGateways *core_mesh.MeshGatewayResourceList

+ TrafficRouteList *core_mesh.TrafficRouteResourceList

v1.5.0-rc2

Feb 18, 2022

v1.2.1

Jun 30, 2021

Changes in this version

+ type CLACache interface

+ GetCLA func(ctx context.Context, meshName, meshHash string, cluster envoy_common.Cluster, ...) (proto.Message, error)

+ type CaSecret struct

+ PemCerts [][]byte

+ type CircuitBreakerMap map[ServiceName]*mesh_core.CircuitBreakerResource

+ type DataplaneMetadata struct

+ AdminPort uint32

+ DNSPort uint32

+ DataplaneResource *core_mesh.DataplaneResource

+ DataplaneToken string

+ DataplaneTokenPath string

+ DynamicMetadata map[string]string

+ EmptyDNSPort uint32

+ ProxyType mesh_proto.ProxyType

+ Version *mesh_proto.Version

+ ZoneIngressResource *core_mesh.ZoneIngressResource

+ func DataplaneMetadataFromXdsMetadata(xdsMetadata *_struct.Struct) *DataplaneMetadata

+ func (m *DataplaneMetadata) GetAdminPort() uint32

+ func (m *DataplaneMetadata) GetDNSPort() uint32

+ func (m *DataplaneMetadata) GetDataplaneResource() *core_mesh.DataplaneResource

+ func (m *DataplaneMetadata) GetDataplaneToken() string

+ func (m *DataplaneMetadata) GetDataplaneTokenPath() string

+ func (m *DataplaneMetadata) GetDynamicMetadata(key string) string

+ func (m *DataplaneMetadata) GetEmptyDNSPort() uint32

+ func (m *DataplaneMetadata) GetProxyType() mesh_proto.ProxyType

+ func (m *DataplaneMetadata) GetVersion() *mesh_proto.Version

+ func (m *DataplaneMetadata) GetZoneIngressResource() *core_mesh.ZoneIngressResource

+ type DestinationMap map[ServiceName]TagSelectorSet

+ type Endpoint struct

+ ExternalService *ExternalService

+ Locality *Locality

+ Port uint32

+ Tags map[string]string

+ Target string

+ Weight uint32

+ func (e Endpoint) ContainsTags(tags map[string]string) bool

+ func (e Endpoint) HasLocality() bool

+ func (e Endpoint) IsExternalService() bool

+ func (e Endpoint) LocalityString() string

+ type EndpointList []Endpoint

+ func (l EndpointList) Filter(selector mesh_proto.TagSelector) EndpointList

+ type EndpointMap map[ServiceName][]Endpoint

+ type ExternalService struct

+ AllowRenegotiation bool

+ CaCert []byte

+ ClientCert []byte

+ ClientKey []byte

+ TLSEnabled bool

+ type FaultInjectionMap map[mesh_proto.InboundInterface]*mesh_proto.FaultInjection

+ type HealthCheckMap map[ServiceName]*mesh_core.HealthCheckResource

+ type IdentitySecret struct

+ PemCerts [][]byte

+ PemKey []byte

+ type Locality struct

+ Priority uint32

+ Region string

+ SubZone string

+ Zone string

+ type LogMap map[ServiceName]*mesh_proto.LoggingBackend

+ type MatchedPolicies struct

+ CircuitBreakers CircuitBreakerMap

+ FaultInjections FaultInjectionMap

+ HealthChecks HealthCheckMap

+ Logs LogMap

+ RateLimits RateLimitsMap

+ Retries RetryMap

+ Timeouts TimeoutMap

+ TracingBackend *mesh_proto.TracingBackend

+ TrafficPermissions TrafficPermissionMap

+ TrafficTrace *mesh_core.TrafficTraceResource

+ type Proxy struct

+ APIVersion envoy_common.APIVersion

+ Dataplane *mesh_core.DataplaneResource

+ Id ProxyId

+ Metadata *DataplaneMetadata

+ Policies MatchedPolicies

+ Routing Routing

+ ZoneIngress *mesh_core.ZoneIngressResource

+ type ProxyId struct

+ func BuildProxyId(mesh, name string) *ProxyId

+ func FromResourceKey(key core_model.ResourceKey) ProxyId

+ func ParseProxyIdFromString(id string) (*ProxyId, error)

+ func (id *ProxyId) String() string

+ func (id *ProxyId) ToResourceKey() core_model.ResourceKey

+ type RateLimitsMap map[mesh_proto.InboundInterface][]*mesh_proto.RateLimit

+ type Resource struct

+ Name string

+ Origin string

+ Resource ResourcePayload

+ type ResourceList []*Resource

+ func (rs ResourceList) Len() int

+ func (rs ResourceList) Less(i, j int) bool

+ func (rs ResourceList) Payloads() []ResourcePayload

+ func (rs ResourceList) Swap(i, j int)

+ func (rs ResourceList) ToDeltaDiscoveryResponse() (*envoy.DeltaDiscoveryResponse, error)

+ func (rs ResourceList) ToIndex() map[string]ResourcePayload

+ type ResourcePayload = envoy_types.Resource

+ type ResourceSet struct

+ func NewResourceSet() *ResourceSet

+ func (s *ResourceSet) Add(resources ...*Resource) *ResourceSet

+ func (s *ResourceSet) AddSet(set *ResourceSet) *ResourceSet

+ func (s *ResourceSet) Contains(name string, resource ResourcePayload) bool

+ func (s *ResourceSet) Empty() bool

+ func (s *ResourceSet) List() ResourceList

+ func (s *ResourceSet) ListOf(typ string) ResourceList

+ func (s *ResourceSet) Remove(typ string, name string)

+ func (s *ResourceSet) Resources(typ string) map[string]*Resource

+ type RetryMap map[ServiceName]*mesh_core.RetryResource

+ type RouteMap map[mesh_proto.OutboundInterface]*mesh_core.TrafficRouteResource

+ type Routing struct

+ OutboundTargets EndpointMap

+ TrafficRouteList *mesh_core.TrafficRouteResourceList

+ TrafficRoutes RouteMap

+ type ServiceName = string

+ type SocketAddressProtocol int32

+ const SocketAddressProtocolTCP

+ const SocketAddressProtocolUDP

+ type StreamID = int64

+ type TagSelectorSet []mesh_proto.TagSelector

+ func (s TagSelectorSet) Add(new mesh_proto.TagSelector) TagSelectorSet

+ func (s TagSelectorSet) Matches(tags map[string]string) bool

+ type TimeoutMap map[mesh_proto.OutboundInterface]*mesh_core.TimeoutResource

+ type TrafficPermissionMap map[mesh_proto.InboundInterface]*mesh_core.TrafficPermissionResource

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