- Sort Score
- Result 10 results
- Languages All
Results 411 - 420 of 1,339 for contextos (0.2 sec)
-
istioctl/pkg/ztunnelconfig/ztunnelconfig.go
result, err := kubeClient.EnvoyDoWithPort(context.TODO(), podName, podNamespace, "POST", path, port) if err != nil { return "", fmt.Errorf("failed to execute command on Ztunnel: %v", err) } return string(result), nil } // getComponentPodName returns the pod name and namespace of the Istio component func getComponentPodName(ctx cli.Context, podflag string) (string, string, error) {
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Oct 09 19:17:45 UTC 2024 - 22.2K bytes - Viewed (0) -
cmd/metacache-bucket.go
cachesRoot map[string][]string `msg:"-"` // Internal state mu sync.RWMutex `msg:"-"` updated bool `msg:"-"` } type deleteAllStorager interface { deleteAll(ctx context.Context, bucket, prefix string) } // newBucketMetacache creates a new bucketMetacache. // Optionally remove all existing caches. func newBucketMetacache(bucket string, cleanup bool) *bucketMetacache { if cleanup {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6.6K bytes - Viewed (0) -
internal/mcontext/ctxt.go
package mcontext // Share a common context information between different // packages in github.com/minio/minio import ( xhttp "github.com/minio/minio/internal/http" ) // ContextTraceType represents the type of golang Context key type ContextTraceType string // ContextTraceKey is the key of TraceCtxt saved in a Golang context const ContextTraceKey = ContextTraceType("ctx-trace-info")
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Dec 06 17:27:26 UTC 2022 - 1.3K bytes - Viewed (0) -
.github/workflows/release-branch-cherrypick.yml
required: true type: string git_commit: description: 'Git commit to cherry-pick' required: true type: string permissions: contents: read jobs: cherrypick: name: Cherrypick to ${{ github.event.inputs.release_branch}} - ${{ github.event.inputs.git_commit }} runs-on: ubuntu-latest
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Fri Nov 01 08:40:10 UTC 2024 - 3.1K bytes - Viewed (0) -
cmd/erasure-decode_test.go
// along with this program. If not, see <http://www.gnu.org/licenses/>. package cmd import ( "bytes" "context" crand "crypto/rand" "io" "math/rand" "testing" "github.com/dustin/go-humanize" ) func (a badDisk) ReadFile(ctx context.Context, volume string, path string, offset int64, buf []byte, verifier *BitrotVerifier) (n int64, err error) { return 0, errFaultyDisk }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Jan 30 20:43:25 UTC 2024 - 21.1K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/UpgradePropertiesRuleSetup.java
} @Override public void execute(ViolationCheckContext context) { List<UpgradedProperty> currentUpgradedProperties = UpgradedProperties.parse(params.get(CURRENT_UPGRADED_PROPERTIES_KEY)); List<UpgradedProperty> baselineUpgradedProperties = UpgradedProperties.parse(params.get(BASELINE_UPGRADED_PROPERTIES_KEY)); context.putUserData(CURRENT_ACCESSORS_OF_UPGRADED_PROPERTIES, diff(
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Mon Aug 19 15:30:48 UTC 2024 - 4.5K bytes - Viewed (0) -
cmd/erasure-healing-common_test.go
package cmd import ( "bytes" "context" "fmt" "os" "path/filepath" "runtime" "testing" "time" "github.com/minio/madmin-go/v3" ) // Returns the latest updated FileInfo files and error in case of failure. func getLatestFileInfo(ctx context.Context, partsMetadata []FileInfo, defaultParityCount int, errs []error) (FileInfo, error) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 15:19:10 UTC 2024 - 23.1K bytes - Viewed (0) -
okhttp-testing-support/src/test/kotlin/okhttp3/OkHttpClientTestRuleTest.kt
class OkHttpClientTestRuleTest { lateinit var extensionContext: ExtensionContext @RegisterExtension @JvmField val beforeEachCallback = BeforeEachCallback { context -> ******@****.***ionContext = context } @Test fun uncaughtException() { val testRule = OkHttpClientTestRule() testRule.beforeEach(extensionContext) val thread = object : Thread() {
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 1.7K bytes - Viewed (0) -
cmd/metrics-v3-system-network.go
"Total number of bytes received from other peer nodes") ) // loadNetworkInternodeMetrics - reads internode network metrics. // // This is a `MetricsLoaderFn`. func loadNetworkInternodeMetrics(ctx context.Context, m MetricValues, _ *metricsCache) error { connStats := globalConnStats.toServerConnStats() rpcStats := rest.GetRPCStats() if globalIsDistErasure { m.Set(internodeErrorsTotal, float64(rpcStats.Errs))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Sun Mar 10 09:15:15 UTC 2024 - 2.4K bytes - Viewed (0) -
cmd/test-utils_test.go
globalIAMSys.Init(ctx, obj, globalEtcdClient, 2*time.Second) return obj, fsDirs[0], nil } func prepareErasureSets32(ctx context.Context) (ObjectLayer, []string, error) { return prepareErasure(ctx, 32) } func prepareErasure(ctx context.Context, nDisks int) (ObjectLayer, []string, error) { fsDirs, err := getRandomDisks(nDisks) if err != nil { return nil, nil, err }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Oct 01 22:13:18 UTC 2024 - 77K bytes - Viewed (0)