- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 394 for trackers (0.14 sec)
-
pkg/bootstrap/option/instances_test.go
key: "lightstep", option: option.LightstepAddress("[2001:db8::100]:80"), expected: "{\"address\": \"2001:db8::100\", \"port_value\": 80}", }, { testName: "lightstep address ipv6 missing brackets", key: "lightstep", option: option.LightstepAddress("2001:db8::100:80"), expectError: true, }, { testName: "lightstep address host port", key: "lightstep",
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Mar 28 20:38:02 UTC 2024 - 22.4K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/HeadersRequestTest.kt
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.5K bytes - Viewed (0) -
mockwebserver-deprecated/src/test/java/okhttp3/mockwebserver/KotlinSourceModernTest.kt
var trailers: Headers = mockResponse.trailers mockResponse = mockResponse.clearHeaders() mockResponse = mockResponse.addHeader("") mockResponse = mockResponse.addHeader("", "") mockResponse = mockResponse.addHeaderLenient("", Any()) mockResponse = mockResponse.setHeader("", Any()) mockResponse.headers = headersOf() mockResponse.trailers = headersOf()
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 7.3K bytes - Viewed (0) -
platforms/core-execution/execution/src/main/java/org/gradle/internal/execution/caching/CachingDisabledReasonCategory.java
/** * Work has declared output that is not cacheable. * * Reasons for non-cacheable outputs: * <ul> * <li>an output contains a file tree,</li> * <li>an output is not tracked.</li> * </ul> */ NON_CACHEABLE_OUTPUT, /** * Work's outputs overlap with other work's. */ OVERLAPPING_OUTPUTS, /** * The work has failed validation.
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:46:15 UTC 2023 - 2.1K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/initialization/Environment.java
import javax.annotation.Nullable; import java.io.File; import java.util.Map; /** * Provides access to the environment in a configuration cache friendly way. * * Access to resources will be tracked when storing to the configuration cache. */ @ServiceScope(Scope.Build.class) public interface Environment { /** * Reads the given Java properties file if it exists. *
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 2K bytes - Viewed (0) -
src/go/types/errorcalls_test.go
errorfMinArgCount = 4 errorfFormatIndex = 2 ) // TestErrorCalls makes sure that check.errorf calls have at least // errorfMinArgCount arguments (otherwise we should use check.error) // and use balanced parentheses/brackets. func TestErrorCalls(t *testing.T) { fset := token.NewFileSet() files, err := pkgFiles(fset, ".") if err != nil { t.Fatal(err) } for _, file := range files {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri Dec 15 21:57:36 UTC 2023 - 2.2K bytes - Viewed (0) -
cmd/data-scanner-metric.go
func (p *scannerMetrics) currentPathUpdater(disk, initial string) (update func(path string), done func()) { initialPtr := unsafe.Pointer(&initial) tracker := ¤tPathTracker{ name: &initialPtr, } p.currentPaths.Store(disk, tracker) return func(path string) { atomic.StorePointer(tracker.name, unsafe.Pointer(&path)) }, func() { p.currentPaths.Delete(disk) } }
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Mon Sep 25 05:15:31 UTC 2023 - 9.1K bytes - Viewed (0) -
pilot/pkg/networking/core/tracing.go
"istio.io/istio/pkg/log" "istio.io/istio/pkg/wellknown" ) const ( envoyDatadog = "envoy.tracers.datadog" envoyOpenTelemetry = "envoy.tracers.opentelemetry" envoySkywalking = "envoy.tracers.skywalking" envoyZipkin = "envoy.tracers.zipkin" ) // this is used for testing. it should not be changed in regular code. var clusterLookupFn = model.LookupCluster
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu May 16 17:05:28 UTC 2024 - 24.2K bytes - Viewed (0) -
mockwebserver-deprecated/src/main/kotlin/okhttp3/mockwebserver/DeprecationBridge.kt
for (pushPromise in pushPromises) { result.addPush(pushPromise.wrap()) } result.settings(settings) result.status = status result.headers(headers) result.trailers(trailers) result.socketPolicy = when (socketPolicy) { SocketPolicy.EXPECT_CONTINUE, SocketPolicy.CONTINUE_ALWAYS -> { result.add100Continue() KeepOpen }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 4.6K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/http/ExchangeCodec.kt
fun reportedContentLength(response: Response): Long @Throws(IOException::class) fun openResponseBodySource(response: Response): Source /** Returns the trailers after the HTTP response. May be empty. */ @Throws(IOException::class) fun trailers(): Headers /** * Cancel this stream. Resources held by this stream will be cleaned up, though not synchronously. * That may happen later by the connection pool thread.
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 3K bytes - Viewed (0)