- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 620 for pushers (0.22 sec)
-
src/runtime/mspanset.go
// Every other popper must have crossed this barrier (and thus finished // popping its corresponding mspan) by the time we get here. Because // we're the last popper, we also don't have to worry about concurrent // pushers (there can't be any). Note that we may not be the popper // which claimed the last slot in the block, we're just the last one // to finish popping. if block.popped.Add(1) == spanSetBlockEntries {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 13.1K bytes - Viewed (0) -
pilot/pkg/xds/eds_test.go
errChan <- errors.New("no endpoints") wgConnect.Done() return } wgConnect.Done() // Check we received all pushes log.Infof("Waiting for pushes %v", id) // Pushes may be merged so we may not get nPushes pushes got, err := adscConn.Wait(15*time.Second, v3.EndpointType) // If in incremental mode, shouldn't receive cds|rds|lds here if inc {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Feb 02 20:58:47 UTC 2024 - 39.6K bytes - Viewed (0) -
pilot/pkg/xds/monitoring.go
pushes = monitoring.NewSum( "pilot_xds_pushes", "Pilot build and send errors for lds, rds, cds and eds.", ) cdsSendErrPushes = pushes.With(typeTag.Value("cds_senderr")) edsSendErrPushes = pushes.With(typeTag.Value("eds_senderr")) ldsSendErrPushes = pushes.With(typeTag.Value("lds_senderr")) rdsSendErrPushes = pushes.With(typeTag.Value("rds_senderr"))
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 6.7K bytes - Viewed (0) -
docs_src/bigger_applications/app_an_py39/routers/users.py
from fastapi import APIRouter router = APIRouter() @router.get("/users/", tags=["users"]) async def read_users(): return [{"username": "Rick"}, {"username": "Morty"}] @router.get("/users/me", tags=["users"]) async def read_user_me(): return {"username": "fakecurrentuser"} @router.get("/users/{username}", tags=["users"]) async def read_user(username: str):
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 18 12:29:59 UTC 2023 - 407 bytes - Viewed (0) -
architecture/networking/pilot.md
#### Pushes A push occurs when Istiod detects an update of some set of configuration is needed. This results in roughly the same result as a Request (new configuration is pushed to the client), and is just triggered by a different source.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Feb 07 17:53:24 UTC 2024 - 19.1K bytes - Viewed (0) -
pilot/pkg/xds/ads.go
} // Register the connection. this allows pushes to be triggered for the proxy. Note: the timing of // this and initializeProxy important. While registering for pushes *after* initialization is complete seems like // a better choice, it introduces a race condition; If we complete initialization of a new push // context between initializeProxy and addCon, we would not get any pushes triggered for the new
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Jun 03 08:29:05 UTC 2024 - 23.4K bytes - Viewed (0) -
docs_src/bigger_applications/app/routers/users.py
from fastapi import APIRouter router = APIRouter() @router.get("/users/", tags=["users"]) async def read_users(): return [{"username": "Rick"}, {"username": "Morty"}] @router.get("/users/me", tags=["users"]) async def read_user_me(): return {"username": "fakecurrentuser"} @router.get("/users/{username}", tags=["users"]) async def read_user(username: str):
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sun Nov 29 17:32:18 UTC 2020 - 407 bytes - Viewed (0) -
docs_src/bigger_applications/app_an/routers/users.py
from fastapi import APIRouter router = APIRouter() @router.get("/users/", tags=["users"]) async def read_users(): return [{"username": "Rick"}, {"username": "Morty"}] @router.get("/users/me", tags=["users"]) async def read_user_me(): return {"username": "fakecurrentuser"} @router.get("/users/{username}", tags=["users"]) async def read_user(username: str):
Registered: Mon Jun 17 08:32:26 UTC 2024 - Last Modified: Sat Mar 18 12:29:59 UTC 2023 - 407 bytes - Viewed (0) -
pilot/pkg/xds/discovery_test.go
} if !wgDoneOrTimeout(wg, time.Second) { t.Fatalf("Expected 5 pushes but got %v", len(pushes)) } expected := map[string]int{ "proxy-0": 1, "proxy-1": 1, "proxy-2": 1, "proxy-3": 1, "proxy-4": 1, } if !reflect.DeepEqual(expected, pushes) { t.Fatalf("Expected pushes %+v, got %+v", expected, pushes) } } type fakeStream struct { grpc.ServerStream }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 30 00:26:45 UTC 2024 - 9.2K bytes - Viewed (0) -
cmd/admin-handlers-users.go
Type: madmin.SRIAMItemIAMUser, IAMUser: &madmin.SRIAMUser{ AccessKey: accessKey, IsDeleteReq: true, }, UpdatedAt: UTCNow(), })) } // ListBucketUsers - GET /minio/admin/v3/list-users?bucket={bucket} func (a adminAPIHandlers) ListBucketUsers(w http.ResponseWriter, r *http.Request) { ctx := r.Context() objectAPI, cred := validateAdminReq(ctx, w, r, policy.ListUsersAdminAction) if objectAPI == nil {
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Tue May 28 17:19:04 UTC 2024 - 78.6K bytes - Viewed (0)