- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 19 for traceapi (0.21 sec)
-
pkg/tracing/tracing.go
"go.opentelemetry.io/otel/propagation" "go.opentelemetry.io/otel/sdk/resource" "go.opentelemetry.io/otel/sdk/trace" semconv "go.opentelemetry.io/otel/semconv/v1.17.0" traceapi "go.opentelemetry.io/otel/trace" "istio.io/istio/pkg/log" ) // Inspired by https://github.com/moby/buildkit/blob/d9a6afdf089a7c4b97cac704a60ad70c21086f12/util/tracing/detect/otlp.go#L18
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Wed Jul 26 01:07:39 UTC 2023 - 3.9K bytes - Viewed (0) -
pkg/test/framework/test.go
// See the License for the specific language governing permissions and // limitations under the License. package framework import ( context2 "context" "fmt" "testing" "time" traceapi "go.opentelemetry.io/otel/trace" "istio.io/istio/pkg/test/framework/label" "istio.io/istio/pkg/test/framework/resource" "istio.io/istio/pkg/test/scopes" "istio.io/istio/pkg/tracing" ) type Test interface {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Jun 06 22:12:34 UTC 2024 - 10.3K bytes - Viewed (0) -
src/runtime/tracemap.go
// appear in the table anymore. func (tab *traceMap) stealID() uint64 { return tab.seq.Add(1) } // put inserts the data into the table. // // It's always safe for callers to noescape data because put copies its bytes. // // Returns a unique ID for the data and whether this is the first time // the data has been added to the map. func (tab *traceMap) put(data unsafe.Pointer, size uintptr) (uint64, bool) {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 4.5K bytes - Viewed (0) -
src/runtime/tracecpu.go
Carlos Amedee <******@****.***> 1712158572 -0400
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 8.7K bytes - Viewed (0) -
src/runtime/traceevent.go
return traceArg(trace.stringTab[tl.gen%2].put(tl.gen, s)) } // uniqueString returns a traceArg representing s which may be passed to write. // The string is assumed to be unique or long, so it will be written out to // the trace eagerly. func (tl traceLocker) uniqueString(s string) traceArg { return traceArg(trace.stringTab[tl.gen%2].emit(tl.gen, s)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 08 17:47:01 UTC 2024 - 9.2K bytes - Viewed (0) -
src/runtime/traceallocfree.go
traceRelease(trace) } func traceSpanTypeAndClass(s *mspan) traceArg { if s.state.get() == mSpanInUse { return traceArg(s.spanclass) << 1 } return traceArg(1) } // SpanExists records an event indicating that the span exists. func (tl traceLocker) SpanExists(s *mspan) { tl.eventWriter(traceGoRunning, traceProcRunning).commit(traceEvSpan, traceSpanID(s), traceArg(s.npages), traceSpanTypeAndClass(s)) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 20:32:51 UTC 2024 - 5.9K bytes - Viewed (0) -
src/runtime/tracestatus.go
// Trace the status. if stackID == 0 { w = w.event(traceEvGoStatus, traceArg(goid), traceArg(uint64(mid)), traceArg(status)) } else { w = w.event(traceEvGoStatusStack, traceArg(goid), traceArg(uint64(mid)), traceArg(status), traceArg(stackID)) } // Trace any special ranges that are in-progress. if markAssist { w = w.event(traceEvGCMarkAssistActive, traceArg(goid)) } return w }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Apr 15 17:03:35 UTC 2024 - 7.2K bytes - Viewed (0) -
src/runtime/traceruntime.go
} w.commit(traceEvProcSteal, traceArg(pp.id), pp.trace.nextSeq(tl.gen), traceArg(mStolenFrom)) } // HeapAlloc emits a HeapAlloc event. func (tl traceLocker) HeapAlloc(live uint64) { tl.eventWriter(traceGoRunning, traceProcRunning).commit(traceEvHeapAlloc, traceArg(live)) } // HeapGoal reads the current heap goal and emits a HeapGoal event.
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed May 22 22:31:00 UTC 2024 - 25.7K bytes - Viewed (0) -
pkg/test/framework/components/zipkin/kube.go
// Get 100 most recent traces client := http.Client{ Timeout: 5 * time.Second, } scopes.Framework.Debugf("make get call to zipkin api %v", c.address+fmt.Sprintf(tracesAPI, limit, spanName, annotationQuery)) resp, err := client.Get(c.address + fmt.Sprintf(tracesAPI, limit, spanName, annotationQuery)) if err != nil { scopes.Framework.Debugf("zipking err %v", err) return nil, err } if resp.StatusCode != http.StatusOK {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Mon Aug 14 19:29:38 UTC 2023 - 8K bytes - Viewed (0) -
src/runtime/trace2map_test.go
// license that can be found in the LICENSE file. package runtime_test import ( . "runtime" "strconv" "sync" "testing" ) func TestTraceMap(t *testing.T) { var m TraceMap // Try all these operations multiple times between resets, to make sure // we're resetting properly. for range 3 { var d = [...]string{ "a", "b", "aa", "ab", "ba", "bb",
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Apr 10 18:52:49 UTC 2024 - 1.8K bytes - Viewed (0)