api

Nov 7, 2026

Changes in this version

+ func InstanceTarget(ctx context.Context, store datatug.ProjectStore, environment, catalog string) policyscope.Target

type ResolvedSource

+ Catalog string

Nov 7, 2026

Changes in this version

type CatalogSchema

+ func GetDbModelSchema(projectDir, dbModelID string) (*CatalogSchema, error)

Nov 7, 2026

Changes in this version

+ func SecurePolicyFreeReads() bool

Nov 6, 2026

Changes in this version

+ const DriverIngitDB

type ProjectSourceRequest

+ IngitDBPath string

Nov 3, 2026

Changes in this version

+ func HostedTableRead(ctx context.Context, project, environment, catalog string) (*secureread.HostedTableRead, error)

type CatalogTables

+ HostedTableRead *secureread.HostedTableRead

Nov 3, 2026

Changes in this version

+ type ContextualEnvironmentParent struct

+ Archived bool

+ ReadOnly bool

+ type ContextualEnvironmentScope struct

+ CatalogID string

+ EnvironmentID string

+ ProjectID string

+ type ContextualEnvironments struct

+ Items *[]LocalEnvironmentBrief

+ Parent *ContextualEnvironmentParent

+ ReasonCode string

+ Scope ContextualEnvironmentScope

+ Status string

+ Version int

+ func BoundContextualEnvironments(ctx context.Context, scope ContextualEnvironmentScope) (ContextualEnvironments, error)

Nov 2, 2026

Changes in this version

+ func BoundReadScope(ctx context.Context) (project, environment, catalog string, bound bool, err error)

+ func BoundSourceBackend(ctx context.Context, sourceURL string) (dbcopy.BackendRef, bool, error)

+ func CheckSourceBinding(ctx context.Context) error

+ func ConfigureSecureSessionChecked(session secureread.Session, pathsByID map[string]string, caps Capabilities) error

+ func SourceBoundProfile() bool

Nov 1, 2026

Changes in this version

+ func LocalProjectDbServerDiscovery(ctx context.Context, ref dto.ProjectRef, branch string) ([]datatug.ProjDbServer, error)

+ func LocalProjectMeaningDiscovery(ctx context.Context, ref dto.ProjectRef, branch string) (datatug.ProjectMeaningsCatalog, error)

Oct 31, 2026

Changes in this version

+ func ArchiveLocalProject(ctx context.Context, request localprojects.Archive) (localprojects.ArchiveResult, error)

+ func CanCreateLocalProject() bool

+ func ConfigureLocalProjectRegistry(registry *localprojects.Registry)

+ func ConfigureLocalVisibilityInventory(factory LocalVisibilityInventoryFactory)

+ func CreateLocalProject(ctx context.Context, request localprojects.Create) (localprojects.Project, error)

+ func LocalProjectMeaningVisibilityItems(project string) ([]datatug.ProjectUsageItem, error)

+ func SecureConfiguredProjectPaths() map[string]string

type Capabilities

+ ProjectsRoot string

type LocalConnectionCatalog

+ ArchivedItems map[string]bool

+ func (catalog LocalConnectionCatalog) MarshalJSON() ([]byte, error)

+ type LocalProjectRegistryState struct

+ CanArchive bool

+ CanCreate bool

+ Projects []localprojects.Project

+ func GetLocalProjectRegistry() (LocalProjectRegistryState, error)

+ type LocalVisibilityInventoryFactory func(context.Context, datatug.ProjectLifecycleScope) (projectvisibility.Runtime, error)

Oct 30, 2026

Changes in this version

+ const DriverClickHouse

+ func SecureLocalProjectOwner() bool

+ type ClickHouseScanParams struct

+ func NewClickHouseScanParams(lookup func(string) (string, bool), dsnEnv, environment, catalog string) (*ClickHouseScanParams, error)

+ func (*ClickHouseScanParams) Driver() string

+ func (*ClickHouseScanParams) Mode() dbconnection.Mode

+ func (*ClickHouseScanParams) User() string

+ func (p *ClickHouseScanParams) Catalog() string

+ func (p *ClickHouseScanParams) ConnectionString() string

+ func (p *ClickHouseScanParams) GoString() string

+ func (p *ClickHouseScanParams) LogTarget() string

+ func (p *ClickHouseScanParams) Path() string

+ func (p *ClickHouseScanParams) Port() int

+ func (p *ClickHouseScanParams) Server() string

+ func (p *ClickHouseScanParams) SourceRef() dbcopy.BackendRef

+ func (p *ClickHouseScanParams) String() string

+ func (p *ClickHouseScanParams) WriteDescriptor(projectDir string) (func() error, error)

type ProjectSourceRequest

+ Driver string

Oct 30, 2026

Changes in this version

+ func CreateEntity(ctx context.Context, ref dto.ProjectRef, entity *datatug.Entity) error

Oct 30, 2026

Changes in this version

+ func CreateLocalProjectBoard(ctx context.Context, ref dto.ProjectRef, branch string, board datatug.Board) (result *datatug.Board, err error)

+ func LocalGuardedBoardCreateSupported(ctx context.Context, ref dto.ProjectRef, branch string) bool

Oct 29, 2026

Changes in this version

+ const DriverTypesense

+ type TypesenseScanParams struct

+ func NewTypesenseScanParams(lookupEnv func(string) (string, bool), dsnEnv, environment, catalog string) (*TypesenseScanParams, error)

+ func (*TypesenseScanParams) Driver() string

+ func (*TypesenseScanParams) Mode() dbconnection.Mode

+ func (*TypesenseScanParams) User() string

+ func (p *TypesenseScanParams) Catalog() string

+ func (p *TypesenseScanParams) ConnectionString() string

+ func (p *TypesenseScanParams) GoString() string

+ func (p *TypesenseScanParams) LogTarget() string

+ func (p *TypesenseScanParams) Path() string

+ func (p *TypesenseScanParams) Port() int

+ func (p *TypesenseScanParams) Server() string

+ func (p *TypesenseScanParams) SourceRef() dbcopy.BackendRef

+ func (p *TypesenseScanParams) String() string

+ func (p *TypesenseScanParams) WriteDescriptor(projectDir string) (undo func() error, err error)

Oct 29, 2026

Changes in this version

+ func CreateProjectQueryFolder(ctx context.Context, r QueryFolderCreate) (*datatug.QueriesFolder, error)

+ func DeclaredProjectQueryFolders(ctx context.Context, ref dto.ProjectRef) ([]string, error)

+ func LocalCreatePublicOVDBConnection(ctx context.Context, request dto.CreatePublicOVDBConnectionRequest) (result *dto.EnvironmentOperationResult, err error)

+ func LocalProjectLifecycleCatalog(ctx context.Context, selection LocalLifecycleSelection, archived bool) (datatug.ProjectLifecycleCatalog, error)

+ func LocalProjectLifecycleChange(ctx context.Context, request LocalLifecycleWrite) (datatug.ProjectLifecycleAck, error)

+ func LocalProjectLifecycleReview(ctx context.Context, selection LocalLifecycleSelection, ...) (datatug.ProjectLifecycleReview, error)

+ func LocalPublicOVDBConnectionState(ctx context.Context, scope dto.EnvironmentScope, ...) (result *dto.PublicOVDBConnectionState, err error)

+ type LocalLifecycleSelection struct

+ Branch string

+ Environment string

+ ProjectAPI string

+ type LocalLifecycleWrite struct

+ type QueryFolderCreate struct

+ Branch string

+ Name string

+ Path string

+ func (r QueryFolderCreate) Validate() error

Oct 28, 2026

Changes in this version

+ const DriverLibSQL

+ type LibSQLScanParams struct

+ func NewLibSQLScanParams(lookupEnv func(string) (string, bool), dsnEnv, environment, catalog string) (*LibSQLScanParams, error)

+ func (*LibSQLScanParams) Driver() string

+ func (*LibSQLScanParams) Mode() dbconnection.Mode

+ func (*LibSQLScanParams) User() string

+ func (p *LibSQLScanParams) Catalog() string

+ func (p *LibSQLScanParams) ConnectionString() string

+ func (p *LibSQLScanParams) GoString() string

+ func (p *LibSQLScanParams) LogTarget() string

+ func (p *LibSQLScanParams) Path() string

+ func (p *LibSQLScanParams) Port() int

+ func (p *LibSQLScanParams) Server() string

+ func (p *LibSQLScanParams) SourceRef() dbcopy.BackendRef

+ func (p *LibSQLScanParams) String() string

+ func (p *LibSQLScanParams) WriteDescriptor(projectDir string) (undo func() error, err error)

Oct 28, 2026

Changes in this version

+ const DriverCouchDB

+ const DriverPostgREST

+ func ConnectionDescriptorPath(environment, catalog string) string

+ type CouchDBScanParams struct

+ func NewCouchDBScanParams(lookupEnv func(string) (string, bool), dsnEnv, environment, catalog string) (*CouchDBScanParams, error)

+ func (*CouchDBScanParams) Driver() string

+ func (*CouchDBScanParams) Mode() dbconnection.Mode

+ func (*CouchDBScanParams) User() string

+ func (p *CouchDBScanParams) Catalog() string

+ func (p *CouchDBScanParams) ConnectionString() string

+ func (p *CouchDBScanParams) GoString() string

+ func (p *CouchDBScanParams) LogTarget() string

+ func (p *CouchDBScanParams) Path() string

+ func (p *CouchDBScanParams) Port() int

+ func (p *CouchDBScanParams) Server() string

+ func (p *CouchDBScanParams) SourceRef() dbcopy.BackendRef

+ func (p *CouchDBScanParams) String() string

+ func (p *CouchDBScanParams) WriteDescriptor(projectDir string) (undo func() error, err error)

+ type PostgRESTScanParams struct

+ func NewPostgRESTScanParams(lookupEnv func(string) (string, bool), dsnEnv, environment, catalog string) (*PostgRESTScanParams, error)

+ func (*PostgRESTScanParams) Driver() string

+ func (*PostgRESTScanParams) Mode() dbconnection.Mode

+ func (*PostgRESTScanParams) User() string

+ func (p *PostgRESTScanParams) Catalog() string

+ func (p *PostgRESTScanParams) ConnectionString() string

+ func (p *PostgRESTScanParams) GoString() string

+ func (p *PostgRESTScanParams) LogTarget() string

+ func (p *PostgRESTScanParams) Path() string

+ func (p *PostgRESTScanParams) Port() int

+ func (p *PostgRESTScanParams) Server() string

+ func (p *PostgRESTScanParams) SourceRef() dbcopy.BackendRef

+ func (p *PostgRESTScanParams) String() string

+ func (p *PostgRESTScanParams) WriteDescriptor(projectDir string) (undo func() error, err error)

Oct 23, 2026

Changes in this version

+ func LocalCreateEnvironment(ctx context.Context, r dto.CreateEnvironmentRequest) (*dto.EnvironmentOperationResult, error)

+ func LocalEnvironmentOperationStatus(ctx context.Context, r dto.EnvironmentOperationStatusRequest) (result *dto.EnvironmentOperationResult, err error)

+ func LocalEnvironmentState(ctx context.Context, s dto.EnvironmentScope) (result *dto.EnvironmentState, err error)

+ func LocalSaveEnvironmentOrder(ctx context.Context, r dto.SaveEnvironmentOrderRequest) (*dto.EnvironmentOperationResult, error)

type Capabilities

+ EnvironmentAuthorityID string

+ EnvironmentMetadataPolicies map[string]EnvironmentMetadataPolicy

+ EnvironmentPrivateDir string

+ type EnvironmentError struct

+ Code string

+ Message string

+ Status int

+ func (e *EnvironmentError) Error() string

+ type EnvironmentMetadataPolicy struct

+ CanCreateEnvironment bool

+ CanReadOrder bool

+ CanWriteOrder bool

+ PrincipalID string

Oct 23, 2026

Changes in this version

+ const DriverMySQL

+ const DriverOracle

+ const DriverSQLServer

+ const ServerDefaultSchema

+ func IsServerDriver(driver string) bool

type PostgresScanParams

+ func NewServerScanParams(driver string, lookupEnv func(string) (string, bool), ...) (*PostgresScanParams, error)

Oct 22, 2026

Changes in this version

+ func CreateCard(ctx context.Context, ref dto.ProjectRef, card datatug.Card) (*datatug.Card, error)

+ func DeleteCard(ctx context.Context, ref dto.ProjectItemRef) error

+ func GetCard(ctx context.Context, ref dto.ProjectItemRef) (*datatug.Card, error)

+ func ListCards(ctx context.Context, ref dto.ProjectRef) ([]datatug.CardBrief, error)

+ func LocalProjectCard(ctx context.Context, ref dto.ProjectItemRef, branch string) (*datatug.Card, error)

+ func LocalProjectCards(ctx context.Context, ref dto.ProjectRef, branch string) ([]datatug.CardBrief, error)

+ func SaveCard(ctx context.Context, ref dto.ProjectRef, card datatug.Card) (*datatug.Card, error)

Oct 21, 2026

Changes in this version

+ func LocalProjectMeaningChange(ctx context.Context, r LocalMeaningWrite) (datatug.ProjectMeaningAck, error)

+ func LocalProjectMeaningsCatalog(ctx context.Context, ref dto.ProjectRef, branch string) (datatug.ProjectMeaningsCatalog, error)

+ type LocalMeaningWrite struct

+ Branch string

Oct 21, 2026

Changes in this version

+ var ErrItemTagsRevisionConflict = errors.New("item tags document changed; reload before saving")

+ func LocalProjectDbServers(ctx context.Context, ref dto.ProjectRef, branch string) ([]datatug.ProjDbServer, error)

+ type ItemTags struct

+ BranchHead string

+ ID string

+ Kind string

+ Revision string

+ Tags []string

+ func LocalProjectItemTags(ctx context.Context, s ItemTagsSelector) (*ItemTags, error)

+ func SaveLocalProjectItemTags(ctx context.Context, request SaveItemTagsRequest) (*ItemTags, error)

+ type ItemTagsSelector struct

+ Branch string

+ Driver string

+ ID string

+ Kind string

+ type SaveItemTagsRequest struct

+ ExpectedBranchHead string

+ IfMatch string

+ Tags []string

Oct 16, 2026

Changes in this version

+ func ScannedColumnOrder(projectDir, environmentID, catalogID, schema, name string) ([]string, bool)

Oct 16, 2026

Changes in this version

+ func LocalProjectBoard(ctx context.Context, ref dto.ProjectItemRef, branch string) (*datatug.Board, error)

+ func LocalProjectBoards(ctx context.Context, ref dto.ProjectRef, branch string) ([]datatug.ProjBoardBrief, error)

+ func LocalProjectEntities(ctx context.Context, ref dto.ProjectRef, branch string) ([]datatug.ProjEntityBrief, error)

+ func LocalProjectEntity(ctx context.Context, ref dto.ProjectItemRef, branch string) (json.RawMessage, error)

+ func LocalProjectSummary(ctx context.Context, ref dto.ProjectRef, branch string) (*datatug.ProjectSummary, error)

type LocalConnectionCatalog

+ func LocalProjectConnectionCatalogForBranch(ctx context.Context, ref dto.ProjectRef, branch string) (*LocalConnectionCatalog, error)

+ type LocalEnvironmentBrief struct

+ ID string

+ Presentation *LocalEnvironmentPresentation

+ Title string

+ func LocalProjectEnvironments(ctx context.Context, ref dto.ProjectRef, branch string) ([]LocalEnvironmentBrief, error)

+ type LocalEnvironmentPresentation struct

+ Icon string

+ Label string

+ Tone string

Oct 16, 2026

Changes in this version

+ const MaxColumnsFileSize

type CatalogRelation

+ func FindCatalogRelations(projectDir, environmentID, catalogID, name string) (found []CatalogRelation, scanned bool, err error)

Oct 16, 2026

Changes in this version

+ func AcceptedSessionActorGate(ctx context.Context, p sessioncontext.Principal, ...) error

+ func ResolveAcceptedSessionContext(ctx context.Context, storage, project string) (*sessioncontext.Service, sessioncontext.Principal, ...)

type Capabilities

+ NativeSessionDetective bool

type SessionContextCapabilities

+ NativeDetective bool

+ OperationScope *SessionDetectiveOperationScope

type SessionContextEnvironment

+ QuerySources []SessionContextQuerySource

+ type SessionContextQuerySource struct

+ CatalogRevision string

+ ConnectionID string

+ DatabaseID string

+ FixtureSHA256 string

+ Kind string

+ Origin string

+ type SessionDetectiveInputSelection struct

+ EntryID string

+ InputName string

+ RevisionID string

+ type SessionDetectiveOperationScope struct

+ DatabaseID string

+ NamespaceID string

+ Project string

+ ProjectID string

+ SpaceID string

+ Storage string

+ type SessionDetectiveRequest struct

+ Attachments []sessioncontext.EntryRef

+ Bindings []SessionDetectiveInputSelection

+ CaseID string

+ CheckID string

+ ExpectedContextSetID string

+ ExpectedVersion int64

+ Inputs map[string]core.InputValue

+ OperationID string

+ Scope sessioncontext.Scope

+ SessionID string

+ type SessionDetectiveResponse struct

+ OperationID string

+ OperationScope SessionDetectiveOperationScope

+ Status sessioncontext.AcceptedDetectiveStatus

Oct 15, 2026

Changes in this version

+ func DefaultSchemaForDriver(driver string) string

Oct 15, 2026

Changes in this version

type Capabilities

+ Access *agentaccess.Access

Oct 15, 2026

Changes in this version

+ func EnvironmentsListingSource(ctx context.Context, store datatug.ProjectStore, sourceID string) ([]string, error)

+ func PostgresDescriptorPath(environment, catalog string) string

+ func ResolveProjectSourceURL(ctx context.Context, store datatug.ProjectStore, ...) (string, error)

+ func WritePostgresDescriptor(projectDir, environment, catalog, dsnEnv string) (undo func() error, err error)

+ type AddedSource struct

+ Added bool

+ Driver string

+ Environment string

+ ID string

+ func AddProjectSource(ctx context.Context, store datatug.ProjectStore, projectDir string, ...) (AddedSource, error)

+ type AmbiguousSourceError struct

+ Environments []string

+ func (e *AmbiguousSourceError) Error() string

+ type ProjectSourceNotFoundError struct

+ func (e *ProjectSourceNotFoundError) Error() string

+ type ProjectSourceRefusal struct

+ func (e *ProjectSourceRefusal) Error() string

+ type ProjectSourceRequest struct

+ DSNEnv string

+ Environment string

+ ID string

+ SQLitePath string

+ type SourceUnresolvedError struct

+ Driver string

+ func (e *SourceUnresolvedError) Error() string

+ func (e *SourceUnresolvedError) Unwrap() error

Oct 15, 2026

Changes in this version

type CatalogColumn

+ IsNullable bool

Oct 14, 2026

Changes in this version

type Capabilities

+ DetectiveAIProfile *dtconfig.AIProfile

Oct 13, 2026

Changes in this version

+ func CloseSessionContext() error

+ type LocalCatalogConnection struct

+ BrowserFixture struct{ ... }

+ FixtureSHA256 string

+ Source string

+ type LocalConnectionCatalog struct

+ BigQueryEditions []datatug.EditionConnection

+ BigQueryPlans []datatug.ConnectionPlan

+ Connections []LocalCatalogConnection

+ Format string

+ func LocalProjectConnectionCatalog(_ context.Context, ref dto.ProjectRef) (*LocalConnectionCatalog, error)

+ type SessionContextCapabilities struct

+ Actions []string

+ ActorID string

+ DatabaseID string

+ Environments []SessionContextEnvironment

+ ProjectID string

+ SchemaVersion int

+ Subjects []SessionContextSubject

+ func ResolveSessionContext(ctx context.Context, storage, project string) (*sessioncontext.Service, sessioncontext.Principal, SessionContextCapabilities, ...)

+ type SessionContextEnvironment struct

+ EnvironmentID string

+ IdentityDomain string

+ Title string

+ type SessionContextSubject struct

+ ID string

+ Label string

+ Scope sessioncontext.Scope

+ Shape string

+ Subject sessioncontext.Subject

+ Type apicontract.ValueType

Oct 12, 2026

Changes in this version

+ func BeginCompareCache(ctx context.Context, req comparecache.BeginRequest) (*comparecache.WriteSession, error)

+ func CloseCompareCache() error

+ func ComparisonCacheID(left, right apicontract.ExecutionRef) string

+ func ConfigureCompareCache(options comparecache.Options) error

+ func LogCompareCacheSkip(op string, err error)

+ func LookupCompareCache(ctx context.Context, comparisonID string) (comparecache.Meta, error)

+ func PageCompareCache(ctx context.Context, req comparecache.PageRequest) (comparecache.Page, error)

Oct 7, 2026

Changes in this version

+ func ResolveCatalogSourceURL(catalog datatug.DbCatalog, projDir string) (string, error)

Oct 7, 2026

Changes in this version

+ func RequireLocalReadPrincipal() error

+ type ProjectBranch struct

+ Head string

+ Name string

+ type ProjectBranches struct

+ Branches []ProjectBranch

+ CurrentBranch string

+ DefaultBranch string

+ func LocalProjectBranches(ctx context.Context, ref dto.ProjectRef) (*ProjectBranches, error)

Oct 7, 2026

Changes in this version

+ var ErrProjectMutationOutcomeUncertain = errors.New("project mutation outcome is uncertain; reload and review the query")

+ func SecureProjectMutationScope(ref dto.ProjectRef, branch, kind string) (dto.OperationScope, error)

+ type LocalProjectQueryAdapter struct

+ func (LocalProjectQueryAdapter) Capabilities(_ context.Context, ref dto.ProjectRef) (dto.ProjectCapabilities, error)

+ func (LocalProjectQueryAdapter) GetQuery(ctx context.Context, request dto.GetQueryRequest) (*dto.GetQueryResponse, error)

+ func (LocalProjectQueryAdapter) SaveQuery(ctx context.Context, scope dto.OperationScope, request dto.SaveQueryRequest) (*dto.SaveQueryResponse, error)

Oct 5, 2026

Changes in this version

type PostgresScanParams

+ func (p *PostgresScanParams) LogTarget() string

Oct 5, 2026

Changes in this version

type Capabilities

+ AllowLiveConnections bool

+ type SourceUnavailableError struct

+ func SourceUnavailable(sourceID string, err error) *SourceUnavailableError

+ func (e *SourceUnavailableError) Error() string

Oct 5, 2026

Changes in this version

+ var ErrItemNotFound = errors.New("item not found")

Oct 5, 2026

Changes in this version

+ const HostRule

+ const MaxPathIdentifierLength

+ const PlainPathRule

+ var DriverRule = "must be one of " + strings.Join(dbServerDrivers, ", ")

+ func HostlessRule(driver string) string

+ func ValidatePathIdentifier(field, id string) error

+ func ValidateProjDbServerNames(server datatug.ProjDbServer) error

+ func ValidateProjectIdentifier(field, id string) error

+ func ValidateServerRef(server datatug.ServerRef) error

Oct 5, 2026

Changes in this version

+ func CheckScanDriverAgainstProject(projectDir, environment, catalogID, driver string) error

+ func OpenSchemaScanForTest() func(dbcopy.BackendRef, context.Context) (dbcopy.SchemaScanDB, error)

+ func ResolveDescriptorPath(projectDir, catalogPath string) (string, error)

+ func ResolveScanDbModelNoted(projectDir, environment, catalogID, flag string) (model, note string, err error)

+ func SetOpenSchemaScanForTest(open func(dbcopy.BackendRef, context.Context) (dbcopy.SchemaScanDB, error)) (restore func())

type PostgresScanParams

+ func (p *PostgresScanParams) Display() string

Oct 5, 2026

Changes in this version

+ const PlainNameRule

+ func ValidateCatalogIdentifiers(environmentID, catalogID string) error

+ func ValidateIdentifier(field, id string) error

Oct 5, 2026

Changes in this version

+ func CheckSQLitePath(path, absolute string) error

+ func CheckScanName(flag, value string) error

+ func CheckScanNamesAgainstProject(projectDir, environment, catalogID, model string) error

+ func LocalSQLiteSourceURL(path string) string

+ func ResolveScanDbModel(projectDir, environment, catalogID, flag string) (string, error)

+ func ScannedServer(driver string, dbConnParams dbconnection.Params) datatug.ServerRef

+ func WithScanWarnings(ctx context.Context, w io.Writer) context.Context

type ScannedCatalog

+ Server datatug.ServerRef

Oct 5, 2026

Changes in this version

+ func SaveScannedProject(ctx context.Context, store datatug.ProjectStore, projectDir string, ...) error

type CatalogColumn

+ PrimaryKeyPosition int

+ type ScannedCatalog struct

+ Driver string

+ Environment string

+ ID string

Oct 5, 2026

Changes in this version

+ func LookupError(format string, cause error, ids ...string) error

Oct 4, 2026

Changes in this version

+ const DriverPostgres

+ func CheckPostgresScanAvailable() error

+ type PostgresScanParams struct

+ func NewPostgresScanParams(lookupEnv func(string) (string, bool), dsnEnv, environment, catalog string) (*PostgresScanParams, error)

+ func (*PostgresScanParams) Driver() string

+ func (*PostgresScanParams) Mode() dbconnection.Mode

+ func (p *PostgresScanParams) Catalog() string

+ func (p *PostgresScanParams) ConnectionString() string

+ func (p *PostgresScanParams) DSNEnv() string

+ func (p *PostgresScanParams) Path() string

+ func (p *PostgresScanParams) Port() int

+ func (p *PostgresScanParams) Server() string

+ func (p *PostgresScanParams) SourceRef() dbcopy.BackendRef

+ func (p *PostgresScanParams) User() string

+ func (p *PostgresScanParams) WriteDescriptor(projectDir string) error

+ func (p PostgresScanParams) GoString() string

+ func (p PostgresScanParams) String() string

Sep 24, 2026

Changes in this version

type CatalogRelation

+ Issue string

type CatalogSchema

+ func GetCatalogSchemaPartial(projectDir, environmentID, catalogID string) (*CatalogSchema, error)

Sep 20, 2026

Changes in this version

+ type CatalogColumn struct

+ DbType string

+ Name string

+ type CatalogRelation struct

+ Columns []CatalogColumn

+ DbType string

+ Name string

+ Schema string

+ type CatalogSchema struct

+ Relations []CatalogRelation

+ func GetCatalogSchema(projectDir, environmentID, catalogID string) (*CatalogSchema, error)

Sep 13, 2026

Changes in this version

+ func IncidentStoreByID(projectID, storeID string) (incidents.APIStore, error)

+ func IncidentView(ctx context.Context, stored incidents.Incident, events []incidents.Event) (incidents.IncidentView, incidents.ViewPolicy, error)

+ func ResolveIncidentProject(projectID, environment string) (incidents.ProjectRef, error)

+ func SecureIncidentActor(via string) (incidents.Actor, error)

Sep 13, 2026

Changes in this version

+ func CloseExecutionEvidence() error

+ func ConfigureExecutionEvidence(pathsByID map[string]string, configured []incidentstore.ConfiguredStore, ...) error

+ func ExecutionEvidenceStore(projectID string, incident *incidents.IncidentRef) (*executionstore.Store, error)

+ func ExecutionEvidenceStoreByID(projectID, storeID string) (*executionstore.Store, error)

+ func SecurePolicyFingerprint() string

type Capabilities

+ EvidenceByteCap int

+ EvidencePrivateDir string

+ EvidenceRetention time.Duration

+ IncidentStores []incidentstore.ConfiguredStore

+ SnapshotPolicies map[string]SnapshotProjectPolicy

+ type SnapshotProjectPolicy struct

+ Sources map[string]SnapshotSourcePolicy

+ type SnapshotSourcePolicy struct

+ Allow bool

+ MaskedColumns []string

+ func SnapshotPolicy(projectID, sourceID string) (SnapshotSourcePolicy, bool)

Sep 12, 2026

Changes in this version

+ var ErrLegacyQueryWriteConflict = errors.New("the query kept changing while it was being saved, so nothing was saved")

+ func AuthorizeProjectQueryWrite(ctx context.Context, projectID, queryID string, operation access.Operations) error

Sep 10, 2026

Changes in this version

+ var ErrCatalogNotFound = errors.New("catalog not found")

+ type CatalogTable struct

+ DbType string

+ Name string

+ Schema string

+ type CatalogTables struct

+ Tables []CatalogTable

+ Views []CatalogTable

+ func GetCatalogTables(projectDir, environmentID, catalogID string) (*CatalogTables, error)

Sep 10, 2026

Changes in this version

type Capabilities

+ ExecTimeout time.Duration

+ HTTPOffline bool

Sep 9, 2026

Changes in this version

+ func PolicyCollectionName(name, driver string) string

Sep 9, 2026

Changes in this version

+ var ErrAmbiguousQueryID = errors.New("query id is ambiguous across folders")

+ var ErrQueryNotFound = errors.New("query not found")

+ func QueryIDIndex(projectDir string) (map[string]string, error)

+ func ResolveQueryID(projectDir, id string) (string, error)

Sep 9, 2026

Changes in this version

+ const LocalStoreID

+ var ErrAmbiguousStore = errors.New("project is served by more than one store")

+ var ErrUnknownStoreID = errors.New("unknown storage id")

+ func ConfiguredStoreIDs(projectID string) []string

+ func ResolveStoreID(explicit, projectID string) (string, error)

Sep 9, 2026

Changes in this version

+ func WarnMissingSourceFiles(ctx context.Context, pathsByID map[string]string)

Sep 9, 2026

Changes in this version

+ var ErrSourceUnavailable = errors.New("resolver: source unavailable")

+ func LoadQueryDocument(projectID, queryID string, queryType datatug.QueryType) (string, error)

+ func ProjectDir(projectID string) (string, bool)

+ func ProjectStoreFor(projectID string) (datatug.ProjectStore, error)

+ func SecureConfiguredProjectIDs() []string

+ func SecurePrincipalRolesGroups() (roles, groups []string)

+ func SecureSessionUnrestricted() bool

+ func SecurityContextID() string

+ func ValidateSecurityContext(id string) bool

+ type Capabilities struct

+ AllowOpaqueSQL bool

+ AllowWrites bool

+ func GetCapabilities() Capabilities

+ type ResolvedSource struct

+ Collection string

+ ID string

+ Kind SourceKind

+ Label string

+ URL string

+ func EligibleTargets(ctx context.Context, projStore datatug.ProjectStore, ...) ([]ResolvedSource, error)

+ func ListSources(ctx context.Context, projStore datatug.ProjectStore, ...) ([]ResolvedSource, error)

+ func ResolveSource(ctx context.Context, projStore datatug.ProjectStore, ...) (ResolvedSource, error)

+ type SourceKind string

+ const SourceKindHTTP

+ const SourceKindInGitDB

+ const SourceKindSQL

Sep 9, 2026

Changes in this version

+ func AuthTokenFromHTTPRequest(_ *http.Request, _ bool) (*sneatauth.Token, error)

+ func ResolveCatalogPath(projectDir, catalogPath string) (string, error)

+ type CommandExecutionResult struct

+ CommandID string

+ ElapsedMilliseconds int64

+ Items []CommandResponseItem

+ type CommandResponseItem struct

+ Type string

+ Value interface{}

+ type ExecuteCommandRequest struct

+ DB string

+ Env string

+ ID string

+ NamedParams map[string]any

+ Text string

+ Type string

+ func (v ExecuteCommandRequest) Validate() error

+ type ExecuteCommandsRequest struct

+ Commands []ExecuteCommandRequest

+ ID string

+ Project string

+ func (v ExecuteCommandsRequest) Validate() error

+ type ExecuteCommandsResponse struct

+ Commands []CommandExecutionResult

+ DurationMilliseconds int64

+ type ProvenanceDTO struct

+ Collection string

+ FetchedAt string

+ Source string

type QueryResultResponse

+ Provenance *ProvenanceDTO

Sep 9, 2026

Changes in this version

+ func ConfigureSecureSession(session secureread.Session, pathsByID map[string]string)

+ func SecureExecutor() (*secureread.Executor, bool)

+ func SecurePrincipalID() string

type AgentInfo

+ Principal string

+ type LimitationDTO struct

+ Columns []string

+ Count *int

+ Kind string

+ Note string

+ Policy string

+ type QueryResultResponse struct

+ Columns []string

+ Limitations []LimitationDTO

+ Rows []map[string]any

+ type RunQueryRequest struct

+ DTQL string

+ Database string

+ Environment string

+ Parameters map[string]any

+ ProjectID string

+ QueryID string

+ StoreID string

+ func (v RunQueryRequest) Validate() error

+ type RunQueryResponse struct

+ BindingsApplied map[string]any

+ func RunQuery(ctx context.Context, request RunQueryRequest) (RunQueryResponse, error)

May 14, 2026

Changes in this version

type ProjectLoader

+ LoadProjectFile func(ctx context.Context) (projectFile datatug.ProjectFile, err error)

Jan 4, 2026

Changes in this version

+ const DataTugAgentVersion

+ func AddDbServer(ctx context.Context, ref dto.ProjectRef, projDbServer datatug.ProjDbServer) error

+ func AddRowsToRecordset(params RecordsetDataRequestParams, _ []RowValues) (numberOfRecords int, err error)

+ func CreateBoard(ctx context.Context, ref dto.ProjectRef, board datatug.Board) (*datatug.Board, error)

+ func CreateFolder(ctx context.Context, request dto.CreateFolder) (folder *datatug.Folder, err error)

+ func CreateProject(ctx context.Context, request dto.CreateProjectRequest) (*datatug.ProjectSummary, error)

+ func CreateQuery(ctx context.Context, request dto.CreateQuery) (*datatug.QueryDefWithFolderPath, error)

+ func DeleteBoard(ctx context.Context, ref dto.ProjectItemRef) error

+ func DeleteDbServer(ctx context.Context, ref dto.ProjectRef, dbServer datatug.ServerRef) (err error)

+ func DeleteEntity(ctx context.Context, ref dto.ProjectItemRef) error

+ func DeleteFolder(ctx context.Context, ref dto.ProjectItemRef) error

+ func DeleteQuery(ctx context.Context, ref dto.ProjectItemRef) error

+ func ExecuteCommands(ctx context.Context, storeID string, request sqlexecute.Request) (response sqlexecute.Response, err error)

+ func ExecuteSelect(ctx context.Context, storeID string, selectRequest SelectRequest) (response sqlexecute.Response, err error)

+ func GetAllEntities(ctx context.Context, ref dto.ProjectRef) (entity datatug.Entities, err error)

+ func GetBoard(ctx context.Context, ref dto.ProjectItemRef) (*datatug.Board, error)

+ func GetDatasetDefinition(ctx context.Context, ref dto.ProjectItemRef) (dataset *datatug.RecordsetDefinition, err error)

+ func GetDbServerSummary(ctx context.Context, ref dto.ProjectRef, dbServer datatug.ServerRef) (*datatug.ProjDbServer, error)

+ func GetEntity(ctx context.Context, ref dto.ProjectItemRef) (entity *datatug.Entity, err error)

+ func GetEnvironmentSummary(ctx context.Context, ref dto.ProjectItemRef) (*datatug.EnvironmentSummary, error)

+ func GetProjectFull(ctx context.Context, ref dto.ProjectRef) (*datatug.Project, error)

+ func GetProjectSummary(ctx context.Context, ref dto.ProjectRef) (*datatug.ProjectSummary, error)

+ func GetProjects(ctx context.Context, storeID string) ([]datatug.ProjectBrief, error)

+ func GetQuery(ctx context.Context, ref dto.ProjectItemRef) (query *datatug.QueryDefWithFolderPath, err error)

+ func GetRecordset(_ context.Context, _ dto.ProjectItemRef) (recordset *datatug.Recordset, err error)

+ func GetRecordsetsSummary(ctx context.Context, ref dto.ProjectRef) (*dto.ProjRecordsetSummary, error)

+ func GetServerDatabases(request dto.GetServerDatabasesRequest) (databases []*datatug.DbCatalog, err error)

+ func RemoveRowsFromRecordset(params RecordsetDataRequestParams, rows []RowWithIndex) (numberOfRecordsAffected int, err error)

+ func SaveBoard(ctx context.Context, ref dto.ProjectRef, board datatug.Board) (*datatug.Board, error)

+ func SaveEntity(ctx context.Context, ref dto.ProjectRef, entity *datatug.Entity) error

+ func UpdateDbSchema(ctx context.Context, projectLoader ProjectLoader, ...) (project *datatug.Project, err error)

+ func UpdateDbServer(ctx context.Context, ref dto.ProjectRef, projDbServer datatug.ProjDbServer) error

+ func UpdateQuery(ctx context.Context, request dto.UpdateQuery) (*datatug.QueryDefWithFolderPath, error)

+ func UpdateRowsInRecordset(params RecordsetDataRequestParams, rows []RowWithIndexAndNewValues) (numberOfRecordsAffected int, err error)

+ type AgentInfo struct

+ UptimeMinutes float64

+ Version string

+ func GetAgentInfo() AgentInfo

+ type ProjectLoader interface

+ LoadProject func(ctx context.Context, o ...datatug.StoreOption) (project *datatug.Project, err error)

+ LoadProjectSummary func(ctx context.Context) (projectSummary datatug.ProjectSummary, err error)

+ type RecordsetDataRequestParams struct

+ Data string

+ func (v RecordsetDataRequestParams) Validate() error

+ type RecordsetRequestParams struct

+ Project string

+ Recordset string

+ func (v RecordsetRequestParams) Validate() error

+ type RowValues = map[string]interface

+ type RowWithIndex struct

+ Index int

+ Values map[string]interface{}

+ func (v RowWithIndex) Validate() error

+ type RowWithIndexAndNewValues struct

+ NewValues map[string]interface{}

+ type SelectRequest struct

+ Columns []string

+ Database string

+ Environment string

+ From string

+ Limit int

+ Parameters []datatug.Parameter

+ Project string

+ SQL string

+ Where string

+ func (v SelectRequest) Validate() error