client

package
v1.5.7 Latest Latest
Warning

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

Go to latest
Published: Feb 10, 2023 License: AGPL-3.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	SQLClient = "SQLClient"
	BQClient  = "BigQueryClient"
	DBClient  = "DBClient"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type Client

type Client struct {
	SQL       *sql.DB
	BQ        *bigquery.Client
	DBHandleT *databricks.DBHandleT
	Type      string
}

func (*Client) Close

func (cl *Client) Close()

func (*Client) Query

func (cl *Client) Query(statement string) (result warehouseutils.QueryResult, err error)

type StagingFile added in v1.5.0

type StagingFile struct {
	WorkspaceID   string
	SourceID      string
	DestinationID string
	Location      string

	Schema map[string]map[string]interface{}

	FirstEventAt          string
	LastEventAt           string
	TotalEvents           int
	TotalBytes            int
	UseRudderStorage      bool
	DestinationRevisionID string
	// cloud sources specific info
	SourceBatchID   string
	SourceTaskID    string
	SourceTaskRunID string
	SourceJobID     string
	SourceJobRunID  string
	TimeWindow      time.Time
}

StagingFile contains the require metadata to process a staging file.

type Warehouse added in v1.5.0

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

func NewWarehouse added in v1.5.0

func NewWarehouse(baseURL string, opts ...WarehouseOpts) *Warehouse

func (*Warehouse) Process added in v1.5.0

func (warehouse *Warehouse) Process(ctx context.Context, stagingFile StagingFile) error

type WarehouseOpts added in v1.5.0

type WarehouseOpts func(*Warehouse)

func WithTimeout added in v1.5.0

func WithTimeout(timeout time.Duration) WarehouseOpts

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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