Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DataChangesWorker ¶
type DataChangesWorker struct {
// contains filtered or unexported fields
}
DataChangesWorker writes data from the pending writes topic to the database.
func ProvideDataChangesWorker ¶
func ProvideDataChangesWorker(logger logging.Logger) *DataChangesWorker
ProvideDataChangesWorker provides a DataChangesWorker.
func (*DataChangesWorker) HandleMessage ¶
func (w *DataChangesWorker) HandleMessage(ctx context.Context, message []byte) error
HandleMessage handles a pending write.
type PreArchivesWorker ¶
type PreArchivesWorker struct {
// contains filtered or unexported fields
}
PreArchivesWorker archives data from the pending archives topic to the database.
func ProvidePreArchivesWorker ¶
func ProvidePreArchivesWorker( ctx context.Context, logger logging.Logger, client *http.Client, dataManager database.DataManager, postArchivesPublisher publishers.Publisher, searchIndexLocation search.IndexPath, searchIndexProvider search.IndexManagerProvider, ) (*PreArchivesWorker, error)
ProvidePreArchivesWorker provides a PreArchivesWorker.
func (*PreArchivesWorker) HandleMessage ¶
func (w *PreArchivesWorker) HandleMessage(ctx context.Context, message []byte) error
HandleMessage handles a pending archive.
type PreUpdatesWorker ¶
type PreUpdatesWorker struct {
// contains filtered or unexported fields
}
PreUpdatesWorker updates data from the pending updates topic to the database.
func ProvidePreUpdatesWorker ¶
func ProvidePreUpdatesWorker( ctx context.Context, logger logging.Logger, client *http.Client, dataManager database.DataManager, postUpdatesPublisher publishers.Publisher, searchIndexLocation search.IndexPath, searchIndexProvider search.IndexManagerProvider, ) (*PreUpdatesWorker, error)
ProvidePreUpdatesWorker provides a PreUpdatesWorker.
func (*PreUpdatesWorker) HandleMessage ¶
func (w *PreUpdatesWorker) HandleMessage(ctx context.Context, message []byte) error
HandleMessage handles a pending update.
type PreWritesWorker ¶
type PreWritesWorker struct {
// contains filtered or unexported fields
}
PreWritesWorker writes data from the pending writes topic to the database.
func ProvidePreWritesWorker ¶
func ProvidePreWritesWorker( ctx context.Context, logger logging.Logger, client *http.Client, dataManager database.DataManager, postWritesPublisher publishers.Publisher, searchIndexLocation search.IndexPath, searchIndexProvider search.IndexManagerProvider, ) (*PreWritesWorker, error)
ProvidePreWritesWorker provides a PreWritesWorker.
func (*PreWritesWorker) HandleMessage ¶
func (w *PreWritesWorker) HandleMessage(ctx context.Context, message []byte) error
HandleMessage handles a pending write.
Source Files