Skip to main content

Documentation Index

Fetch the complete documentation index at: https://docs.tilebox.com/llms.txt

Use this file to discover all available pages before exploring further.

func (*JobClient) QuerySpans(
    ctx context.Context,
    jobID uuid.UUID,
    options ...workflows.TelemetryQueryOption,
) iter.Seq2[*workflows.Span, error]
Query spans emitted while running a job. The spans are lazily loaded and returned as a sequence of spans. Use Collect to transform the sequence into a slice.

​
Parameters

​
jobID
uuid.UUID
required
The ID of the job to query spans for.
​
options
[]workflows.TelemetryQueryOption
Options for querying spans.

​
Options

​
WithSortDirection(direction workflows.SortDirection)
Sort spans by start time. Use workflows.Ascending for oldest first or workflows.Descending for newest first.
​
WithLimit(limit int64)
Limit the number of spans returned.

​
Returns

A sequence of spans. Each span includes StartTime, Name, StatusCode, Attributes, and Duration(). 
import (
    "fmt"
    "log/slog"
    "time"

    "github.com/google/uuid"
    "github.com/tilebox/tilebox-go/workflows/v1"
)

jobID := uuid.MustParse("019e07b1-916b-0630-f3ba-f1c33235d174")

for span, err := range client.Jobs.QuerySpans(
    ctx,
    jobID,
    workflows.WithSortDirection(workflows.Ascending),
) {
    if err != nil {
        slog.ErrorContext(ctx, "failed to query job spans", slog.Any("error", err))
        return
    }

    fmt.Printf("%s %-40s %s\n",
        span.StartTime.Format(time.RFC3339),
        span.Name,
        span.Duration(),
    )
}