Search Options

Results per page
Sort
Preferred Languages
Advance

Results 371 - 380 of 819 for Contexto (0.17 sec)

  1. cmd/utils.go

    	ep, err := unescapeGeneric(p, escapeFn)
    	if err != nil {
    		return p
    	}
    	return ep
    }
    
    func updateReqContext(ctx context.Context, objects ...ObjectV) context.Context {
    	req := logger.GetReqInfo(ctx)
    	if req != nil {
    		req.Lock()
    		defer req.Unlock()
    		req.Objects = make([]logger.ObjectVersion, 0, len(objects))
    		for _, ov := range objects {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  2. .github/ISSUE_TEMPLATE/feature_request.md

    A clear and concise description of what you want to happen.
    
    **Describe alternatives you've considered**
    A clear and concise description of any alternative solutions or features you've considered.
    
    **Additional context**
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue May 07 20:49:54 UTC 2019
    - 610 bytes
    - Viewed (0)
  3. cmd/metrics-v3-cluster-iam.go

    )
    
    // loadClusterIAMMetrics - `MetricsLoaderFn` for cluster IAM metrics.
    func loadClusterIAMMetrics(_ context.Context, m MetricValues, _ *metricsCache) error {
    	m.Set(lastSyncDurationMillis, float64(atomic.LoadUint64(&globalIAMSys.LastRefreshDurationMilliseconds)))
    	pluginAuthNMetrics := globalAuthNPlugin.Metrics()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu May 02 08:20:42 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  4. cmd/erasure-utils.go

    		size += len(block)
    	}
    	return size
    }
    
    // Writes all the data blocks from encoded blocks until requested
    // outSize length. Provides a way to skip bytes until the offset.
    func writeDataBlocks(ctx context.Context, dst io.Writer, enBlocks [][]byte, dataBlocks int, offset int64, length int64) (int64, error) {
    	// Offset and out size cannot be negative.
    	if offset < 0 || length < 0 {
    		return 0, errUnexpected
    	}
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jan 31 02:11:45 UTC 2024
    - 3.1K bytes
    - Viewed (0)
  5. buildscripts/heal-manual.go

    	}
    
    	start, _, err := madmClnt.Heal(context.Background(), "healing-rewrite-bucket", "", opts, "", false, false)
    	if err != nil {
    		log.Fatalln(err)
    	}
    	fmt.Println("Healstart sequence ===")
    	enc := json.NewEncoder(os.Stdout)
    	if err = enc.Encode(&start); err != nil {
    		log.Fatalln(err)
    	}
    
    	fmt.Println()
    	for {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Feb 27 09:47:58 UTC 2024
    - 2.3K bytes
    - Viewed (0)
  6. internal/hash/reader.go

    // does not send more content than specified size.
    func NewReader(ctx context.Context, src io.Reader, size int64, md5Hex, sha256Hex string, actualSize int64) (*Reader, error) {
    	return newReader(ctx, src, size, md5Hex, sha256Hex, actualSize, false, nil)
    }
    
    func newReader(ctx context.Context, src io.Reader, size int64, md5Hex, sha256Hex string, actualSize int64, disableMD5 bool, forceMD5 []byte) (*Reader, error) {
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Thu Sep 19 12:59:07 UTC 2024
    - 10.9K bytes
    - Viewed (0)
  7. docs/sts/assume-role.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 main
    
    import (
    	"context"
    	"flag"
    	"fmt"
    	"io"
    	"log"
    	"net/url"
    	"os"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    	"github.com/minio/minio-go/v7"
    	cr "github.com/minio/minio-go/v7/pkg/credentials"
    )
    
    var (
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Sat Aug 17 01:24:54 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  8. cmd/erasure-decode_test.go

    // along with this program.  If not, see <http://www.gnu.org/licenses/>.
    
    package cmd
    
    import (
    	"bytes"
    	"context"
    	crand "crypto/rand"
    	"io"
    	"math/rand"
    	"testing"
    
    	"github.com/dustin/go-humanize"
    )
    
    func (a badDisk) ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error) {
    	return 0, errFaultyDisk
    }
    
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 21.1K bytes
    - Viewed (0)
  9. cmd/service.go

    )
    
    // Global service signal channel.
    var globalServiceSignalCh = make(chan serviceSignal)
    
    // GlobalContext context that is canceled when server is requested to shut down.
    // cancelGlobalContext can be used to indicate server shutdown.
    var GlobalContext, cancelGlobalContext = context.WithCancel(context.Background())
    
    // restartProcess starts a new process passing it the active fd's. It
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Feb 28 07:02:14 UTC 2024
    - 3.8K bytes
    - Viewed (0)
  10. docs/debugging/s3-verify/main.go

    		Prefix:    sourcePrefix,
    	}
    
    	topts := minio.ListObjectsOptions{
    		Recursive: true,
    		Prefix:    targetPrefix,
    	}
    
    	srcCh := sclnt.ListObjects(context.Background(), sourceBucket, sopts)
    	tgtCh := tclnt.ListObjects(context.Background(), targetBucket, topts)
    
    	srcCtnt, srcOk := nextObject(srcCh)
    	tgtCtnt, tgtOk := nextObject(tgtCh)
    
    	var srcEOF, tgtEOF bool
    
    	srcSha256 := sha256.New()
    Registered: Sun Oct 27 19:28:09 UTC 2024
    - Last Modified: Wed Jun 22 15:12:47 UTC 2022
    - 8.4K bytes
    - Viewed (0)
Back to top