- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for destinationEdgeIndex (0.31 sec)
-
plugin/pkg/auth/authorizer/node/graph.go
lock sync.RWMutex graph *simple.DirectedAcyclicGraph // vertices is a map of type -> namespace -> name -> vertex vertices map[vertexType]namespaceVertexMapping // destinationEdgeIndex is a map of vertex -> set of destination IDs destinationEdgeIndex map[int]*intSet // destinationEdgeThreshold is the minimum number of distinct destination IDs at which to maintain an index destinationEdgeThreshold int }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 17.5K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/graph_test.go
t.Errorf("expected graph:\n%s\ngot:\n%s", string(e), string(a)) } } expectIndex := func(expect map[string][]string) { t.Helper() actual := map[string][]string{} for from, to := range g.destinationEdgeIndex { sortedValues := []string{} for member, count := range to.members { sortedValues = append(sortedValues, fmt.Sprintf("%s=%d", toString(member), count)) } sort.Strings(sortedValues)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Sep 23 23:14:19 UTC 2022 - 12.3K bytes - Viewed (0) -
plugin/pkg/auth/authorizer/node/node_authorizer.go
return false, fmt.Errorf("node '%s' cannot get unknown %s %s/%s", nodeName, vertexTypes[startingType], startingNamespace, startingName) } // Fast check to see if we know of a destination edge if r.graph.destinationEdgeIndex[startingVertex.ID()].has(nodeVertex.ID()) { return true, nil } found := false traversal := &traverse.VisitingDepthFirst{ EdgeFilter: func(edge graph.Edge) bool {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 21:22:55 UTC 2024 - 16K bytes - Viewed (0)