Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInvalid = errors.New("importer: invalid batch")
ErrInvalid is a batch refused as a whole.
Functions ¶
This section is empty.
Types ¶
type Options ¶
type Options struct {
Pool *pgxpool.Pool
Schema string
Tenant string
Catalog *catalogstore.Store
Entities *entitystore.Store
Channels *channelstore.Store
Content *contentstore.Runtime
// Signals is nil, or answers discovery.ErrNoSignals, without a signal
// plane: signals are skipped.
Signals *discoverystore.Service
// Rebuild queues the jobs that rebuild what an import changed: search
// documents, entity counts and listing counts.
Rebuild func(ctx context.Context) error
Logger *slog.Logger
}
Options configures a Service over the engine's stores.
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
Service is one tenant's bulk import.
func (*Service) ExternalIDs ¶
func (s *Service) ExternalIDs(ctx context.Context, q importer.ExternalIDsQuery) (importer.ExternalIDs, error)
ExternalIDs pages the external ids imports under q.Source hold, per entity.
Click to show internal directories.
Click to hide internal directories.