Search Options

Results per page
Sort
Preferred Languages
Advance

Results 971 - 980 of 1,178 for rsync (0.04 sec)

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

    import (
    	"context"
    	"encoding/json"
    	"errors"
    	"fmt"
    	"io"
    	"net/http"
    	"sync"
    	"time"
    
    	jwtgo "github.com/golang-jwt/jwt/v4"
    	"github.com/minio/minio/internal/arn"
    	"github.com/minio/minio/internal/auth"
    	xnet "github.com/minio/pkg/v3/net"
    	"github.com/minio/pkg/v3/policy"
    )
    
    type publicKeys struct {
    	*sync.RWMutex
    
    	// map of kid to public key
    	pkMap map[string]interface{}
    }
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Sep 06 02:46:36 UTC 2024
    - 8.4K bytes
    - Viewed (0)
  2. cmd/erasure-coding.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"context"
    	"encoding/hex"
    	"fmt"
    	"os"
    	"reflect"
    	"sync"
    
    	"github.com/cespare/xxhash/v2"
    	"github.com/klauspost/reedsolomon"
    	"github.com/minio/minio/internal/logger"
    )
    
    // Erasure - erasure encoding details.
    type Erasure struct {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 8.6K bytes
    - Viewed (0)
  3. 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)
  4. cmd/admin-handlers_test.go

    package cmd
    
    import (
    	"bytes"
    	"context"
    	"encoding/json"
    	"fmt"
    	"io"
    	"net/http"
    	"net/http/httptest"
    	"net/url"
    	"sort"
    	"sync"
    	"testing"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio/internal/auth"
    	"github.com/minio/mux"
    )
    
    // adminErasureTestBed - encapsulates subsystems that need to be setup for
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jul 24 10:24:01 UTC 2024
    - 13.9K bytes
    - Viewed (0)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top