connection

Jan 26, 2026

Changes in this version

type Connection

+ func (c *Connection) GetType() dbio.Type

Dec 20, 2025

Changes in this version

type Connection

+ func (c *Connection) IsADBC() bool

type EnvFileConns

+ func (ec *EnvFileConns) Keys() []string

Dec 7, 2025

Changes in this version

type AsConnOptions

+ Expire int

Oct 17, 2025

Changes in this version

+ type AsConnOptions struct

+ Extra map[string]any

+ UseCache bool

type Connection

+ func (c *Connection) DataSWithExtra(extra map[string]any) map[string]string

Jun 27, 2025

Changes in this version

+ type LocalConnsExclude string

May 13, 2025

Changes in this version

type ConnEntries

+ func (ce ConnEntries) Names() (names []string)

Apr 17, 2025

Changes in this version

+ func LoadAPISpec(specLocation string) (spec api.Spec, err error)

type Connection

+ API *api.APIConnection

+ func ParseLocation(location string) (conn Connection, objectExpr string, err error)

+ func (c *Connection) AsAPI(cache ...bool) (ac *api.APIConnection, err error)

+ func (c *Connection) AsAPIContext(ctx context.Context, cache ...bool) (ac *api.APIConnection, err error)

Jan 15, 2025

Changes in this version

+ func CloseAll()

Dec 27, 2024

Changes in this version

type Connection

+ func (c *Connection) AsDatabaseContext(ctx context.Context, cache ...bool) (dc database.Connection, err error)

+ func (c *Connection) AsFileContext(ctx context.Context, cache ...bool) (fc filesys.FileSysClient, err error)

Sep 22, 2024

Changes in this version

type ConnEntries

+ func (ce ConnEntries) Discover(name string, opt *DiscoverOptions) (nodes filesys.FileNodes, schemata database.Schemata, err error)

+ func (ce ConnEntries) List() (fields []string, rows [][]any)

+ func (ce ConnEntries) Test(name string) (ok bool, err error)

type DiscoverOptions

+ Level database.SchemataLevel

+ type EnvFileConns struct

+ EnvFile *env.EnvFile

+ Name string

+ func (ec *EnvFileConns) ConnectionEntries() (entries ConnEntries, err error)

+ func (ec *EnvFileConns) GetConnEntry(name string) (conn ConnEntry, ok bool)

+ func (ec *EnvFileConns) Set(name string, kvMap map[string]any) (err error)

+ func (ec *EnvFileConns) Unset(name string) (err error)

Aug 27, 2024

Changes in this version

+ type ConnEntries []ConnEntry

+ func (ce ConnEntries) Get(name string) ConnEntry

type Connection

+ Database database.Connection

+ File filesys.FileSysClient

+ func (c *Connection) Discover(opt *DiscoverOptions) (ok bool, nodes filesys.FileNodes, schemata database.Schemata, err error)

+ func (c *Connection) Test() (ok bool, err error)

Aug 14, 2024

Changes in this version

type ConnEntry

+ func EnvFileConnectionEntries(ef env.EnvFile, sourceName string) (entries []ConnEntry, err error)

Mar 31, 2024

Changes in this version

type DiscoverOptions

+ Discover bool

Mar 23, 2024

Changes in this version

type DiscoverOptions

+ ColumnLevel bool

+ Pattern string

Feb 26, 2024

Changes in this version

type DiscoverOptions

+ Stream string

Feb 7, 2024

Changes in this version

+ func CopyDirect(conn database.Connection, tableFName string, srcFile Connection) (cnt uint64, ok bool, err error)

+ func ReadConnections(env map[string]interface{}) (conns map[string]Connection, err error)

+ func ReadConnectionsEnv(env map[string]interface{}) (conns map[string]Connection, err error)

+ func ReadConnectionsFromFile(path string) (conns map[string]Connection, err error)

+ func ReadDbtConnections() (conns map[string]Connection, err error)

+ func SchemeType(url string) dbio.Type

+ type ConnEntry struct

+ Connection Connection

+ Description string

+ Name string

+ Source string

+ func GetLocalConns(force ...bool) []ConnEntry

+ func LocalFileConnEntry() ConnEntry

+ type Connection struct

+ Data map[string]interface{}

+ Name string

+ Type dbio.Type

+ func NewConnection(Name string, t dbio.Type, Data map[string]interface{}) (conn Connection, err error)

+ func NewConnectionFromDbt(name string) (c Connection, err error)

+ func NewConnectionFromMap(m map[string]interface{}) (c Connection, err error)

+ func NewConnectionFromProfiles(name string) (c Connection, err error)

+ func NewConnectionFromURL(Name, URL string) (conn Connection, err error)

+ func (c *Connection) AsDatabase() (database.Connection, error)

+ func (c *Connection) AsFile() (filesys.FileSysClient, error)

+ func (c *Connection) Close() error

+ func (c *Connection) ConnSetDatabase(dbName string) *Connection

+ func (c *Connection) Context() *g.Context

+ func (c *Connection) Copy() *Connection

+ func (c *Connection) DataS(lowerCase ...bool) map[string]string

+ func (c *Connection) Hash() string

+ func (c *Connection) Info() Info

+ func (c *Connection) Set(m map[string]interface{})

+ func (c *Connection) ToMap() map[string]interface{}

+ func (c *Connection) URL() string

+ type ConnectionInt interface

+ AsDatabase func() (database.Connection, error)

+ AsFile func() (filesys.FileSysClient, error)

+ Close func() error

+ Context func() g.Context

+ DataS func(lowerCase ...bool) map[string]string

+ Info func() Info

+ Set func(map[string]interface{})

+ ToMap func() map[string]interface{}

+ URL func() string

+ type DiscoverOptions struct

+ Filter string

+ Folder string

+ Recursive bool

+ Schema string

+ type EnvConns struct

+ EnvFile *env.EnvFile

+ func (ec *EnvConns) Discover(name string, opt DiscoverOptions) (streamNames []string, err error)

+ func (ec *EnvConns) GetConnEntry(name string) (conn ConnEntry, ok bool)

+ func (ec *EnvConns) List() string

+ func (ec *EnvConns) Set(name string, kvMap map[string]any) (err error)

+ func (ec *EnvConns) Test(name string) (ok bool, err error)

+ func (ec *EnvConns) Unset(name string) (err error)

+ type Info struct

+ Data map[string]interface{}

+ Database string

+ LongType string

+ Name string

+ Type dbio.Type

+ func (i *Info) IsURL() bool