Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for RemoveObject (0.12 sec)

  1. operator/pkg/cache/cache.go

    		objectCaches[name] = &ObjectCache{
    			Cache: make(map[string]*object.K8sObject),
    			Mu:    &sync.RWMutex{},
    		}
    	}
    	return objectCaches[name]
    }
    
    // RemoveObject removes object with objHash in the Cache with the given name from the object Cache.
    func RemoveObject(name, objHash string) {
    	objectCachesMu.RLock()
    	objectCache := objectCaches[name]
    	objectCachesMu.RUnlock()
    
    	if objectCache != nil {
    		objectCache.Mu.Lock()
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Wed Dec 06 13:12:49 UTC 2023
    - 2.4K bytes
    - Viewed (0)
  2. operator/pkg/cache/cache_test.go

    			},
    		},
    	}
    	for _, tt := range tests {
    		t.Run(tt.desc, func(t *testing.T) {
    			for key, value := range tt.in {
    				objectCaches[key] = value
    			}
    			defer FlushObjectCaches()
    			RemoveObject(tt.objCacheRemovalKey, tt.removalKey)
    			if got := objectCaches[tt.objCacheRemovalKey]; !reflect.DeepEqual(*got, tt.expectedCache) {
    				t.Errorf("%s: expected object cache %v, got %v\n", tt.desc, tt.expectedCache, got)
    			}
    Registered: Fri Jun 14 15:00:06 UTC 2024
    - Last Modified: Fri Jan 20 18:46:12 UTC 2023
    - 5.3K bytes
    - Viewed (0)
  3. cmd/warm-backend-s3.go

    }
    
    func (s3 *warmBackendS3) Remove(ctx context.Context, object string, rv remoteVersionID) error {
    	ropts := minio.RemoveObjectOptions{}
    	if rv != "" {
    		ropts.VersionID = string(rv)
    	}
    	err := s3.client.RemoveObject(ctx, s3.Bucket, s3.getDest(object), ropts)
    	return s3.ToObjectError(err, object)
    }
    
    func (s3 *warmBackendS3) InUse(ctx context.Context) (bool, error) {
    Registered: Sun Jun 16 00:44:34 UTC 2024
    - Last Modified: Sun Apr 21 11:43:18 UTC 2024
    - 5.5K bytes
    - Viewed (0)
Back to top