- Sort Score
- Result 10 results
- Languages All
Results 2371 - 2380 of 2,532 for created (0.08 sec)
-
docs/en/docs/tutorial/security/simple-oauth2.md
For the rest, **FastAPI** handles it for you. /// ## Update the dependencies Now we are going to update our dependencies. We want to get the `current_user` *only* if this user is active. So, we create an additional dependency `get_current_active_user` that in turn uses `get_current_user` as a dependency. Both of these dependencies will just return an HTTP error if the user doesn't exist, or if is inactive.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sun Oct 06 20:36:54 UTC 2024 - 12.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealRoutePlanner.kt
routes = routes, attempt = 0, tunnelRequest = tunnelRequest, connectionSpecIndex = -1, isTlsFallback = false, ) } /** * Returns a request that creates a TLS tunnel via an HTTP proxy. Everything in the tunnel request * is sent unencrypted to the proxy server, so tunnels include only the minimum set of headers.
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 12K bytes - Viewed (0) -
android/guava/src/com/google/common/collect/Multiset.java
* * <p>In addition to these required methods, implementations of {@code Multiset} are expected to * provide two {@code static} creation methods: {@code create()}, returning an empty multiset, and * {@code create(Iterable<? extends E>)}, returning a multiset containing the given initial * elements. This is simply a refinement of {@code Collection}'s constructor recommendations,
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Jun 17 14:40:53 UTC 2023 - 19.7K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/internal/ws/WebSocketRecorder.kt
private val name: String, ) : WebSocketListener() { private val events = LinkedBlockingQueue<Any>() private var delegate: WebSocketListener? = null /** Sets a delegate for handling the next callback to this listener. Cleared after invoked. */ fun setNextEventDelegate(delegate: WebSocketListener?) { this.delegate = delegate } override fun onOpen( webSocket: WebSocket, response: Response, ) {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 6.9K bytes - Viewed (0) -
istioctl/pkg/validate/validate.go
_, _ = fmt.Fprintf(writer, "%q has warnings: %v\n", fname, warningToString(w)) } else { _, _ = fmt.Fprintf(writer, "%q is valid\n", fname) } } return nil } // NewValidateCommand creates a new command for validating Istio k8s resources. func NewValidateCommand(ctx cli.Context) *cobra.Command { var filenames []string var referential bool c := &cobra.Command{
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Thu Aug 15 22:27:47 UTC 2024 - 14.3K bytes - Viewed (0) -
internal/logger/target/kafka/kafka.go
logCh := h.logCh if logCh != nil { // We are not allowed to add when logCh is nil h.wg.Add(1) defer h.wg.Done() } h.logChMu.RUnlock() if logCh == nil { return } // Create a routine which sends json logs received // from an internal channel. for entry := range logCh { h.logEntry(entry) } } func (h *Target) logEntry(entry interface{}) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10.2K bytes - Viewed (0) -
cmd/bucket-lifecycle.go
func (sys *LifecycleSys) Get(bucketName string) (lc *lifecycle.Lifecycle, err error) { lc, _, err = globalBucketMetadataSys.GetLifecycleConfig(bucketName) return lc, err } // NewLifecycleSys - creates new lifecycle system. func NewLifecycleSys() *LifecycleSys { return &LifecycleSys{} }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Oct 23 15:35:37 UTC 2024 - 33.7K bytes - Viewed (0) -
common-protos/k8s.io/api/rbac/v1beta1/generated.proto
// AggregationRule describes how to locate ClusterRoles to aggregate into the ClusterRole message AggregationRule { // ClusterRoleSelectors holds a list of selectors which will be used to find ClusterRoles and create the rules. // If any of the selectors match, then the ClusterRole's permissions will be added // +optional repeated k8s.io.apimachinery.pkg.apis.meta.v1.LabelSelector clusterRoleSelectors = 1; }
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Mon Mar 11 18:43:24 UTC 2024 - 8.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/connection/RealCall.kt
internal val lock: ReentrantLock = ReentrantLock() private val connectionPool: RealConnectionPool = client.connectionPool.delegate internal val eventListener: EventListener = client.eventListenerFactory.create(this) private val timeout = object : AsyncTimeout() { override fun timedOut() { ******@****.***() } }.apply { timeout(client.callTimeoutMillis.toLong(), MILLISECONDS)
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/EventListenerTest.kt
Request.Builder() .url(server.url("/")) .build(), ) warmUpCall.execute().use { warmUpResponse -> warmUpResponse.body.string() } listener.clearAllEvents() // Create a client with artificial delays. client = client.newBuilder() .addInterceptor( Interceptor { chain: Interceptor.Chain -> try {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Sat Jan 20 10:30:28 UTC 2024 - 56.9K bytes - Viewed (2)