- Sort Score
- Result 10 results
- Languages All
Results 481 - 490 of 1,719 for onText (0.05 sec)
-
cmd/local-locker_test.go
package cmd import ( "context" "encoding/hex" "fmt" "math/rand" "testing" "time" "github.com/google/uuid" "github.com/minio/minio/internal/dsync" ) func TestLocalLockerExpire(t *testing.T) { wResources := make([]string, 1000) rResources := make([]string, 1000) quorum := 0 l := newLocker() ctx := context.Background() for i := range wResources {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jul 24 10:24:01 UTC 2024 - 11.9K bytes - Viewed (0) -
cmd/metrics-v3-cluster-iam.go
) // loadClusterIAMMetrics - `MetricsLoaderFn` for cluster IAM metrics. func loadClusterIAMMetrics(_ context.Context, m MetricValues, _ *metricsCache) error { m.Set(lastSyncDurationMillis, float64(atomic.LoadUint64(&globalIAMSys.LastRefreshDurationMilliseconds))) pluginAuthNMetrics := globalAuthNPlugin.Metrics()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 02 08:20:42 UTC 2024 - 4.5K bytes - Viewed (0) -
compat/maven-model-builder/src/main/java/org/apache/maven/model/profile/activation/FileProfileActivator.java
this.profileActivationFilePathInterpolator = profileActivationFilePathInterpolator; } @Override public boolean isActive(Profile profile, ProfileActivationContext context, ModelProblemCollector problems) { Activation activation = profile.getActivation(); if (activation == null) { return false; } ActivationFile file = activation.getFile();
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4.2K bytes - Viewed (0) -
src/test/java/jcifs/tests/BaseCIFSTest.java
import jcifs.config.PropertyConfiguration; import jcifs.context.BaseContext; import jcifs.context.CIFSContextWrapper; import jcifs.smb.NtlmPasswordAuthenticator; import jcifs.smb.SmbFile; /** * @author mbechler * */ @SuppressWarnings ( "javadoc" ) public abstract class BaseCIFSTest { private Map<String, String> properties; private CIFSContext context; private Random rand = new Random();
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Sun Jul 01 13:12:10 UTC 2018 - 8.1K bytes - Viewed (0) -
istioctl/pkg/authz/authz.go
pods, err := kubeClient.GetIstioPods(context.TODO(), podNamespace, metav1.ListOptions{ FieldSelector: "metadata.name=" + podName, }) if err != nil { return nil, fmt.Errorf("failed to get pod: %s", err) } if len(pods) != 1 { return nil, fmt.Errorf("expecting only 1 pod for %s.%s, found: %d", podName, podNamespace, len(pods)) } data, err := kubeClient.EnvoyDo(context.TODO(), podName, podNamespace, "GET", "config_dump")
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 5K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/goals/Diag.java
super(messageBuilderFactory, secDispatcher); } @Override protected int doExecute(DefaultEncryptInvoker.LocalContext context) { dumpResponse(context, "", secDispatcher.validateConfiguration()); return OK; }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 1.6K bytes - Viewed (0) -
docs/extensions/fan-out/README.md
Fan-Out uploads are automatically enabled if `x-minio-fanout-list` form-field is provided with the PostUpload API, to keep things simple higher level APIs are provided in our SDKs for example in `minio-go` SDK: ``` PutObjectFanOut(ctx context.Context, bucket string, fanOutContent io.Reader, fanOutReq minio.PutObjectFanOutRequest) ([]minio.PutObjectFanOutResponse, error)
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu May 25 05:51:07 UTC 2023 - 1.4K bytes - Viewed (0) -
docs/en/docs/tutorial/security/oauth2-jwt.md
/// ## Hash and verify the passwords Import the tools we need from `passlib`. Create a PassLib "context". This is what will be used to hash and verify passwords. /// tip The PassLib context also has functionality to use different hashing algorithms, including deprecated old ones only to allow verifying them, etc.
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Sat Oct 26 11:45:10 UTC 2024 - 12.8K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/AcceptedRegressionsRuleSetup.java
} @Override @SuppressWarnings("unchecked") public void execute(ViolationCheckContext context) { Map<String, Object> userData = (Map<String, Object>) context.getUserData(); userData.put("acceptedApiChanges", acceptedApiChanges); userData.put("seenApiChanges", new HashSet<ApiChange>()); }
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Wed Dec 09 08:14:05 UTC 2020 - 1.6K bytes - Viewed (0) -
internal/hash/reader.go
// does not send more content than specified size. func NewReader(ctx context.Context, src io.Reader, size int64, md5Hex, sha256Hex string, actualSize int64) (*Reader, error) { return newReader(ctx, src, size, md5Hex, sha256Hex, actualSize, false, nil) } func newReader(ctx context.Context, src io.Reader, size int64, md5Hex, sha256Hex string, actualSize int64, disableMD5 bool, forceMD5 []byte) (*Reader, error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 19 12:59:07 UTC 2024 - 10.9K bytes - Viewed (0)