metadata

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: Nov 17, 2023 License: MIT Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrDuplicatedTable = errors.New("table is already created")

Functions

This section is empty.

Types

type Dataset 

type Dataset struct {
	ID        string
	ProjectID string
	// contains filtered or unexported fields
}

func NewDataset 

func NewDataset(
	repo *Repository,
	projectID string,
	datasetID string,
	content *bigqueryv2.Dataset,
	tables []*Table,
	models []*Model,
	routines []*Routine) *Dataset

func (*Dataset) AddTable 

func (d *Dataset) AddTable(ctx context.Context, tx *sql.Tx, table *Table) error

func (*Dataset) Content 

func (d *Dataset) Content() *bigqueryv2.Dataset

func (*Dataset) Delete 

func (d *Dataset) Delete(ctx context.Context, tx *sql.Tx) error

func (*Dataset) DeleteModel 

func (d *Dataset) DeleteModel(ctx context.Context, tx *sql.Tx, id string) error

func (*Dataset) Insert 

func (d *Dataset) Insert(ctx context.Context, tx *sql.Tx) error

func (*Dataset) Model 

func (d *Dataset) Model(id string) *Model

func (*Dataset) ModelIDs 

func (d *Dataset) ModelIDs() []string

func (*Dataset) Models 

func (d *Dataset) Models() []*Model

func (*Dataset) Routine 

func (d *Dataset) Routine(id string) *Routine

func (*Dataset) RoutineIDs 

func (d *Dataset) RoutineIDs() []string

func (*Dataset) Routines 

func (d *Dataset) Routines() []*Routine

func (*Dataset) Table 

func (d *Dataset) Table(id string) *Table

func (*Dataset) TableIDs 

func (d *Dataset) TableIDs() []string

func (*Dataset) Tables 

func (d *Dataset) Tables() []*Table

func (*Dataset) UpdateContent 

func (d *Dataset) UpdateContent(newContent *bigqueryv2.Dataset)

func (*Dataset) UpdateContentIfExists 

func (d *Dataset) UpdateContentIfExists(newContent *bigqueryv2.Dataset)

type Job 

type Job struct {
	ID        string
	ProjectID string
	// contains filtered or unexported fields
}

func NewJob 

func NewJob(repo *Repository, projectID, jobID string, content *bigqueryv2.Job, response *internaltypes.QueryResponse, err error) *Job

func (*Job) Cancel 

func (j *Job) Cancel(ctx context.Context) error

func (*Job) Content 

func (j *Job) Content() *bigqueryv2.Job

func (*Job) Delete 

func (j *Job) Delete(ctx context.Context, tx *sql.Tx) error

func (*Job) Insert 

func (j *Job) Insert(ctx context.Context, tx *sql.Tx) error

func (*Job) Query 

func (j *Job) Query() string

func (*Job) QueryParameters 

func (j *Job) QueryParameters() []*bigqueryv2.QueryParameter

func (*Job) SetResult 

func (j *Job) SetResult(ctx context.Context, tx *sql.Tx, response *internaltypes.QueryResponse, err error) error

func (*Job) Wait 

func (j *Job) Wait(ctx context.Context) (*internaltypes.QueryResponse, error)

type Model 

type Model struct {
	ID        string
	ProjectID string
	DatasetID string
	// contains filtered or unexported fields
}

func NewModel 

func NewModel(repo *Repository, projectID, datasetID, modelID string, metadata map[string]interface{}) *Model

func (*Model) Delete 

func (m *Model) Delete(ctx context.Context, tx *sql.Tx) error

func (*Model) Insert 

func (m *Model) Insert(ctx context.Context, tx *sql.Tx) error

type Project 

type Project struct {
	ID string
	// contains filtered or unexported fields
}

func NewProject 

func NewProject(repo *Repository, id string, datasets []*Dataset, jobs []*Job) *Project

func (*Project) AddDataset 

func (p *Project) AddDataset(ctx context.Context, tx *sql.Tx, dataset *Dataset) error

func (*Project) AddJob 

func (p *Project) AddJob(ctx context.Context, tx *sql.Tx, job *Job) error

func (*Project) Dataset 

func (p *Project) Dataset(id string) *Dataset

func (*Project) DatasetIDs 

func (p *Project) DatasetIDs() []string

func (*Project) Datasets 

func (p *Project) Datasets() []*Dataset

func (*Project) Delete 

func (p *Project) Delete(ctx context.Context, tx *sql.Tx) error

func (*Project) DeleteDataset 

func (p *Project) DeleteDataset(ctx context.Context, tx *sql.Tx, id string) error

func (*Project) DeleteJob 

func (p *Project) DeleteJob(ctx context.Context, tx *sql.Tx, id string) error

func (*Project) Insert 

func (p *Project) Insert(ctx context.Context, tx *sql.Tx) error

func (*Project) Job 

func (p *Project) Job(id string) *Job

func (*Project) JobIDs 

func (p *Project) JobIDs() []string

func (*Project) Jobs 

func (p *Project) Jobs() []*Job

type Repository 

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

func NewRepository 

func NewRepository(db *sql.DB) (*Repository, error)

func (*Repository) AddDataset 

func (r *Repository) AddDataset(ctx context.Context, tx *sql.Tx, dataset *Dataset) error

func (*Repository) AddJob 

func (r *Repository) AddJob(ctx context.Context, tx *sql.Tx, job *Job) error

func (*Repository) AddModel 

func (r *Repository) AddModel(ctx context.Context, tx *sql.Tx, model *Model) error

func (*Repository) AddProject 

func (r *Repository) AddProject(ctx context.Context, tx *sql.Tx, project *Project) error

func (*Repository) AddProjectIfNotExists 

func (r *Repository) AddProjectIfNotExists(ctx context.Context, tx *sql.Tx, project *Project) error

func (*Repository) AddRoutine 

func (r *Repository) AddRoutine(ctx context.Context, tx *sql.Tx, routine *Routine) error

func (*Repository) AddTable 

func (r *Repository) AddTable(ctx context.Context, tx *sql.Tx, table *Table) error

func (*Repository) DatasetFromData 

func (r *Repository) DatasetFromData(projectID string, data *types.Dataset) *Dataset

func (*Repository) DeleteDataset 

func (r *Repository) DeleteDataset(ctx context.Context, tx *sql.Tx, dataset *Dataset) error

func (*Repository) DeleteJob 

func (r *Repository) DeleteJob(ctx context.Context, tx *sql.Tx, job *Job) error

func (*Repository) DeleteModel 

func (r *Repository) DeleteModel(ctx context.Context, tx *sql.Tx, model *Model) error

func (*Repository) DeleteProject 

func (r *Repository) DeleteProject(ctx context.Context, tx *sql.Tx, project *Project) error

func (*Repository) DeleteRoutine 

func (r *Repository) DeleteRoutine(ctx context.Context, tx *sql.Tx, routine *Routine) error

func (*Repository) DeleteTable 

func (r *Repository) DeleteTable(ctx context.Context, tx *sql.Tx, table *Table) error

func (*Repository) FindAllProjects 

func (r *Repository) FindAllProjects(ctx context.Context) ([]*Project, error)

func (*Repository) FindDataset 

func (r *Repository) FindDataset(ctx context.Context, projectID, datasetID string) (*Dataset, error)

func (*Repository) FindJob 

func (r *Repository) FindJob(ctx context.Context, projectID, jobID string) (*Job, error)

func (*Repository) FindModel 

func (r *Repository) FindModel(ctx context.Context, projectID, datasetID, modelID string) (*Model, error)

func (*Repository) FindProject 

func (r *Repository) FindProject(ctx context.Context, id string) (*Project, error)

func (*Repository) FindProjectWithConn 

func (r *Repository) FindProjectWithConn(ctx context.Context, tx *sql.Tx, id string) (*Project, error)

func (*Repository) FindRoutine 

func (r *Repository) FindRoutine(ctx context.Context, projectID, datasetID, routineID string) (*Routine, error)

func (*Repository) FindTable 

func (r *Repository) FindTable(ctx context.Context, projectID, datasetID, tableID string) (*Table, error)

func (*Repository) JobFromData 

func (r *Repository) JobFromData(projectID string, data *types.Job) *Job

func (*Repository) ModelFromData 

func (r *Repository) ModelFromData(projectID, datasetID string, data *types.Model) *Model

func (*Repository) ProjectFromData 

func (r *Repository) ProjectFromData(data *types.Project) *Project

func (*Repository) RoutineFromData 

func (r *Repository) RoutineFromData(projectID, datasetID string, data *types.Routine) *Routine

func (*Repository) TableFromData 

func (r *Repository) TableFromData(projectID, datasetID string, data *types.Table) *Table

func (*Repository) UpdateDataset 

func (r *Repository) UpdateDataset(ctx context.Context, tx *sql.Tx, dataset *Dataset) error

func (*Repository) UpdateJob 

func (r *Repository) UpdateJob(ctx context.Context, tx *sql.Tx, job *Job) error

func (*Repository) UpdateModel 

func (r *Repository) UpdateModel(ctx context.Context, tx *sql.Tx, model *Model) error

func (*Repository) UpdateProject 

func (r *Repository) UpdateProject(ctx context.Context, tx *sql.Tx, project *Project) error

func (*Repository) UpdateRoutine 

func (r *Repository) UpdateRoutine(ctx context.Context, tx *sql.Tx, routine *Routine) error

func (*Repository) UpdateTable 

func (r *Repository) UpdateTable(ctx context.Context, tx *sql.Tx, table *Table) error

type Routine 

type Routine struct {
	ID        string
	ProjectID string
	DatasetID string
	// contains filtered or unexported fields
}

func NewRoutine 

func NewRoutine(repo *Repository, projectID, datasetID, routineID string, metadata map[string]interface{}) *Routine

type Table 

type Table struct {
	ID        string
	ProjectID string
	DatasetID string
	// contains filtered or unexported fields
}

func NewTable 

func NewTable(repo *Repository, projectID, datasetID, tableID string, metadata map[string]interface{}) *Table

func (*Table) Content 

func (t *Table) Content() (*bigqueryv2.Table, error)

func (*Table) Delete 

func (t *Table) Delete(ctx context.Context, tx *sql.Tx) error

func (*Table) Insert 

func (t *Table) Insert(ctx context.Context, tx *sql.Tx) error

func (*Table) Update 

func (t *Table) Update(ctx context.Context, tx *sql.Tx, metadata map[string]interface{}) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.