metabase_mapper

Documentation

Index

• type Mapper
  • func New(metabaseService service.MetabaseService, ...) *Mapper
  • func (m *Mapper) MapDataset(ctx context.Context, datasetID uuid.UUID, services []string)
  • func (m *Mapper) Run(ctx context.Context)
• type Work

Types

type Mapper

type Mapper struct {
	Queue chan Work
	// contains filtered or unexported fields
}

func New

func New(
	metabaseService service.MetabaseService,
	thirdPartyMappingStorage service.ThirdPartyMappingStorage,
	mappingDeadlineSec, mappingFrequencySec int,
	log zerolog.Logger,
) *Mapper

func (*Mapper) MapDataset

func (m *Mapper) MapDataset(ctx context.Context, datasetID uuid.UUID, services []string)

func (*Mapper) Run

func (m *Mapper) Run(ctx context.Context)

type Work

type Work struct {
	DatasetID uuid.UUID
	Services  []string
}