databricks

package
v0.4.10 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 13, 2025 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewQuerier

func NewQuerier[T any](conn *DatabricksExecutor) querier.Querier[T]

Types

type Auth

type Auth interface {
	Configure(config *databricks.Config)
}

type DatabricksConf

type DatabricksConf struct {
	WorkspaceUrl string
	Auth         Auth
	WarehouseId  string
}

type DatabricksExecutor

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

func NewDatabricksExecutor

func NewDatabricksExecutor(ctx context.Context, conf *DatabricksConf) (*DatabricksExecutor, error)

func (*DatabricksExecutor) Close

func (e *DatabricksExecutor) Close() error

func (*DatabricksExecutor) GetDb

func (e *DatabricksExecutor) GetDb() *sqlx.DB

func (*DatabricksExecutor) QueryRows

func (e *DatabricksExecutor) QueryRows(ctx context.Context, sql string, args ...interface{}) (*sqlx.Rows, error)

type Executor

type Executor interface {
	stdsql.StdSqlExecutor
}

type OAuthM2mAuth

type OAuthM2mAuth struct {
	ClientId     string
	ClientSecret string
}

func NewOAuthM2mAuth

func NewOAuthM2mAuth(clientId, clientSecret string) *OAuthM2mAuth

func (OAuthM2mAuth) Configure

func (o OAuthM2mAuth) Configure(config *databricks.Config)

type TokenAuth

type TokenAuth struct {
	Token string
}

func NewTokenAuth

func NewTokenAuth(token string) *TokenAuth

func (TokenAuth) Configure

func (t TokenAuth) Configure(config *databricks.Config)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL