Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for ShouldRespond (0.28 sec)

  1. security/pkg/nodeagent/sds/sdsservice.go

    			if res == secretName {
    				return true
    			}
    		}
    	}
    	return false
    }
    
    func (c *Context) Process(req *discovery.DiscoveryRequest) error {
    	shouldRespond, delta := xds.ShouldRespond(c.Watcher(), c.XdsConnection().ID(), req)
    	if !shouldRespond {
    		return nil
    	}
    	resources := req.ResourceNames
    	if !delta.IsEmpty() {
    		resources = delta.Subscribed.UnsortedList()
    	}
    	res, err := c.s.generate(resources)
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Sat May 25 00:20:04 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  2. pkg/xds/server_test.go

    				ResponseNonce: "nonce",
    				ResourceNames: []string{},
    			},
    			response: false,
    		},
    	}
    
    	for _, tt := range tests {
    		t.Run(tt.name, func(t *testing.T) {
    			if response, _ := ShouldRespond(tt.proxy, "test", tt.request); response != tt.response {
    				t.Fatalf("Unexpected value for response, expected %v, got %v", tt.response, response)
    			}
    			if tt.name != "reconnect" && tt.response {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Tue Apr 30 00:26:45 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  3. pkg/xds/server.go

    			return
    		}
    	}
    }
    
    // ShouldRespond determines whether this request needs to be responded back. It applies the ack/nack rules as per xds protocol
    // using WatchedResource for previous state and discovery request for the current state.
    func ShouldRespond(w Watcher, id string, request *discovery.DiscoveryRequest) (bool, ResourceDelta) {
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon May 13 20:55:20 UTC 2024
    - 16.3K bytes
    - Viewed (0)
  4. pilot/pkg/xds/ads.go

    	}
    
    	if s.StatusReporter != nil {
    		s.StatusReporter.RegisterEvent(con.ID(), req.TypeUrl, req.ResponseNonce)
    	}
    
    	shouldRespond, delta := xds.ShouldRespond(con.proxy, con.ID(), req)
    	if !shouldRespond {
    		return nil
    	}
    
    	request := &model.PushRequest{
    		Full:   true,
    		Push:   con.proxy.LastPushContext,
    		Reason: model.NewReasonStats(model.ProxyRequest),
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Mon Jun 03 08:29:05 UTC 2024
    - 23.4K bytes
    - Viewed (0)
  5. pilot/pkg/xds/delta.go

    	}
    
    	if s.StatusReporter != nil {
    		s.StatusReporter.RegisterEvent(con.ID(), req.TypeUrl, req.ResponseNonce)
    	}
    
    	shouldRespond := s.shouldRespondDelta(con, req)
    	if !shouldRespond {
    		return nil
    	}
    
    	subs, _ := deltaWatchedResources(nil, req)
    	request := &model.PushRequest{
    		Full:   true,
    		Push:   con.proxy.LastPushContext,
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jun 14 04:34:37 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  6. architecture/networking/pilot.md

    Note that clients can actually send three types of messages - requests, ACKs of previous pushes, and NACKs of previous pushes. Unfortunately, these are not clearly distinguished in the API, so there is some logic to split these out (`shouldRespond`).
    
    #### Pushes
    
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Feb 07 17:53:24 UTC 2024
    - 19.1K bytes
    - Viewed (0)
Back to top