Versions in this module Expand all Collapse all v0 v0.4.0 Aug 8, 2026 Changes in this version + var ErrNotImplemented = errors.New("not implemented") + func EnvFirst(vars ...string) func() string + func IntParam(v any) (int, bool) + func StringList(params map[string]any, key string) []string + type Column struct + Name string + Type string + type Connector interface + Scan func(ctx context.Context, req ScanRequest, emit func(*Rows) error) error + Tables func() []TableSchema + type Credential struct + func NewCredential(connector, name string, params map[string]any, staticKey string, ...) (*Credential, error) + func (c *Credential) Get(ctx context.Context) (string, error) + type CredentialFunc = func(ctx context.Context) (string, error) + type Factory func(params map[string]any) (Connector, error) + type Filter struct + Column string + Op Operator + Value any + Values []any + type ListOptions struct + Filter string + Limit int + type Operator int + const OpBetween + const OpEq + const OpGlob + const OpGt + const OpGte + const OpIn + const OpIs + const OpIsDistinctFrom + const OpIsNot + const OpIsNotDistinctFrom + const OpIsNotNull + const OpIsNull + const OpLike + const OpLt + const OpLte + const OpMatch + const OpNone + const OpNotBetween + const OpNotEq + const OpNotGlob + const OpNotIn + const OpNotLike + const OpNotMatch + const OpNotRegexp + const OpRegexp + func (o Operator) String() string + type OrderTerm struct + Column string + Desc bool + type Registry struct + func NewRegistry() *Registry + func (r *Registry) Build(typeName string, params map[string]any) (Connector, error) + func (r *Registry) Merge(other *Registry) + func (r *Registry) Register(typeName string, f Factory) + type Rows struct + Columns []string + Rows [][]any + Warnings []string + func Warn(format string, a ...any) *Rows + type ScanRequest struct + Columns []string + Filters []Filter + Limit *int + Offset *int + OrderBy []OrderTerm + Table string + func (r ScanRequest) Filter(column string) (Filter, bool) + type SchemaDescriber interface + DescribeTable func(ctx context.Context, table string) (ts TableSchema, found bool, err error) + type TableLister interface + ListTables func(ctx context.Context, opts ListOptions) ([]string, error) + type TableSchema struct + Columns []Column + Name string + func (t TableSchema) ColumnNames() []string
Go to main page