- Sort Score
- Result 10 results
- Languages All
Results 211 - 220 of 714 for Contexto (0.11 sec)
-
cmd/erasure-encode_test.go
return nil, errFaultyDisk } func (a badDisk) CreateFile(ctx context.Context, origvolume, volume, path string, size int64, reader io.Reader) error { return errFaultyDisk } func (badDisk) Hostname() string { return "" } const oneMiByte = 1 * humanize.MiByte var erasureEncodeTests = []struct { dataBlocks int
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 11.9K bytes - Viewed (0) -
internal/grid/manager.go
// Sign a token for the given audience. AuthFn AuthFn // Callbacks to validate incoming connections. AuthToken ValidateTokenFn } // NewManager creates a new grid manager func NewManager(ctx context.Context, o ManagerOptions) (*Manager, error) { found := false if o.AuthToken == nil { return nil, fmt.Errorf("grid: AuthToken not set") } if o.Dialer == nil { return nil, fmt.Errorf("grid: Dialer not set") }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Mon Jul 29 18:10:04 UTC 2024 - 10.6K bytes - Viewed (0) -
cmd/http-tracer.go
r.Body = reqRecorder // Create tracing data structure and associate it to the request context tc := mcontext.TraceCtxt{ AmzReqID: w.Header().Get(xhttp.AmzRequestID), RequestRecorder: reqRecorder, ResponseRecorder: respRecorder, } r = r.WithContext(context.WithValue(r.Context(), mcontext.ContextTraceKey, &tc)) reqStartTime := time.Now().UTC() h.ServeHTTP(respRecorder, r)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Sep 24 17:13:00 UTC 2024 - 6K bytes - Viewed (0) -
internal/crypto/sse-s3.go
} keyID, kmsKey, sealedKey, err := s3.ParseMetadata(metadata) if err != nil { return key, err } unsealKey, err := k.Decrypt(context.TODO(), &kms.DecryptRequest{ Name: keyID, Ciphertext: kmsKey, AssociatedData: kms.Context{bucket: path.Join(bucket, object)}, }) if err != nil { return key, err } err = key.Unseal(unsealKey, sealedKey, s3.String(), bucket, object)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue May 07 23:55:37 UTC 2024 - 7.6K bytes - Viewed (0) -
internal/crypto/key.go
} if len(extKey) != 32 { // safety check logger.CriticalIf(context.Background(), errors.New("crypto: invalid key length")) } var nonce [32]byte if _, err := io.ReadFull(random, nonce[:]); err != nil { logger.CriticalIf(context.Background(), errOutOfEntropy) } const Context = "object-encryption-key generation" mac := hmac.New(sha256.New, extKey) mac.Write([]byte(Context)) mac.Write(nonce[:]) mac.Sum(key[:0]) return key
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Mar 19 20:28:10 UTC 2024 - 6.4K bytes - Viewed (0) -
cmd/lock-rest-server-common_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "context" "os" "reflect" "sync" "testing" "github.com/minio/minio/internal/dsync" ) // Helper function to create a lock server for testing func createLockTestServer(ctx context.Context, t *testing.T) (string, *lockRESTServer, string) { obj, fsDir, err := prepareFS(ctx) if err != nil { t.Fatal(err)
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 3.2K bytes - Viewed (0) -
internal/store/batch_test.go
} var limit uint32 = 100 batch := NewBatch[TestItem](BatchConfig[TestItem]{ Limit: limit, Store: store, CommitTimeout: 5 * time.Minute, Log: func(ctx context.Context, err error, id string, errKind ...interface{}) { t.Log(err) }, }) defer batch.Close() for i := 0; i < int(limit); i++ { if err := batch.Add(testItem); err != nil {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 5.6K bytes - Viewed (0) -
internal/http/listener.go
opts TCPOptions listeners []net.Listener // underlying TCP listeners. acceptCh chan acceptResult // channel where all TCP listeners write accepted connection. ctx context.Context ctxCanceler context.CancelFunc } // start - starts separate goroutine for each TCP listener. A valid new connection is passed to httpListener.acceptCh. func (listener *httpListener) start() {
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Tue Jul 23 10:53:03 UTC 2024 - 5.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/base/FessBaseAction.java
private static final Logger logger = LogManager.getLogger(FessBaseAction.class); /** The application type for FESs, e.g. used by access context. */ protected static final String APP_TYPE = "FES"; // #change_it_first /** The user type for Admin, e.g. used by access context. */ protected static final String USER_TYPE = "A"; // ===================================================================================
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Thu Feb 22 01:53:18 UTC 2024 - 9.3K bytes - Viewed (0) -
internal/http/check_port_linux.go
// the specified interface if any. _ = syscall.SetsockoptString(int(fdPtr), syscall.SOL_SOCKET, syscall.SO_BINDTODEVICE, opts.Interface) } }) return nil }, } ctx, cancel := context.WithTimeout(context.Background(), time.Second) defer cancel() l, err := lc.Listen(ctx, "tcp", net.JoinHostPort(host, port)) if err != nil { return err }
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Wed May 03 21:12:25 UTC 2023 - 1.9K bytes - Viewed (0)