Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 41 - 50 of 896 for context_a (0.04 seconds)

  1. cmd/lock-rest-client.go

    func (c *lockRESTClient) RUnlock(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCRUnlock, &args)
    }
    
    // Refresh calls Refresh REST API.
    func (c *lockRESTClient) Refresh(ctx context.Context, args dsync.LockArgs) (reply bool, err error) {
    	return c.call(ctx, lockRPCRefresh, &args)
    }
    
    // Unlock calls write unlock RPC.
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Mon Jul 29 18:10:04 GMT 2024
    - 3.3K bytes
    - Click Count (0)
  2. callbacks/associations.go

    							fv, _ := ref.PrimaryKey.ValueOf(db.Statement.Context, obj)
    							db.AddError(ref.ForeignKey.Set(db.Statement.Context, joinValue, fv))
    						} else if ref.PrimaryValue != "" {
    							db.AddError(ref.ForeignKey.Set(db.Statement.Context, joinValue, ref.PrimaryValue))
    						} else {
    							fv, _ := ref.PrimaryKey.ValueOf(db.Statement.Context, elem)
    							db.AddError(ref.ForeignKey.Set(db.Statement.Context, joinValue, fv))
    						}
    					}
    Created: Sun Dec 28 09:35:17 GMT 2025
    - Last Modified: Thu Feb 13 06:16:26 GMT 2025
    - 14.4K bytes
    - Click Count (0)
  3. cmd/object_api_suite_test.go

    		checkObjCount[key]++
    		_, err = obj.PutObject(context.Background(), "bucket", key, mustGetPutObjReader(t, bytes.NewBufferString(uploadContent), int64(len(uploadContent)), "", ""), opts)
    		if err != nil {
    			t.Fatalf("%s: <ERROR> %s", instanceType, err)
    		}
    	}
    	{
    		ctx, cancel := context.WithTimeout(context.Background(), time.Second*5)
    		defer cancel()
    		token := ""
    		for ctx.Err() == nil {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 34.5K bytes
    - Click Count (0)
  4. cmd/ftp-server-driver.go

    }
    
    // ListDir implements ftpDriver
    func (driver *ftpDriver) ListDir(ctx *ftp.Context, objPath string, callback func(os.FileInfo) error) (err error) {
    	stopFn := globalFtpMetrics.log(ctx, objPath)
    	defer stopFn(0, err)
    
    	clnt, err := driver.getMinIOClient(ctx)
    	if err != nil {
    		return err
    	}
    
    	cctx, cancel := context.WithCancel(context.Background())
    	defer cancel()
    
    	bucket, prefix := path2BucketObject(objPath)
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  5. internal/logger/targets.go

    //
    //	e.g. Send the log to a http server
    type Target interface {
    	String() string
    	Endpoint() string
    	Stats() types.TargetStats
    	Init(ctx context.Context) error
    	IsOnline(ctx context.Context) bool
    	Cancel()
    	Send(ctx context.Context, entry any) error
    	Type() types.TargetType
    }
    
    type targetsList struct {
    	list []Target
    	mu   sync.RWMutex
    }
    
    func newTargetsList() *targetsList {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Sun Sep 28 20:59:21 GMT 2025
    - 6K bytes
    - Click Count (0)
  6. cmd/config.go

    	return err
    }
    
    func readServerConfigHistory(ctx context.Context, objAPI ObjectLayer, uuidKV string) ([]byte, error) {
    	historyFile := pathJoin(minioConfigHistoryPrefix, uuidKV+kvPrefix)
    	data, err := readConfig(ctx, objAPI, historyFile)
    	if err != nil {
    		return nil, err
    	}
    
    	return decryptData(data, historyFile)
    }
    
    func saveServerConfigHistory(ctx context.Context, objAPI ObjectLayer, kv []byte) error {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.9K bytes
    - Click Count (0)
  7. internal/cachevalue/cache.go

    func NewFromFunc[T any](ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) *Cache[T] {
    	return &Cache[T]{
    		ttl:      ttl,
    		updateFn: update,
    		opts:     opts,
    	}
    }
    
    // InitOnce initializes the cache with a TTL and an update function. It is
    // guaranteed to be called only once.
    func (t *Cache[T]) InitOnce(ttl time.Duration, opts Opts, update func(ctx context.Context) (T, error)) {
    	t.Once.Do(func() {
    		t.ttl = ttl
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri May 24 12:50:46 GMT 2024
    - 4.4K bytes
    - Click Count (0)
  8. cmd/callhome.go

    package cmd
    
    import (
    	"bytes"
    	"compress/gzip"
    	"context"
    	"encoding/json"
    	"errors"
    	"fmt"
    	"math/rand"
    	"net/url"
    	"time"
    
    	"github.com/minio/madmin-go/v3"
    )
    
    var callhomeLeaderLockTimeout = newDynamicTimeout(30*time.Second, 10*time.Second)
    
    // initCallhome will start the callhome task in the background.
    func initCallhome(ctx context.Context, objAPI ObjectLayer) {
    	if !globalCallhomeConfig.Enabled() {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  9. impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/PluginUpgradeStrategyTest.java

                when(options.plugins()).thenReturn(Optional.of(true));
                when(options.all()).thenReturn(Optional.empty());
    
                UpgradeContext context = createMockContext(options);
    
                assertTrue(strategy.isApplicable(context), "Strategy should be applicable when --plugins is true");
            }
    
            @Test
            @DisplayName("should be applicable when --all option is specified")
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Tue Nov 18 18:03:26 GMT 2025
    - 27.8K bytes
    - Click Count (0)
  10. cmd/admin-handler-utils.go

    // specific error.
    func toAdminAPIErrCode(ctx context.Context, err error) APIErrorCode {
    	if errors.Is(err, errErasureWriteQuorum) {
    		return ErrAdminConfigNoQuorum
    	}
    	return toAPIErrorCode(ctx, err)
    }
    
    // wraps export error for more context
    func exportError(ctx context.Context, err error, fname, entity string) APIError {
    	if entity == "" {
    Created: Sun Dec 28 19:28:13 GMT 2025
    - Last Modified: Wed Jul 03 07:17:20 GMT 2024
    - 8.4K bytes
    - Click Count (0)
Back to Top