connections

type BodyDecoder func(context.Context, map[string]any) (map[string]any, error)

type ConnectionInspection struct {
	Targets []ConnectionInspectionTarget `json:"targets,omitempty"`
	Result  *query.InspectionResult      `json:"result,omitempty"`
}

type ConnectionInspectionTarget struct {
	Name       string          `json:"name"`
	Target     string          `json:"target"`
	Kind       string          `json:"kind"`
	Schema     string          `json:"schema,omitempty"`
	FieldCount int             `json:"fieldCount,omitempty"`
	Inspect    api.LinkCommand `json:"inspect"`
}

type ContextProvider func() dbcontext.Context

type DatabaseProvider func() (*gorm.DB, error)

type InspectFlags struct {
	Database   string `flag:"database" help:"Database to inspect"`
	Schema     string `flag:"schema" hidden:"true" help:"SQL schema containing the target"`
	Target     string `flag:"target" help:"Table, view, index, alias, data stream, or pattern to inspect"`
	TargetKind string `flag:"target-kind" hidden:"true" help:"OpenSearch target kind"`
	Sample     bool   `flag:"sample" help:"Sample the selected target to resolve cardinality and auto-filters"`
	Refresh    bool   `flag:"refresh" help:"Refresh cached inspection metadata and re-read connection secrets"`
	// contains filtered or unexported fields
}

type ListOptions struct {
	Type  string `flag:"type" help:"Filter by connection type"`
	Types string `flag:"types" help:"Filter by connection types (comma-separated)"`
}

type Options struct {
	Database   DatabaseProvider
	Context    ContextProvider
	DecodeBody BodyDecoder
	Profiles   ProfileProvider
	Virtual    VirtualConnectionProvider
}

type ProfileProvider func(context.Context) ([]query.Profile, error)

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

type VirtualConnectionProvider interface {
	ListConnections() []*models.Connection
	// ResolveConnection takes the context for the same reason
	// dbcontext.ConnectionResolver does: a reference alone does not always
	// identify a connection, and the same provider answers it here and there.
	ResolveConnection(dbcontext.Context, string) (*models.Connection, error)
}