- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for Builds (0.38 sec)
-
pilot/pkg/networking/core/listener_inbound.go
func (lb *ListenerBuilder) buildInboundListeners() []*listener.Listener { // All listeners we build var listeners []*listener.Listener // virtualInboundFilterChains builds up all of the filter chains for the virtual inbound listener var virtualInboundFilterChains []*listener.FilterChain // For each chain config we will build required filter chain(s) for _, cc := range lb.buildInboundChainConfigs() {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 35.1K bytes - Viewed (0) -
pilot/pkg/networking/util/util.go
if strings.Contains(host, ":") { return "[" + host + "]" } return host } // DomainName builds the domain name for a given host and port func DomainName(host string, port int) string { return net.JoinHostPort(host, strconv.Itoa(port)) } // BuildInternalEndpoint builds an lb endpoint pointing to the internal listener named dest.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 28.5K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster_builder.go
if cachedCluster == nil { allFound = false } res = append(res, cachedCluster) } return res, allFound } // build does any final build operations needed, like marshaling etc. func (mc *clusterWrapper) build() *cluster.Cluster { if mc == nil { return nil } // Marshall Http Protocol options if they exist. if mc.httpProtocolOptions != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 31.6K bytes - Viewed (0) -
pilot/pkg/networking/core/listener_waypoint.go
post = append(post, xdsfilters.WaypointUpstreamMetadataFilter) post = append(post, lb.push.Telemetry.HTTPFilters(lb.node, cls, svc)...) return } // buildWaypointInboundHTTPFilters builds the network filters that should be inserted before an HCM. // This should only be used with HTTP; see buildInboundNetworkFilters for TCP
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Jun 14 04:34:37 UTC 2024 - 27.6K bytes - Viewed (0) -
pilot/pkg/networking/core/cluster.go
deletedClusters = append(deletedClusters, subsetClusters[matchedSvc.Hostname.String()].UnsortedList()...) } } return services, deletedClusters } // buildClusters builds clusters for the proxy with the services passed. func (configgen *ConfigGeneratorImpl) buildClusters(proxy *model.Proxy, req *model.PushRequest, services []*model.Service, ) ([]*discovery.Resource, model.XdsLogDetails) {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 13 01:56:28 UTC 2024 - 33K bytes - Viewed (0) -
cmd/iam-store.go
iamGroupsMap: map[string]GroupInfo{}, iamUserGroupMemberships: map[string]set.StringSet{}, iamGroupPolicyMap: xsync.NewMapOf[string, MappedPolicy](), } } // buildUserGroupMemberships - builds the memberships map. IMPORTANT: // Assumes that c.Lock is held by caller. func (c *iamCache) buildUserGroupMemberships() { for group, gi := range c.iamGroupsMap { c.updateGroupMembershipsMap(group, &gi) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 75.8K bytes - Viewed (0) -
cmd/iam.go
updatedAt, err = sys.store.SetGroupStatus(ctx, group, enabled) if err != nil { return updatedAt, err } sys.notifyForGroup(ctx, group) return updatedAt, nil } // GetGroupDescription - builds up group description func (sys *IAMSys) GetGroupDescription(group string) (gd madmin.GroupDesc, err error) { if !sys.Initialized() { return gd, errServerNotInitialized }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Thu Jun 13 22:26:38 UTC 2024 - 71.9K bytes - Viewed (0) -
tensorflow/compiler/mlir/tf2xla/internal/utils/BUILD
A. Unique TensorFlower <******@****.***> 1718318717 -0700
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Thu Jun 13 23:59:33 UTC 2024 - 2.7K bytes - Viewed (0)