Deta - Code Search

cmd/warm-backend-minio.go

	partSize = int64(partSizeFlt)
	if partSize == 0 {
		return minPartSize, nil
	}
	return partSize, nil
}

func (m *warmBackendMinIO) PutWithMeta(ctx context.Context, object string, r io.Reader, length int64, meta map[string]string) (remoteVersionID, error) {
	partSize, err := optimalPartSize(length)
	if err != nil {
		return remoteVersionID(""), err
	}

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Thu Oct 31 22:10:24 UTC 2024

- 4K bytes

- Viewed (0)

github.com/google/guava

guava/src/com/google/common/hash/PrimitiveSink.java

package com.google.common.hash;

import com.google.common.annotations.Beta;
import com.google.errorprone.annotations.CanIgnoreReturnValue;
import java.nio.ByteBuffer;
import java.nio.charset.Charset;

/**
 * An object which can receive a stream of primitive values.
 *
 * @author Kevin Bourrillion
 * @since 12.0 (in 11.0 as {@code Sink})
 */
@Beta
@ElementTypesAreNonnullByDefault
public interface PrimitiveSink {
  /**

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Wed Jun 15 20:59:00 UTC 2022

- 3.9K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/graph/ValueGraphBuilder.java

import static com.google.common.base.Preconditions.checkArgument;
import static com.google.common.base.Preconditions.checkNotNull;
import static com.google.common.graph.Graphs.checkNonNegative;

import com.google.common.annotations.Beta;
import com.google.common.base.Optional;
import com.google.errorprone.annotations.CanIgnoreReturnValue;

/**
 * A builder for constructing instances of {@link MutableValueGraph} or {@link ImmutableValueGraph}

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri Jun 03 01:21:31 UTC 2022

- 8K bytes

- Viewed (0)

github.com/minio/minio

cmd/event-notification.go

			arns = append(arns, targetID.ToARN(region).String())
		}
	}

	return arns
}

// Loads notification policies for all buckets into EventNotifier.
func (evnot *EventNotifier) set(bucket string, meta BucketMetadata) {
	config := meta.notificationConfig
	if config == nil {
		return
	}
	region := globalSite.Region()
	config.SetRegion(region)
	if err := config.Validate(region, globalEventNotifier.targetList); err != nil {

Registered: Sun Nov 03 19:28:11 UTC 2024

- Last Modified: Fri Jun 21 22:22:24 UTC 2024

- 7.7K bytes

- Viewed (0)

github.com/google/guava

android/guava/src/com/google/common/hash/HashingOutputStream.java

import static com.google.common.base.Preconditions.checkNotNull;

import com.google.common.annotations.Beta;
import java.io.FilterOutputStream;
import java.io.IOException;
import java.io.OutputStream;

/**
 * An {@link OutputStream} that maintains a hash of the data written to it.
 *
 * @author Zoe Piepmeier
 * @since 16.0
 */
@Beta
@ElementTypesAreNonnullByDefault
public final class HashingOutputStream extends FilterOutputStream {

Registered: Fri Nov 01 12:43:10 UTC 2024

- Last Modified: Fri Oct 11 22:00:03 UTC 2024

- 2.6K bytes

- Viewed (0)

github.com/gradle/gradle

build-logic/buildquality/src/main/kotlin/gradlebuild/incubation/action/IncubatingApiReportAggregationWorkAction.kt

            writer.println(
                """<html lang="en">
    <head>
       <META http-equiv="Content-Type" content="text/html; charset=UTF-8">
       <title>Incubating APIs</title>
       <link xmlns:xslthl="http://xslthl.sf.net" rel="stylesheet" href="https://fonts.googleapis.com/css?family=Lato:400,400i,700">
       <meta xmlns:xslthl="http://xslthl.sf.net" content="width=device-width, initial-scale=1" name="viewport">

Registered: Wed Nov 06 11:36:14 UTC 2024

- Last Modified: Mon Jan 18 06:55:55 UTC 2021

- 3.4K bytes

- Viewed (0)

github.com/kubernetes/kubernetes

CHANGELOG/CHANGELOG-1.27.md

- Graduated CRI Events driven Pod LifeCycle Event Generator (Evented PLEG) to Beta ([#115967](https://github.com/kubernetes/kubernetes/pull/115967), [@harche](https://github.com/harche))
- Graduated `matchLabelKeys` in `podTopologySpread` to Beta ([#116291](https://github.com/kubernetes/kubernetes/pull/116291), [@denkensk](https://github.com/denkensk))

Registered: Fri Nov 01 09:05:11 UTC 2024

- Last Modified: Wed Jul 17 07:48:22 UTC 2024

- 466.3K bytes

- Viewed (1)

github.com/codelibs/fess

src/main/resources/fess_se++.xml

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE components PUBLIC "-//DBFLUTE//DTD LastaDi 1.0//EN"
	"http://dbflute.org/meta/lastadi10.dtd">
<components>
	<component name="groovyEngine"
		class="org.codelibs.fess.script.groovy.GroovyEngine">
		<postConstruct name="register"></postConstruct>
	</component>

Registered: Thu Oct 31 13:40:30 UTC 2024

- Last Modified: Mon Oct 21 12:16:01 UTC 2024

- 322 bytes

- Viewed (0)

github.com/golang/go

misc/wasm/wasm_exec.html

<!doctype html>
<!--
Copyright 2018 The Go Authors. All rights reserved.
Use of this source code is governed by a BSD-style
license that can be found in the LICENSE file.
-->
<html>

<head>
	<meta charset="utf-8">
	<title>Go wasm</title>
</head>

<body>
	<!--
	Add the following polyfill for Microsoft Edge 17/18 support:
	<script src="https://cdn.jsdelivr.net/npm/text-encoding@0.7.0/lib/encoding.min.js"></script>

Registered: Tue Nov 05 11:13:11 UTC 2024

- Last Modified: Fri Aug 30 19:15:21 UTC 2024

- 1.3K bytes

- Viewed (0)

github.com/istio/istio

istioctl/pkg/multicluster/cluster.go

// See the License for the specific language governing permissions and
// limitations under the License.

package multicluster

import (
	"context"

	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
	"k8s.io/apimachinery/pkg/types"
	"k8s.io/client-go/kubernetes"
)

// Use UUID of kube-system Namespace as unique identifier for cluster.

Registered: Wed Nov 06 22:53:10 UTC 2024

- Last Modified: Fri Sep 02 03:11:58 UTC 2022

- 1.1K bytes

- Viewed (0)

Search Options