telemetry

type Client ¶

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

func NewClient(cfg Config) (*Client, error)

func (c *Client) Close(ctx context.Context) error

func (c *Client) Pageview(path string, fields Fields)

func (c *Client) Track(name string, fields Fields)

type Config ¶

type Config struct {
	Host       string
	WebsiteID  string
	App        string
	Version    string
	GOOS       string
	GOARCH     string
	HTTPClient *http.Client
}

type Fields ¶

type Fields map[string]any

type ReadSurfaceGate ¶

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

ReadSurfaceGate bounds telemetry volume for high-frequency read-only commands (axi-status, axi-home, status, runs). It emits when the observed state fingerprint changed since the last emit, and otherwise at most once per heartbeat interval. State persists in a small JSON file so agent polling loops - a fresh CLI process per poll - stay bounded across process boundaries. Any state-file failure fails open (emit), degrading to the pre-gate behavior instead of dropping meaningful events.

func NewReadSurfaceGate(path string, interval time.Duration, now func() time.Time) *ReadSurfaceGate

func (g *ReadSurfaceGate) ShouldEmit(surface, fingerprint string) bool

type Sink ¶

type Sink interface {
	Track(name string, fields Fields)
	Pageview(path string, fields Fields)
	Close(ctx context.Context) error
}

func Default() (Sink, error)