wiretrace

type BlobRef struct {
	Seg    int    `json:"seg"`
	Off    int64  `json:"off"`
	Len    int    `json:"len"`
	CRC32C uint32 `json:"crc32c"`
	SHA256 string `json:"sha256,omitempty"`
}

type Cause struct {
	// Req is the request id of the response, 0 for updates.
	Req int64 `json:"req"`
	// Outer is the outer msg_id of the response.
	Outer ID `json:"outer"`
	// Type is the constructor id of the response.
	Type TypeID `json:"type"`
}

type Event struct {
	Seq    uint64
	T      float64
	Thread string
	Kind   string
	// Blob references the body of the event, if any.
	Blob *BlobRef
	// Inline is the decoded "b64" field, if the writer inlined the body.
	Inline []byte
	// Cause is the causal context, if any.
	Cause *Cause
	// UI is the UI action stamp, if any. It is never set for "hdr" records
	// (their "ui" is HeaderUI).
	UI *UIStamp
	// Fields holds all fields of the record.
	Fields map[string]json.RawMessage

	// Segment is the index of the events segment the record was read from.
	Segment int
	// Line is the 1-based line number in that segment.
	Line int
	// Raw is the (repaired, see RepairLegacyNumbers) JSON line.
	Raw []byte
}

type Field struct {
	Key   string
	Value any
}

type Header struct {
	V             int      `json:"v"`
	Seg           int      `json:"seg"`
	Run           string   `json:"run,omitempty"`
	App           string   `json:"app,omitempty"`
	Layer         int      `json:"layer,omitempty"`
	APISHA256     string   `json:"api_sha256,omitempty"`
	MTProtoSHA256 string   `json:"mtproto_sha256,omitempty"`
	WallUTC       string   `json:"wall_utc,omitempty"`
	MonoT         float64  `json:"mono_t,omitempty"`
	PID           int64    `json:"pid,omitempty"`
	Flags         []string `json:"flags,omitempty"`
	// UI is set when UI tracing (P14) is on.
	UI *HeaderUI `json:"ui,omitempty"`
}

type HeaderUI struct {
	V int `json:"v"`
	// IDs is "hmac64" (ids written as "h:<16 hex>") or "raw" (decimal
	// strings, with RawIDs).
	IDs     string `json:"ids,omitempty"`
	RawIDs  bool   `json:"raw_ids"`
	Verbose bool   `json:"verbose,omitempty"`
}

type ID uint64

type IDKey []byte

type Inner struct {
	MsgID    ID     `json:"msg_id"`
	SeqNo    int64  `json:"seqno"`
	Len      int64  `json:"len"`
	Type     TypeID `json:"type"`
	Method   TypeID `json:"method,omitempty"`
	ReqMsgID ID     `json:"req_msg_id,omitempty"`
	Result   TypeID `json:"result,omitempty"`
}

type Msg struct {
	Dir       string   `json:"dir"`
	SDC       int      `json:"sdc"`
	DC        int      `json:"dc"`
	Shift     int      `json:"shift"`
	PDC       int      `json:"pdc"`
	Conn      string   `json:"conn,omitempty"`
	Key       ID       `json:"key"`
	KeyHex    string   `json:"key_hex,omitempty"`
	KeyKind   string   `json:"key_kind,omitempty"`
	Session   SignedID `json:"session"`
	Salt      ID       `json:"salt"`
	MsgID     ID       `json:"msg_id"`
	SeqNo     int64    `json:"seqno"`
	Len       int64    `json:"len"`
	Truncated bool     `json:"truncated,omitempty"`
	Type      TypeID   `json:"type"`
	Method    TypeID   `json:"method,omitempty"`
	Wrap      []TypeID `json:"wrap,omitempty"`
	ReqMsgID  ID       `json:"req_msg_id,omitempty"`
	Result    TypeID   `json:"result,omitempty"`
	Inner     []Inner  `json:"inner,omitempty"`
	Redacted  []string `json:"redacted,omitempty"`
	PII       bool     `json:"pii,omitempty"`
	Partial   bool     `json:"partial,omitempty"`
}

type Run struct {
	// Dir is the run directory.
	Dir string
	// Segments are the indexes of present segments, sorted. Segments may
	// have gaps: the writer deletes the oldest segments except 0 when the
	// total size cap is reached.
	Segments []int
	// Header is the "hdr" record of the first present segment.
	Header *Header
	// contains filtered or unexported fields
}

type SignedID int64

type TypeID uint32

type UIStamp struct {
	// A is the action id.
	A uint32 `json:"a"`
	// Rel is UIRelSync, UIRelDeferred or UIRelAfter.
	Rel string `json:"rel"`
	// DT is the time since the action scope closed (since it opened, for
	// nested event loops), in integer milliseconds. It is written for
	// deferred and after stamps.
	DT float64 `json:"dt"`
}

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

type WriterOptions struct {
	// Header are the fields of the "hdr" record (after "seq", "ev", "v" and
	// "seg"), e.g. run, app, layer.
	Header []Field
	// SegmentEventsBytes rotates segments when the events file exceeds it.
	// Default is 64 MiB.
	SegmentEventsBytes int64
	// SegmentBlobsBytes rotates segments when the blobs file exceeds it.
	// Default is 256 MiB.
	SegmentBlobsBytes int64
	// TotalBytes caps the total size; the oldest segments except segment 0
	// are deleted. Default is 2 GiB.
	TotalBytes int64
	// InlineMax also inlines bodies up to this size as "b64". Zero disables.
	InlineMax int
	// Now returns the event time in seconds. Default is the monotonic time
	// since NewWriter.
	Now func() float64
}