Search Options

Results per page
Sort
Preferred Languages
Advance

Results 511 - 520 of 1,339 for contextos (0.15 sec)

  1. cmd/format-erasure.go

    	defer disk.Delete(context.TODO(), minioMetaBucket, tmpFormat, DeleteOptions{
    		Recursive: false,
    		Immediate: false,
    	})
    
    	// write to unique file.
    	if err = disk.WriteAll(context.TODO(), minioMetaBucket, tmpFormat, formatData); err != nil {
    		return err
    	}
    
    	// Rename file `uuid.json` --> `format.json`.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri May 24 23:05:23 UTC 2024
    - 23.2K bytes
    - Viewed (0)
  2. cmd/admin-bucket-handlers.go

    				continue
    			}
    			kmsKey := encConfig.KeyID()
    			if kmsKey != "" {
    				_, err := GlobalKMS.GenerateKey(ctx, &kms.GenerateKeyRequest{
    					Name:           kmsKey,
    					AssociatedData: kms.Context{"MinIO admin API": "ServerInfoHandler"}, // Context for a test key operation
    				})
    				if err != nil {
    					if errors.Is(err, kes.ErrKeyNotFound) {
    						rpt.SetStatus(bucket, fileName, errKMSKeyNotFound)
    						continue
    					}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 28 15:32:18 UTC 2024
    - 33.2K bytes
    - Viewed (0)
  3. .github/workflows/iam-integrations.yaml

          - master
    
    # This ensures that previous jobs for the PR are canceled when the PR is
    # updated.
    concurrency:
      group: ${{ github.workflow }}-${{ github.head_ref }}
      cancel-in-progress: true
    
    permissions:
      contents: read
    
    jobs:
      iam-matrix-test:
        name: "[Go=${{ matrix.go-version }}|ldap=${{ matrix.ldap }}|etcd=${{ matrix.etcd }}|openid=${{ matrix.openid }}]"
        runs-on: ubuntu-latest
    
        services:
          openldap:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 17 16:45:46 UTC 2024
    - 5.3K bytes
    - Viewed (0)
  4. cmd/admin-heal-ops.go

    	lastHealActivity time.Time
    
    	// Holds the request-info for logging
    	ctx context.Context
    
    	// used to lock this structure as it is concurrently accessed
    	mutex sync.RWMutex
    }
    
    // NewHealSequence - creates healSettings, assumes bucket and
    // objPrefix are already validated.
    func newHealSequence(ctx context.Context, bucket, objPrefix, clientAddr string,
    	hs madmin.HealOpts, forceStart bool,
    ) *healSequence {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 26 09:58:27 UTC 2024
    - 25.6K bytes
    - Viewed (0)
  5. okhttp/src/test/java/okhttp3/TestLogHandler.kt

          }
    
          override fun close() {
          }
        }
    
      private var previousLevel: Level? = null
    
      override fun beforeEach(context: ExtensionContext?) {
        previousLevel = logger.level
        logger.addHandler(handler)
        logger.setLevel(Level.FINEST)
      }
    
      override fun afterEach(context: ExtensionContext?) {
        logger.setLevel(previousLevel)
        logger.removeHandler(handler)
      }
    
      override fun apply(
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 2.6K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/query/BoostQueryCommand.java

        }
    
        @Override
        public QueryBuilder execute(final QueryContext context, final Query query, final float boost) {
            if (query instanceof final BoostQuery boostQuery) {
                if (logger.isDebugEnabled()) {
                    logger.debug("{}:{}", query, boost);
                }
                return getQueryProcessor().execute(context, boostQuery.getQuery(), boostQuery.getBoost());
            }
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 1.8K bytes
    - Viewed (0)
  7. cmd/tier-sweeper.go

    		globalExpiryState.enqueueTierJournalEntry(je)
    	}
    }
    
    type jentry struct {
    	ObjName   string
    	VersionID string
    	TierName  string
    }
    
    func deleteObjectFromRemoteTier(ctx context.Context, objName, rvID, tierName string) error {
    	w, err := globalTierConfigMgr.getDriver(ctx, tierName)
    	if err != nil {
    		return err
    	}
    	return w.Remove(ctx, objName, remoteVersionID(rvID))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Apr 17 05:09:58 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  8. internal/crypto/sse.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 crypto
    
    import (
    	"context"
    	"errors"
    	"fmt"
    	"io"
    	"net/http"
    
    	"github.com/minio/minio/internal/fips"
    	"github.com/minio/minio/internal/ioutil"
    	"github.com/minio/minio/internal/logger"
    	"github.com/minio/sio"
    )
    
    const (
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 30 15:26:43 UTC 2022
    - 4.4K bytes
    - Viewed (0)
  9. cni/pkg/util/podutil.go

    // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    // See the License for the specific language governing permissions and
    // limitations under the License.
    
    package util
    
    import (
    	"context"
    	"fmt"
    	"net/netip"
    
    	corev1 "k8s.io/api/core/v1"
    	"k8s.io/apimachinery/pkg/api/errors"
    	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
    	"k8s.io/apimachinery/pkg/types"
    	"k8s.io/client-go/kubernetes"
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Wed Oct 09 16:05:45 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/OkHttpClientTestRule.kt

        }
      }
    
      @SuppressLint("NewApi")
      override fun afterEach(context: ExtensionContext) {
        val failure = context.executionException.orElseGet { null }
    
        if (uncaughtException != null) {
          throw failure + AssertionError("uncaught exception thrown during test", uncaughtException)
        }
    
        if (context.isFlaky()) {
          logEvents()
        }
    
        LogManager.getLogManager().reset()
    
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Jan 08 01:13:22 UTC 2024
    - 10.5K bytes
    - Viewed (0)
Back to top