- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for makeResp (1.36 sec)
-
cmd/lock-rest-server.go
resp := lockRPCRefresh.NewResponse() refreshed, err := l.ll.Refresh(context.Background(), *args) if err != nil { return l.makeResp(resp, err) } if !refreshed { return l.makeResp(resp, errLockNotFound) } return l.makeResp(resp, err) } // LockHandler - Acquires a lock. func (l *lockRESTServer) LockHandler(args *dsync.LockArgs) (*dsync.LockResp, *grid.RemoteErr) {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue Nov 21 01:09:35 UTC 2023 - 5.9K bytes - Viewed (0) -
pilot/pkg/xds/xds_cache_test.go
} } func TestXdsCache(t *testing.T) { makeEp := func(subset string, dr *model.ConsolidatedDestRule) *endpoints.EndpointBuilder { svc := &model.Service{Hostname: "foo.com"} b := endpoints.NewCDSEndpointBuilder( proxy, nil, fmt.Sprintf("outbound|%s|foo.com", subset), model.TrafficDirectionOutbound, subset, "foo.com", 80, svc, dr) return b } ep1 := makeEp("1", nil) ep2 := makeEp("2", nil)
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Aug 31 20:43:08 UTC 2023 - 7.8K bytes - Viewed (0)