Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 54 for updatepan (0.27 sec)

  1. cmd/iam-store.go

    		cache.iamUserGroupMemberships[member] = gset
    	}
    
    	cache.updatedAt = time.Now()
    	return gi.UpdatedAt, nil
    }
    
    // RemoveUsersFromGroup - removes users from group, deleting it if it is empty.
    func (store *IAMStoreSys) RemoveUsersFromGroup(ctx context.Context, group string, members []string) (updatedAt time.Time, err error) {
    	if group == "" {
    		return updatedAt, errInvalidArgument
    	}
    
    	cache := store.lock()
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 75.8K bytes
    - Viewed (0)
  2. cmd/admin-handlers-site-replication.go

    			}
    		}
    	case madmin.SRIAMItemSvcAcc:
    		err = globalSiteReplicationSys.PeerSvcAccChangeHandler(ctx, item.SvcAccChange, item.UpdatedAt)
    	case madmin.SRIAMItemPolicyMapping:
    		err = globalSiteReplicationSys.PeerPolicyMappingHandler(ctx, item.PolicyMapping, item.UpdatedAt)
    	case madmin.SRIAMItemSTSAcc:
    		err = globalSiteReplicationSys.PeerSTSAccHandler(ctx, item.STSCredential, item.UpdatedAt)
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.4K bytes
    - Viewed (0)
  3. cmd/bucket-metadata-sys.go

    		meta.LifecycleConfigUpdatedAt = updatedAt
    	case bucketSSEConfig:
    		meta.EncryptionConfigXML = configData
    		meta.EncryptionConfigUpdatedAt = updatedAt
    	case bucketTaggingConfig:
    		meta.TaggingConfigXML = configData
    		meta.TaggingConfigUpdatedAt = updatedAt
    	case bucketQuotaConfigFile:
    		meta.QuotaConfigJSON = configData
    		meta.QuotaConfigUpdatedAt = updatedAt
    	case objectLockConfig:
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 19.8K bytes
    - Viewed (0)
  4. tests/non_std_test.go

    	CreatedAt  time.Time
    	UpdatedAt  time.Time
    }
    
    func TestNonStdPrimaryKeyAndDefaultValues(t *testing.T) {
    	DB.Migrator().DropTable(&Animal{})
    	if err := DB.AutoMigrate(&Animal{}); err != nil {
    		t.Fatalf("no error should happen when migrate but got %v", err)
    	}
    
    	animal := Animal{Name: "Ferdinand"}
    	DB.Save(&animal)
    	updatedAt1 := animal.UpdatedAt
    
    	DB.Save(&animal).Update("name", "Francis")
    Registered: Wed Jun 12 16:27:09 UTC 2024
    - Last Modified: Wed May 08 04:07:58 UTC 2024
    - 1.9K bytes
    - Viewed (0)
  5. cmd/bucket-policy-handlers.go

    		Type:      madmin.SRBucketMetaTypePolicy,
    		Bucket:    bucket,
    		Policy:    bucketPolicyBytes,
    		UpdatedAt: updatedAt,
    	}))
    
    	// Success.
    	writeSuccessNoContent(w)
    }
    
    // DeleteBucketPolicyHandler - This HTTP handler removes bucket policy configuration.
    func (api objectAPIHandlers) DeleteBucketPolicyHandler(w http.ResponseWriter, r *http.Request) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.1K bytes
    - Viewed (0)
  6. cmd/site-replication.go

    	if change == nil {
    		return errSRInvalidRequest(errInvalidArgument)
    	}
    	// skip overwrite of local update if peer sent stale info
    	if !updatedAt.IsZero() {
    		if ui, err := globalIAMSys.GetUserInfo(ctx, change.AccessKey); err == nil && ui.UpdatedAt.After(updatedAt) {
    			return nil
    		}
    	}
    
    	var err error
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 184.3K bytes
    - Viewed (0)
  7. cmd/bucket-encryption-handlers.go

    	replLogIf(ctx, globalSiteReplicationSys.BucketMetaHook(ctx, madmin.SRBucketMeta{
    		Type:      madmin.SRBucketMetaTypeSSEConfig,
    		Bucket:    bucket,
    		SSEConfig: &cfgStr,
    		UpdatedAt: updatedAt,
    	}))
    
    	writeSuccessResponseHeadersOnly(w)
    }
    
    // GetBucketEncryptionHandler - Returns bucket policy configuration
    // https://docs.aws.amazon.com/AmazonS3/latest/API/API_GetBucketEncryption.html
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 6.4K bytes
    - Viewed (0)
  8. cmd/iam.go

    	if !sys.Initialized() {
    		return updatedAt, errServerNotInitialized
    	}
    
    	updatedAt, err = sys.store.UpdateServiceAccount(ctx, accessKey, opts)
    	if err != nil {
    		return updatedAt, err
    	}
    
    	sys.notifyForServiceAccount(ctx, accessKey)
    	return updatedAt, nil
    }
    
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Thu Jun 13 22:26:38 UTC 2024
    - 71.9K bytes
    - Viewed (0)
  9. staging/src/k8s.io/apiserver/pkg/endpoints/handlers/rest_test.go

    	tc.startingPod.APIVersion = examplev1.SchemeGroupVersion.String()
    
    	// pod with rv=3 is found when attempting to persist the update
    	tc.updatePod.Name = name
    	tc.updatePod.Namespace = namespace
    	tc.updatePod.UID = uid
    	tc.updatePod.ResourceVersion = "3"
    	tc.updatePod.APIVersion = examplev1.SchemeGroupVersion.String()
    
    	// patches are submitted with a rv=2
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue May 28 08:48:22 UTC 2024
    - 41.8K bytes
    - Viewed (0)
  10. pkg/kubelet/pod_workers_test.go

    	holds   map[types.UID]chan struct{}
    }
    
    // UpdatePod increments the clock after UpdatePod is called, but before the workers
    // are invoked, and then drains all workers before returning. The provided functions
    // are invoked while holding the lock to prevent workers from receiving updates.
    func (w *timeIncrementingWorkers) UpdatePod(options UpdatePodOptions, afterFns ...func()) {
    	func() {
    		w.lock.Lock()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Jun 04 06:25:43 UTC 2024
    - 75.6K bytes
    - Viewed (0)
Back to top