Search Options

Results per page
Sort
Preferred Languages
Advance

Results 981 - 990 of 1,181 for rsync (0.03 sec)

  1. internal/config/identity/openid/openid.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package openid
    
    import (
    	"crypto/sha1"
    	"encoding/base64"
    	"errors"
    	"io"
    	"net/http"
    	"sort"
    	"strconv"
    	"strings"
    	"sync"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7/pkg/set"
    	"github.com/minio/minio/internal/arn"
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/minio/internal/config"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 10 20:16:44 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  2. cni/pkg/nodeagent/server.go

    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package nodeagent
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"net/netip"
    	"os"
    	"path/filepath"
    	"sync/atomic"
    
    	"golang.org/x/sys/unix"
    	corev1 "k8s.io/api/core/v1"
    	"k8s.io/client-go/kubernetes"
    	"k8s.io/client-go/rest"
    
    	pconstants "istio.io/istio/cni/pkg/constants"
    	"istio.io/istio/cni/pkg/ipset"
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Sep 25 20:54:34 UTC 2024
    - 13.4K bytes
    - Viewed (0)
  3. docs/en/docs/advanced/custom-response.md

    ```Python hl_lines="2  7  9"
    {!../../docs_src/custom_response/tutorial006c.py!}
    ```
    
    ### `StreamingResponse`
    
    Takes an async generator or a normal generator/iterator and streams the response body.
    
    ```Python hl_lines="2  14"
    {!../../docs_src/custom_response/tutorial007.py!}
    ```
    
    #### Using `StreamingResponse` with file-like objects
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 12K bytes
    - Viewed (0)
  4. cmd/os_other.go

    				remaining--
    			}
    		}
    	}
    	return entries, nil
    }
    
    func globalSync() {
    	// no-op not sure about plan9/solaris support for syscall support
    	defer globalOSMetrics.time(osMetricSync)()
    	syscall.Sync()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Sep 13 15:14:36 UTC 2023
    - 4K bytes
    - Viewed (0)
  5. go.sum

    golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
    golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
    golang.org/x/sync v0.0.0-20220722155255-886fb9371eb4/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
    golang.org/x/sync v0.1.0/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Nov 06 06:23:25 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  6. cmd/batch-handlers.go

    //msgp:ignore BatchJobPool
    
    // BatchJobPool batch job pool
    type BatchJobPool struct {
    	ctx          context.Context
    	objLayer     ObjectLayer
    	once         sync.Once
    	mu           sync.Mutex
    	jobCh        chan *BatchJobRequest
    	jmu          sync.Mutex // protects jobCancelers
    	jobCancelers map[string]context.CancelFunc
    	workerKillCh chan struct{}
    	workerSize   int
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  7. docs/uk/docs/tutorial/first-steps.md

    У даному випадку це асинхронна функція.
    
    ---
    
    Ви також можете визначити її як звичайну функцію замість `async def`:
    
    ```Python hl_lines="7"
    {!../../docs_src/first_steps/tutorial003.py!}
    ```
    
    /// note | "Примітка"
    
    Якщо не знаєте в чому різниця, подивіться [Конкурентність: *"Поспішаєш?"*](../async.md#in-a-hurry){.internal-link target=_blank}.
    
    ///
    
    ### Крок 5: поверніть результат
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 15.6K bytes
    - Viewed (0)
  8. docs/zh/docs/tutorial/dependencies/sub-dependencies.md

    在高级使用场景中,如果不想使用「缓存」值,而是为需要在同一请求的每一步操作(多次)中都实际调用依赖项,可以把 `Depends` 的参数 `use_cache` 的值设置为 `False` :
    
    ```Python hl_lines="1"
    async def needy_dependency(fresh_value: str = Depends(get_value, use_cache=False)):
        return {"fresh_value": fresh_value}
    ```
    
    ## 小结
    
    千万别被本章里这些花里胡哨的词藻吓倒了,其实**依赖注入**系统非常简单。
    
    依赖注入无非是与*路径操作函数*一样的函数罢了。
    
    Registered: Sun Nov 03 07:19:11 UTC 2024
    - Last Modified: Sun Oct 06 20:36:54 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  9. internal/s3select/jstream/scanner_test.go

    package jstream
    
    import (
    	"bufio"
    	"bytes"
    	"fmt"
    	"io"
    	"sync/atomic"
    	"testing"
    )
    
    var (
    	smallInput  = make([]byte, 1024*12)       // 12K
    	mediumInput = make([]byte, 1024*1024*12)  // 12MB
    	largeInput  = make([]byte, 1024*1024*128) // 128MB
    )
    
    func TestScanner(t *testing.T) {
    	data := []byte("abcdefghijklmnopqrstuvwxyz0123456789")
    
    	var i int
    	r := bytes.NewReader(data)
    	scanner := newScanner(r)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Sep 23 19:35:41 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  10. istioctl/pkg/writer/pilot/status.go

    	"istio.io/istio/istioctl/pkg/multixds"
    	"istio.io/istio/pilot/pkg/model"
    	xdsresource "istio.io/istio/pilot/pkg/xds/v3"
    	"istio.io/istio/pkg/log"
    )
    
    // XdsStatusWriter enables printing of sync status using multiple xdsapi.DiscoveryResponse Istiod responses
    type XdsStatusWriter struct {
    	Writer                 io.Writer
    	Namespace              string
    	InternalDebugAllIstiod bool
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Fri Jun 21 22:47:20 UTC 2024
    - 6.5K bytes
    - Viewed (0)
Back to top