providers

type OpenSearchTimeFieldMappingRequest struct {
	Searcher   *opensearch.Searcher
	Index      string
	Search     esdsl.Search
	Params     []esdsl.ParamBinding
	Inspection query.InspectionOptions
}

type OpenTelemetryRead struct {
	// Connection is the opentelemetry connection, and Options the
	// opentelemetry provider's options for its index and fields.
	Connection string
	Options    map[string]any
	// From and To bound the read on the date field, as date math such as
	// now-1h or RFC3339; empty leaves that side open.
	From, To string
	// Follow keeps reading the spans indexed after the read caught up, until
	// ctx ends; it has no To.
	Follow bool
	// Poll is how long a caught-up follow waits before asking again; zero is
	// two seconds. Lag holds a follow behind now, so spans indexed late still
	// land before the read passes their instant.
	Poll, Lag time.Duration
}

type SQLPageRequest struct {
	// Connection names the connection client is, for the SQL statement tap.
	Connection       string
	Query            string
	QueryArgs        []any
	QueryIdentifiers []string
	Filters          []query.ColumnFilterValue
	Order            query.Order
	Position         query.CursorPosition
	Page             query.PageRequest
	Diagnostics      *query.ProviderDiagnostics
}

type SQLPageResult struct {
	Rows        []query.Row
	ColumnTypes []*sql.ColumnType
	Total       *query.Total
	HasMore     bool
}

type XEventCaptureOptions struct {
	// SessionName names the Extended Events session on the server. Required:
	// the session is visible in sys.dm_xe_sessions to everyone on the instance,
	// so what it is called is the profile author's to say, not this package's.
	// A unique suffix is appended so concurrent captures of one profile do not
	// collide on the server.
	SessionName string `json:"sessionName"`

	// Databases scopes the session by database name; empty uses the
	// connection's own, and "*" captures the whole instance.
	Databases []string `json:"databases,omitempty"`

	Users []string `json:"users,omitempty"`
	Apps  []string `json:"apps,omitempty"`
	Hosts []string `json:"hosts,omitempty"`

	// Events selects the Extended Events to capture; empty uses xetrace's
	// defaults. Add sp_statement_completed to see statements inside procedures.
	Events []string `json:"events,omitempty"`

	// Types narrows to statement types (SELECT/INSERT/UPDATE/DELETE/MERGE/EXEC/DML).
	Types []string `json:"types,omitempty"`
	// Tables narrows to referenced tables, or a procedure name for an EXEC.
	Tables []string `json:"tables,omitempty"`

	// MinDuration drops statements faster than this threshold, e.g. "10ms".
	MinDuration string `json:"minDuration,omitempty"`
	// Poll is the ring-buffer poll cadence, e.g. "1s". Empty uses xetrace's.
	Poll string `json:"poll,omitempty"`

	// MaxEvents caps the ring buffer's event count; MaxMemoryKB its size.
	MaxEvents   int `json:"maxEvents,omitempty"`
	MaxMemoryKB int `json:"maxMemoryKb,omitempty"`
}