- Sort Score
- Result 10 results
- Languages All
Results 891 - 900 of 1,178 for rsync (0.13 sec)
-
tests/test_datastructures.py
assert testing_file_store assert testing_file_store[0].file.closed # For UploadFile coverage, segments copied from Starlette tests @pytest.mark.anyio async def test_upload_file(): stream = io.BytesIO(b"data") file = UploadFile(filename="file", file=stream, size=4) assert await file.read() == b"data" assert file.size == 4 await file.write(b" and more data!")
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Wed Oct 18 12:36:40 UTC 2023 - 2K bytes - Viewed (0) -
internal/config/identity/openid/provider/keycloak.go
"errors" "fmt" "net/http" "net/url" "path" "strings" "sync" ) // Token - parses the output from IDP id_token. type Token struct { AccessToken string `json:"access_token"` Expiry int `json:"expires_in"` } // KeycloakProvider implements Provider interface for KeyCloak Identity Provider. type KeycloakProvider struct { sync.Mutex oeConfig DiscoveryDoc client http.Client adminURL string
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Jul 14 18:12:07 UTC 2024 - 4.6K bytes - Viewed (0) -
internal/config/browser/browser.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package browser import ( "fmt" "strconv" "sync" "github.com/minio/minio/internal/config" "github.com/minio/pkg/v3/env" ) // Browser sub-system constants const ( // browserCSPPolicy setting name for Content-Security-Policy response header value
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 00:58:58 UTC 2024 - 5.9K bytes - Viewed (0) -
cni/pkg/nodeagent/pod_cache.go
// See the License for the specific language governing permissions and // limitations under the License. package nodeagent import ( "errors" "fmt" "path/filepath" "runtime" "sync" corev1 "k8s.io/api/core/v1" "istio.io/istio/pkg/maps" "istio.io/istio/pkg/zdsapi" ) var ErrPodNotFound = errors.New("netns not provided, but is needed as pod is not in cache")
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri May 31 17:18:11 UTC 2024 - 4.3K bytes - Viewed (0) -
cmd/event-notification.go
"fmt" "net/url" "runtime" "strings" "sync" "github.com/minio/minio/internal/crypto" "github.com/minio/minio/internal/event" xhttp "github.com/minio/minio/internal/http" "github.com/minio/minio/internal/pubsub" "github.com/minio/pkg/v3/policy" ) // EventNotifier - notifies external systems about events in MinIO. type EventNotifier struct { sync.RWMutex targetList *event.TargetList
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jun 21 22:22:24 UTC 2024 - 7.7K bytes - Viewed (0) -
internal/store/batch_test.go
// // You should have received a copy of the GNU Affero General Public License // along with this program. If not, see <http://www.gnu.org/licenses/>. package store import ( "context" "sync" "testing" "time" ) func TestBatchCommit(t *testing.T) { defer func() { if err := tearDownQueueStore(); err != nil { t.Fatalf("Failed to tear down store; %v", err) } }()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 5.6K bytes - Viewed (0) -
README.md
<details markdown="1"> <summary>Or use <code>async def</code>...</summary> If your code uses `async` / `await`, use `async def`: ```Python hl_lines="9 14" from typing import Union from fastapi import FastAPI app = FastAPI() @app.get("/") async def read_root(): return {"Hello": "World"} @app.get("/items/{item_id}") async def read_item(item_id: int, q: Union[str, None] = None):
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Thu Oct 31 09:13:26 UTC 2024 - 23.6K bytes - Viewed (0) -
MIGRATION.md
Using the, you can replace existing GSS/CSE JavaScript codes with: ``` <script> (function() { var fess = document.createElement('script'); fess.type = 'text/javascript'; fess.async = true; fess.src = '//<Fess Server Name>/js/ss/fess-ss.min.js'; fess.charset = 'utf-8'; fess.setAttribute('id', 'fess-ss'); fess.setAttribute('fess-url', '//<Server Name>/json');
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Tue Mar 05 06:12:02 UTC 2019 - 1.6K bytes - Viewed (0) -
docs/em/docs/tutorial/dependencies/dependencies-with-yield.md
```Python hl_lines="4" {!../../docs_src/dependencies/tutorial007.py!} ``` 📟 📄 `yield` 📄 🛠️ ⏮️ 📨 ✔️ 🚚: ```Python hl_lines="5-6" {!../../docs_src/dependencies/tutorial007.py!} ``` /// tip 👆 💪 ⚙️ `async` ⚖️ 😐 🔢. **FastAPI** 🔜 ▶️️ 👜 ⏮️ 🔠, 🎏 ⏮️ 😐 🔗. /// ## 🔗 ⏮️ `yield` & `try` 🚥 👆 ⚙️ `try` 🍫 🔗 ⏮️ `yield`, 👆 🔜 📨 🙆 ⚠ 👈 🚮 🕐❔ ⚙️ 🔗.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 8.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/AsyncDns.kt
* */ package okhttp3 import java.net.InetAddress import java.net.UnknownHostException import java.util.concurrent.CountDownLatch import okio.IOException /** * An async domain name service that resolves IP addresses for host names. * * The main implementations will typically be implemented using specific DNS libraries such as * * Android DnsResolver * * OkHttp DnsOverHttps
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Tue Jan 23 14:31:42 UTC 2024 - 3.5K bytes - Viewed (0)