Documentation
¶
Index ¶
- func NewQuerier[T any](conn *DatabricksExecutor) querier.Querier[T]
- type Auth
- type DatabricksConf
- type DatabricksExecutor
- func (e *DatabricksExecutor) Close() error
- func (e *DatabricksExecutor) Exec(ctx context.Context, query string, args ...any) error
- func (e *DatabricksExecutor) GetDb() *sqlx.DB
- func (e *DatabricksExecutor) QueryRows(ctx context.Context, sql string, args ...interface{}) (*sqlx.Rows, error)
- func (e *DatabricksExecutor) Select(ctx context.Context, dest any, query string, args ...any) error
- type Executor
- type OAuthM2mAuth
- type TokenAuth
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 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
type Executor ¶
type Executor interface {
stdsql.StdSqlExecutor
}
type OAuthM2mAuth ¶
func NewOAuthM2mAuth ¶
func NewOAuthM2mAuth(clientId, clientSecret string) *OAuthM2mAuth
func (OAuthM2mAuth) Configure ¶
func (o OAuthM2mAuth) Configure(config *databricks.Config)
Click to show internal directories.
Click to hide internal directories.