bigquery

package
v0.0.0-...-b508d79 Latest Latest
Warning

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

Go to latest
Published: Apr 29, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func MakeJoinableViewName

func MakeJoinableViewName(projectID, datasetID, tableID string) string

Types

type Bigquery

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

func New

func New(ctx context.Context, centralDataProject, pseudoDataset string) (*Bigquery, error)

func (*Bigquery) ComposeJoinableViewQuery

func (c *Bigquery) ComposeJoinableViewQuery(plainTableUrl models.BigQuery, joinableDatasetID string, pseudoColumns []string) string

func (*Bigquery) ComposePseudoViewQuery

func (c *Bigquery) ComposePseudoViewQuery(projectID, datasetID, tableID string, targetColumns []string) string

func (*Bigquery) CreateJoinableView

func (c *Bigquery) CreateJoinableView(ctx context.Context, joinableDatasetID string, datasource JoinableViewDatasource) (string, error)

func (*Bigquery) CreateJoinableViewsForUser

func (c *Bigquery) CreateJoinableViewsForUser(ctx context.Context, name string, datasources []JoinableViewDatasource) (string, string, map[uuid.UUID]string, error)

func (*Bigquery) CreatePseudonymisedView

func (c *Bigquery) CreatePseudonymisedView(ctx context.Context, projectID, datasetID, tableID string, piiColumns []string) (string, string, string, error)

func (*Bigquery) DeleteJoinableDataset

func (c *Bigquery) DeleteJoinableDataset(ctx context.Context, datasetID string) error

func (*Bigquery) DeleteJoinableView

func (c *Bigquery) DeleteJoinableView(ctx context.Context, joinableViewName, refProjectID, refDatasetID, refTableID string) error

func (*Bigquery) DeletePseudoView

func (c *Bigquery) DeletePseudoView(ctx context.Context, pseudoProjectID, pseudoDatasetID, pseudoTableID string) error

func (*Bigquery) GetDatasets

func (c *Bigquery) GetDatasets(ctx context.Context, projectID string) ([]string, error)

func (*Bigquery) GetTables

func (c *Bigquery) GetTables(ctx context.Context, projectID, datasetID string) ([]*models.BigQueryTable, error)

func (*Bigquery) MakeBigQueryUrlForJoinableViews

func (c *Bigquery) MakeBigQueryUrlForJoinableViews(name, projectID, datasetID, tableID string) string

func (*Bigquery) TableMetadata

func (c *Bigquery) TableMetadata(ctx context.Context, projectID string, datasetID string, tableID string) (models.BigqueryMetadata, error)

type JoinableViewDatasource

type JoinableViewDatasource struct {
	RefDatasource    *models.BigQuery
	PseudoDatasource *models.BigQuery
}

type Mock

type Mock struct {
	Tables []*models.BigQueryTable
}

func NewMock

func NewMock() *Mock

func (*Mock) CreateJoinableViewsForUser

func (c *Mock) CreateJoinableViewsForUser(ctx context.Context, user string, tableUrls []JoinableViewDatasource) (string, string, map[uuid.UUID]string, error)

func (*Mock) CreatePseudonymisedView

func (m *Mock) CreatePseudonymisedView(ctx context.Context, projectID, datasetID, tableID string, piiColumns []string) (string, string, string, error)

func (*Mock) DeleteJoinableDataset

func (c *Mock) DeleteJoinableDataset(ctx context.Context, datasetID string) error

func (*Mock) DeleteJoinableView

func (c *Mock) DeleteJoinableView(ctx context.Context, joinableViewName, refProjectID, refDatasetID, refTableID string) error

func (*Mock) DeletePseudoView

func (c *Mock) DeletePseudoView(ctx context.Context, pseudoProjectID, pseudoDatasetID, pseudoTableID string) error

func (*Mock) GetDatasets

func (m *Mock) GetDatasets(ctx context.Context, projectID string) ([]string, error)

func (*Mock) GetJoinableViewsForUser

func (c *Mock) GetJoinableViewsForUser(ctx context.Context, user *auth.User) ([]*models.JoinableView, error)

func (*Mock) GetTables

func (m *Mock) GetTables(ctx context.Context, projectID, datasetID string) ([]*models.BigQueryTable, error)

func (*Mock) MakeBigQueryUrlForJoinableViews

func (c *Mock) MakeBigQueryUrlForJoinableViews(name, projectID, datasetID, tableID string) string

func (*Mock) TableMetadata

func (m *Mock) TableMetadata(ctx context.Context, projectID string, datasetID string, tableID string) (models.BigqueryMetadata, error)

Jump to

Keyboard shortcuts

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