bigquery

Oct 16, 2023

Changes in this version

+ func GetAlteredDataSourceMetaData(ctx context.Context, config *config.ConfigMap) (*ds.MetaData, error)

Oct 2, 2023

Changes in this version

+ const GcpRolesToGroupByIdentity

May 2, 2023

Changes in this version

+ func GetDataUsageStartDate(ctx context.Context, configMap *config.ConfigMap) time.Time

May 2, 2023

Changes in this version

+ const BqDataUsageWindow

Mar 22, 2023

Changes in this version

+ func GetDataSourceMetaData(_ context.Context) (*ds.MetaData, error)

+ func GetResourceIds(ctx context.Context, configMap *config.ConfigMap) ([]string, error)

Jan 10, 2023

Changes in this version

type BQInformationSchemaEntity

+ CachedQuery bool

+ Tables []BQReferencedTable

+ type BQReferencedTable struct

+ Dataset string

+ Project string

+ Table string

Jan 10, 2023

Changes in this version

+ const BqExcludedDatasets

+ const BqIncludeHiddenDatasets

+ const CONTEXT_TIMEOUT

+ const GcpProjectId

+ const GcpSAFileLocation

+ const GsuiteCustomerId

+ const GsuiteIdentityStoreSync

+ const GsuiteImpersonateSubject

+ const MAX_PAGE_ITEMS

+ func ConnectToBigQuery(configMap *config.ConfigMap, ctx context.Context) (*bigquery.Client, error)

+ type AccessSyncer struct

+ func NewDataAccessSyncer() *AccessSyncer

+ func (a *AccessSyncer) SyncAccessAsCodeToTarget(ctx context.Context, accessProviders *importer.AccessProviderImport, ...) error

+ func (a *AccessSyncer) SyncAccessProviderToTarget(ctx context.Context, accessProviders *importer.AccessProviderImport, ...) error

+ func (a *AccessSyncer) SyncAccessProvidersFromTarget(ctx context.Context, accessProviderHandler wrappers.AccessProviderHandler, ...) error

+ type BQEntity struct

+ FullName string

+ ID string

+ Name string

+ ParentId string

+ Type string

+ type BQInformationSchemaEntity struct

+ Dataset string

+ EndTime int64

+ JobType string

+ Project string

+ Query string

+ StartTime int64

+ Table string

+ User string

+ type BigQueryRepository struct

+ func (r *BigQueryRepository) GetDataSetDataAccess(ctx context.Context, configMap *config.ConfigMap, ignoreBindings []IamBinding) ([]*sync_from_target.AccessProvider, error)

+ func (r *BigQueryRepository) GetDataSets(ctx context.Context, configMap *config.ConfigMap) ([]BQEntity, error)

+ func (r *BigQueryRepository) GetDataUsage(ctx context.Context, configMap *config.ConfigMap) ([]BQInformationSchemaEntity, error)

+ func (r *BigQueryRepository) GetProjectDataAccess(ctx context.Context, configMap *config.ConfigMap, ignoreBindings []IamBinding) ([]*sync_from_target.AccessProvider, error)

+ func (r *BigQueryRepository) GetTables(ctx context.Context, configMap *config.ConfigMap, parent BQEntity) ([]BQEntity, error)

+ func (r *BigQueryRepository) Grant(ctx context.Context, configMap *config.ConfigMap, ...) error

+ func (r *BigQueryRepository) Revoke(ctx context.Context, configMap *config.ConfigMap, ...) error

+ type DataSourceSyncer struct

+ func NewDataSourceSyncer() *DataSourceSyncer

+ func (s *DataSourceSyncer) GetDataSourceMetaData() ds.MetaData

+ func (s *DataSourceSyncer) SyncDataSource(ctx context.Context, dataSourceHandler wrappers.DataSourceObjectHandler, ...) error

+ type DataUsageSyncer struct

+ func NewDataUsageSyncer() *DataUsageSyncer

+ func (s *DataUsageSyncer) SyncDataUsage(ctx context.Context, fileCreator wrappers.DataUsageStatementHandler, ...) error

+ type GCPIamRepository struct

+ func NewGCPIamRepository() *GCPIamRepository

+ func (r *GCPIamRepository) GetIamPolicy(ctx context.Context, configMap *config.ConfigMap) (*cloudresourcemanager.Policy, error)

+ func (r *GCPIamRepository) Grant(ctx context.Context, configMap *config.ConfigMap, member, role string) error

+ func (r *GCPIamRepository) Revoke(ctx context.Context, configMap *config.ConfigMap, member, role string) error

+ type GSuiteIdentityStoreRepository struct

+ func (r *GSuiteIdentityStoreRepository) GetGroups(ctx context.Context, configMap *config.ConfigMap) ([]GroupEntity, error)

+ func (r *GSuiteIdentityStoreRepository) GetServiceAccounts(ctx context.Context, configMap *config.ConfigMap) ([]UserEntity, error)

+ func (r *GSuiteIdentityStoreRepository) GetUsers(ctx context.Context, configMap *config.ConfigMap) ([]UserEntity, error)

+ type GroupEntity struct

+ Email string

+ ExternalId string

+ Members []string

+ type IamBinding struct

+ Member string

+ Resource string

+ ResourceType string

+ Role string

+ type IdentityStoreSyncer struct

+ func NewIdentityStoreSyncer() *IdentityStoreSyncer

+ func (s *IdentityStoreSyncer) GetIdentityStoreMetaData() is.MetaData

+ func (s *IdentityStoreSyncer) SyncIdentityStore(ctx context.Context, identityHandler wrappers.IdentityStoreIdentityHandler, ...) error

+ type ProjectIdentityStoreRepository struct

+ func (r *ProjectIdentityStoreRepository) GetGroups(ctx context.Context, configMap *config.ConfigMap) ([]GroupEntity, error)

+ func (r *ProjectIdentityStoreRepository) GetServiceAccounts(ctx context.Context, configMap *config.ConfigMap) ([]UserEntity, error)

+ func (r *ProjectIdentityStoreRepository) GetUsers(ctx context.Context, configMap *config.ConfigMap) ([]UserEntity, error)

+ type UserEntity struct

+ Email string

+ ExternalId string

+ Name string