- Sort Score
- Result 10 results
- Languages All
Results 431 - 440 of 1,339 for contextos (0.06 sec)
-
istioctl/pkg/proxystatus/proxystatus.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 proxystatus import ( "context" "fmt" "io" "os" discovery "github.com/envoyproxy/go-control-plane/envoy/service/discovery/v3" "github.com/spf13/cobra" "istio.io/istio/istioctl/pkg/cli" "istio.io/istio/istioctl/pkg/clioptions"
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 6.2K bytes - Viewed (0) -
src/main/java/jcifs/ntlmssp/Type3Message.java
private byte[] mic = null; private boolean micRequired; /** * Creates a Type-3 message using default values from the current * environment. * * @param tc * context to use */ public Type3Message ( CIFSContext tc ) { setFlags(getDefaultFlags(tc)); setDomain(tc.getConfig().getDefaultDomain()); setUser(tc.getConfig().getDefaultUsername());
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Tue Jul 07 12:07:20 UTC 2020 - 30.6K bytes - Viewed (0) -
cmd/metrics-v3-cluster-notification.go
) // loadClusterNotificationMetrics - `MetricsLoaderFn` for cluster notification metrics. func loadClusterNotificationMetrics(_ context.Context, m MetricValues, _ *metricsCache) error { if globalEventNotifier == nil { return nil } nstats := globalEventNotifier.targetList.Stats() m.Set(notificationCurrentSendInProgress, float64(nstats.CurrentSendCalls))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Apr 24 04:10:35 UTC 2024 - 2.2K bytes - Viewed (0) -
cmd/metrics-v3-logger-webhook.go
allWebhookLabels...) ) // loadLoggerWebhookMetrics - `MetricsLoaderFn` for logger webhook // such as failed messages and total messages. func loadLoggerWebhookMetrics(ctx context.Context, m MetricValues, c *metricsCache) error { tgts := append(logger.SystemTargets(), logger.AuditTargets()...) for _, t := range tgts { labels := []string{nameL, t.String(), endpointL, t.Endpoint()}
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue May 14 07:27:33 UTC 2024 - 2K bytes - Viewed (0) -
api/go1.11.txt
pkg runtime/trace, func IsEnabled() bool pkg runtime/trace, func Log(context.Context, string, string) pkg runtime/trace, func Logf(context.Context, string, string, ...interface{}) pkg runtime/trace, func NewTask(context.Context, string) (context.Context, *Task) pkg runtime/trace, func StartRegion(context.Context, string) *Region pkg runtime/trace, func WithRegion(context.Context, string, func()) pkg runtime/trace, method (*Region) End()
Registered: Tue Nov 05 11:13:11 UTC 2024 - Last Modified: Wed Aug 22 03:48:56 UTC 2018 - 25K bytes - Viewed (0) -
guava/src/com/google/common/base/Objects.java
* Arrays#hashCode(Object[])}. Note that array arguments to this method, with the exception of a * single Object array, do not get any special handling; their hash codes are based on identity * and not contents. * * <p>This is useful for implementing {@link Object#hashCode()}. For example, in an object that * has three properties, {@code x}, {@code y}, and {@code z}, one could write: * * <pre>{@code
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Jul 22 19:03:12 UTC 2024 - 3K bytes - Viewed (0) -
build-logic-commons/module-identity/src/main/kotlin/gradlebuild.module-identity.gradle.kts
ReleasedVersionsDetails( moduleIdentity.version.get().baseVersion, releasedVersionsFile() ) } return versionNumber } /** * Returns the trimmed contents of the file at the given [path] after * marking the file as a build logic input. */ fun Project.trimmedContentsOfFile(path: String): String = providers.fileContents(repoRoot().file(path)).asText.get().trim()
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Sat Sep 30 16:17:28 UTC 2023 - 4.9K bytes - Viewed (0) -
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) -
cmd/erasure-utils.go
size += len(block) } return size } // Writes all the data blocks from encoded blocks until requested // outSize length. Provides a way to skip bytes until the offset. func writeDataBlocks(ctx context.Context, dst io.Writer, enBlocks [][]byte, dataBlocks int, offset int64, length int64) (int64, error) { // Offset and out size cannot be negative. if offset < 0 || length < 0 { return 0, errUnexpected }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Wed Jan 31 02:11:45 UTC 2024 - 3.1K bytes - Viewed (0)