graph

Documentation

Index

• Variables
• func New(repo *database.Repo, gcp Bigquery, gcpProjects *auth.TeamProjectsMapping, ...) *handler.Server
• func WriteFileToBucket(ctx context.Context, gcsPath string, file graphql.Upload) error
• func WriteFilesToBucket(ctx context.Context, storyID string, files []*models.UploadFile) error
• type AccessManager
• type Bigquery
• type Polly
• type Resolver
  • func (r *Resolver) Access() generated.AccessResolver
  • func (r *Resolver) BigQuery() generated.BigQueryResolver
  • func (r *Resolver) Dataproduct() generated.DataproductResolver
  • func (r *Resolver) Dataset() generated.DatasetResolver
  • func (r *Resolver) InsightProduct() generated.InsightProductResolver
  • func (r *Resolver) Mutation() generated.MutationResolver
  • func (r *Resolver) Owner() generated.OwnerResolver
  • func (r *Resolver) Query() generated.QueryResolver
  • func (r *Resolver) SearchResultRow() generated.SearchResultRowResolver
  • func (r *Resolver) Story() generated.StoryResolver
  • func (r *Resolver) UserInfo() generated.UserInfoResolver
• type Slack

Variables

var ErrUnauthorized = fmt.Errorf("unauthorized")

Functions

func New

func New(repo *database.Repo, gcp Bigquery, gcpProjects *auth.TeamProjectsMapping, accessMgr AccessManager, tk teamkatalogen.Teamkatalogen, slack Slack, pollyAPI Polly, centralDataProject string, log *logrus.Entry) *handler.Server

func WriteFileToBucket

func WriteFileToBucket(ctx context.Context, gcsPath string,
	file graphql.Upload,
) error

func WriteFilesToBucket

func WriteFilesToBucket(ctx context.Context, storyID string,
	files []*models.UploadFile,
) error

Types

type AccessManager

type AccessManager interface {
	Grant(ctx context.Context, projectID, dataset, table, member string) error
	Revoke(ctx context.Context, projectID, dataset, table, member string) error
	AddToAuthorizedViews(ctx context.Context, srcProjectID, srcDataset, sinkProjectID, sinkDataset, sinkTable string) error
}

type Bigquery

type Bigquery interface {
	GetTables(ctx context.Context, projectID, datasetID string) ([]*models.BigQueryTable, error)
	GetDatasets(ctx context.Context, projectID string) ([]string, error)
	TableMetadata(ctx context.Context, projectID string, datasetID string, tableID string) (models.BigqueryMetadata, error)
	CreatePseudonymisedView(ctx context.Context, projectID string, datasetID string, tableID string, targetColumns []string) (string, string, string, error)
	CreateJoinableViewsForUser(ctx context.Context, name string, datasources []bq.JoinableViewDatasource) (string, string, map[uuid.UUID]string, error)
	MakeBigQueryUrlForJoinableViews(name, projectID, datasetID, tableID string) string
	DeleteJoinableDataset(ctx context.Context, datasetID string) error
	DeleteJoinableView(ctx context.Context, joinableViewName, refProjectID, refDatasetID, refTableID string) error
	DeletePseudoView(ctx context.Context, pseudoProjectID, pseudoDatasetID, pseudoTableID string) error
}

type Polly

type Polly interface {
	SearchPolly(ctx context.Context, q string) ([]*models.QueryPolly, error)
}

type Resolver

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

func (*Resolver) Access

func (r *Resolver) Access() generated.AccessResolver

Access returns generated.AccessResolver implementation.

func (*Resolver) BigQuery

func (r *Resolver) BigQuery() generated.BigQueryResolver

BigQuery returns generated.BigQueryResolver implementation.

func (*Resolver) Dataproduct

func (r *Resolver) Dataproduct() generated.DataproductResolver

Dataproduct returns generated.DataproductResolver implementation.

func (*Resolver) Dataset

func (r *Resolver) Dataset() generated.DatasetResolver

Dataset returns generated.DatasetResolver implementation.

func (*Resolver) InsightProduct

func (r *Resolver) InsightProduct() generated.InsightProductResolver

InsightProduct returns generated.InsightProductResolver implementation.

func (*Resolver) Mutation

func (r *Resolver) Mutation() generated.MutationResolver

Mutation returns generated.MutationResolver implementation.

func (*Resolver) Owner

func (r *Resolver) Owner() generated.OwnerResolver

Owner returns generated.OwnerResolver implementation.

func (*Resolver) Query

func (r *Resolver) Query() generated.QueryResolver

Query returns generated.QueryResolver implementation.

func (*Resolver) SearchResultRow

func (r *Resolver) SearchResultRow() generated.SearchResultRowResolver

SearchResultRow returns generated.SearchResultRowResolver implementation.

func (*Resolver) Story

func (r *Resolver) Story() generated.StoryResolver

Story returns generated.StoryResolver implementation.

func (*Resolver) UserInfo

func (r *Resolver) UserInfo() generated.UserInfoResolver

UserInfo returns generated.UserInfoResolver implementation.

type Slack

type Slack interface {
	NewAccessRequest(contact string, dp *models.Dataproduct, ds *models.Dataset, ar *models.AccessRequest) error
	IsValidSlackChannel(name string) (bool, error)
}