postgres

Documentation

Index

• func From[I Converter[O], O any](i I) (O, error)
• func NewAccessStorage(queries AccessQueries, fn AccessQueriesWithTxFn) *accessStorage
• func NewBigQueryStorage(db *database.Repo) *bigQueryStorage
• func NewDataProductStorage(databasesBaseURL string, db *database.Repo, log zerolog.Logger) *dataProductStorage
• func NewInsightProductStorage(db *database.Repo) *insightProductStorage
• func NewJoinableViewStorage(db *database.Repo) *joinableViewStorage
• func NewKeywordsStorage(db *database.Repo) *keywordsStorage
• func NewMetabaseStorage(db *database.Repo) *metabaseStorage
• func NewNaisConsoleStorage(db *database.Repo) *naisConsoleStorage
• func NewPollyStorage(db *database.Repo) *pollyStorage
• func NewProductAreaStorage(db *database.Repo) *productAreaStorage
• func NewSearchStorage(db *database.Repo) *searchStorage
• func NewStoryStorage(db *database.Repo) *storyStorage
• func NewThirdPartyMappingStorage(db *database.Repo) *thirdPartyMappingStorage
• func NewTokenStorage(db *database.Repo) *tokenStorage
• type AccessQueries
• type AccessQueriesWithTxFn
• type AccessRequestStatusType
  • func (a AccessRequestStatusType) To() (service.AccessRequestStatus, error)
• type Converter
• type DatasetAccess
  • func (a DatasetAccess) To() (*service.Access, error)
• type DatasetAccessRequest
  • func (d DatasetAccessRequest) To() (*service.AccessRequest, error)
• type DatasetAccessRequests
  • func (d DatasetAccessRequests) To() ([]*service.AccessRequest, error)
• type MetabaseMetadata
  • func ToLocal(m gensql.MetabaseMetadatum) MetabaseMetadata
  • func (m MetabaseMetadata) Convert() *service.MetabaseMetadata
• type StoryWithTeamkatalogenView
  • func (s StoryWithTeamkatalogenView) To() (*service.Story, error)
• type StoryWithTeamkatalogenViewList
  • func (s StoryWithTeamkatalogenViewList) To() ([]*service.Story, error)

Functions

func From

func From[I Converter[O], O any](i I) (O, error)

func NewAccessStorage

func NewAccessStorage(queries AccessQueries, fn AccessQueriesWithTxFn) *accessStorage

func NewBigQueryStorage

func NewBigQueryStorage(db *database.Repo) *bigQueryStorage

func NewDataProductStorage

func NewDataProductStorage(databasesBaseURL string, db *database.Repo, log zerolog.Logger) *dataProductStorage

func NewInsightProductStorage

func NewInsightProductStorage(db *database.Repo) *insightProductStorage

func NewJoinableViewStorage

func NewJoinableViewStorage(db *database.Repo) *joinableViewStorage

func NewKeywordsStorage

func NewKeywordsStorage(db *database.Repo) *keywordsStorage

func NewMetabaseStorage

func NewMetabaseStorage(db *database.Repo) *metabaseStorage

func NewNaisConsoleStorage

func NewNaisConsoleStorage(db *database.Repo) *naisConsoleStorage

func NewPollyStorage

func NewPollyStorage(db *database.Repo) *pollyStorage

func NewProductAreaStorage

func NewProductAreaStorage(db *database.Repo) *productAreaStorage

func NewSearchStorage

func NewSearchStorage(db *database.Repo) *searchStorage

func NewStoryStorage

func NewStoryStorage(db *database.Repo) *storyStorage

func NewThirdPartyMappingStorage

func NewThirdPartyMappingStorage(db *database.Repo) *thirdPartyMappingStorage

func NewTokenStorage

func NewTokenStorage(db *database.Repo) *tokenStorage

Types

type AccessQueries

type AccessQueries interface {
	ListAccessRequestsForOwner(ctx context.Context, owner []string) ([]gensql.DatasetAccessRequest, error)
	ListUnrevokedExpiredAccessEntries(ctx context.Context) ([]gensql.DatasetAccess, error)
	ListActiveAccessToDataset(ctx context.Context, datasetID uuid.UUID) ([]gensql.DatasetAccess, error)
	ListAccessRequestsForDataset(ctx context.Context, datasetID uuid.UUID) ([]gensql.DatasetAccessRequest, error)
	CreateAccessRequestForDataset(ctx context.Context, params gensql.CreateAccessRequestForDatasetParams) (gensql.DatasetAccessRequest, error)
	GetAccessRequest(ctx context.Context, id uuid.UUID) (gensql.DatasetAccessRequest, error)
	DeleteAccessRequest(ctx context.Context, id uuid.UUID) error
	UpdateAccessRequest(ctx context.Context, params gensql.UpdateAccessRequestParams) (gensql.DatasetAccessRequest, error)
	GrantAccessToDataset(ctx context.Context, params gensql.GrantAccessToDatasetParams) (gensql.DatasetAccess, error)
	ApproveAccessRequest(ctx context.Context, params gensql.ApproveAccessRequestParams) error
	GetActiveAccessToDatasetForSubject(ctx context.Context, params gensql.GetActiveAccessToDatasetForSubjectParams) (gensql.DatasetAccess, error)
	RevokeAccessToDataset(ctx context.Context, id uuid.UUID) error
	DenyAccessRequest(ctx context.Context, params gensql.DenyAccessRequestParams) error
	GetAccessToDataset(ctx context.Context, id uuid.UUID) (gensql.DatasetAccess, error)
}

type AccessQueriesWithTxFn

type AccessQueriesWithTxFn func() (AccessQueries, database.Transacter, error)

type AccessRequestStatusType

type AccessRequestStatusType gensql.AccessRequestStatusType

func (AccessRequestStatusType) To

func (a AccessRequestStatusType) To() (service.AccessRequestStatus, error)

type Converter

type Converter[O any] interface {
	To() (O, error)
}

type DatasetAccess

type DatasetAccess gensql.DatasetAccess

func (DatasetAccess) To

func (a DatasetAccess) To() (*service.Access, error)

type DatasetAccessRequest

type DatasetAccessRequest gensql.DatasetAccessRequest

func (DatasetAccessRequest) To

func (d DatasetAccessRequest) To() (*service.AccessRequest, error)

type DatasetAccessRequests

type DatasetAccessRequests []gensql.DatasetAccessRequest

func (DatasetAccessRequests) To

func (d DatasetAccessRequests) To() ([]*service.AccessRequest, error)

type MetabaseMetadata

type MetabaseMetadata gensql.MetabaseMetadatum

func ToLocal

func ToLocal(m gensql.MetabaseMetadatum) MetabaseMetadata

func (MetabaseMetadata) Convert

func (m MetabaseMetadata) Convert() *service.MetabaseMetadata

type StoryWithTeamkatalogenView

type StoryWithTeamkatalogenView gensql.StoryWithTeamkatalogenView

func (StoryWithTeamkatalogenView) To

func (s StoryWithTeamkatalogenView) To() (*service.Story, error)

type StoryWithTeamkatalogenViewList

type StoryWithTeamkatalogenViewList []gensql.StoryWithTeamkatalogenView

func (StoryWithTeamkatalogenViewList) To

func (s StoryWithTeamkatalogenViewList) To() ([]*service.Story, error)