funclog

type BlobSink struct {
	// contains filtered or unexported fields
}

type BlobTraceSink struct {
	// contains filtered or unexported fields
}

type Deps struct {
	Bucket          blob.Bucket
	SegmentMaxBytes int           // seal+Put at this many buffered bytes (default 8 MiB)
	SegmentMaxAge   time.Duration // ...or after this long (default 10s)
	Clock           clock.Clock
	Logger          *slog.Logger
}

type Entry struct {
	Time       time.Time         // real event time (epoch nanos on the wire)
	Severity   Severity          // exact for Path B; coarse for Path A
	Body       string            // the message (Path B keeps console args before util.format)
	Attrs      map[string]string // structured attributes
	Invocation string            // per-invocation id (may be empty for pre-invocation Path A lines)
	TraceID    string            // hex32, may be empty
	SpanID     string            // hex16, may be empty
	Source     Source
}

type Reader interface {
	// Read returns the next Entry, or io.EOF when the channel closes (instance gone).
	Read(ctx context.Context) (Entry, error)
}

type Resource struct {
	Namespace string
	Function  string
	Replica   string
	Tenant    string
}

type Severity string

type Signal string

type Sink interface {
	// Append adds one Entry to the open segment for res.
	Append(ctx context.Context, res Resource, e Entry) error
	// Flush seals res's current segment (also triggered by size/age) and Puts it; returns the blob key.
	Flush(ctx context.Context, res Resource) (key string, err error)
	io.Closer
}

type Sinks struct {
	Logs   Sink
	Traces TraceSink
}

type Source string

type Span struct {
	TraceID    string            // hex32; adopted from traceparent or minted (root)
	SpanID     string            // hex16; minted per invocation
	ParentID   string            // hex16; the traceparent span-id, empty for a root
	Name       string            // the function name (FUNCD_FUNCTION) or "invoke"
	Kind       SpanKind          // SERVER for the auto invocation span
	Start      time.Time         // invocation start (epoch nanos on the wire)
	End        time.Time         // invocation end
	Status     SpanStatus        // OK on return, ERROR on throw/output-mismatch
	StatusMsg  string            // the error message when Status == ERROR
	Attrs      map[string]string // structured attributes
	Invocation string            // the per-invocation id (== the log lines' inv for correlation)
	Links      []string          // hex16 span-ids linked in the SAME trace — fan-in edges (ADR-0105)
}

type SpanKind string

type SpanStatus string

type TraceSink interface {
	// AppendSpan adds one Span to the open segment for res.
	AppendSpan(ctx context.Context, res Resource, s Span) error
	// Flush seals res's current segment (also triggered by size/age) and Puts it; returns the blob key.
	Flush(ctx context.Context, res Resource) (key string, err error)
	// Close stops the age-flusher, then seals and Puts every open segment.
	Close() error
}