access_ensurer

Documentation

Index

• type Ensurer
  • func NewEnsurer(googleGroups *auth.GoogleGroupClient, centralDataProject string, ...) *Ensurer
  • func (e *Ensurer) Run(ctx context.Context, frequency time.Duration)

Types

type Ensurer

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

func NewEnsurer

func NewEnsurer(
	googleGroups *auth.GoogleGroupClient,
	centralDataProject string,
	errs *prometheus.CounterVec,
	accessStorage service.AccessStorage,
	metabaseService service.MetabaseService,
	dataProductsStorage service.DataProductsStorage,
	bigQueryStorage service.BigQueryStorage,
	bigQueryAPI service.BigQueryAPI,
	bigQueryService service.BigQueryService,
	joinableViewService service.JoinableViewsService,
	log zerolog.Logger,
) *Ensurer

func (*Ensurer) Run

func (e *Ensurer) Run(ctx context.Context, frequency time.Duration)