Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for destinationEdgeIndex (0.31 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top