commitingester

Documentation

Overview

Package commitingester contains methods for handling commit ingestion.

It is able to ingest all commits reachable from a given commitish using the following steps.

1. Retrieve up to N closest commits reachable from the given commitish and page token.
2. Check whether those commits has already been saved into the database.
3. If yes, stops the ingestion.
4. If not, save those commits into the database.
5. If root commit hasn't been reached, transactionally schedule another commit ingestion task with the next page token.

Because the ingestion stops when it encounters a commit that is already ingested, it's important to maintain the following invariants:

• If a commit is saved into the database, all its ancestors must also have been, or scheduled to be, saved into the database.

Index

• func RegisterCronHandlers(srv *server.Server) error
• func RegisterPubSubHandlers(srv *server.Server) error
• func RegisterTaskQueueHandlers(srv *server.Server) error

Functions

func RegisterCronHandlers

func RegisterCronHandlers(srv *server.Server) error

RegisterCronHandlers registers the cron handlers for Source Index's commit ingestion.

func RegisterPubSubHandlers

func RegisterPubSubHandlers(srv *server.Server) error

RegisterPubSubHandlers registers the pubsub handlers for Source Index's commit ingestion.

func RegisterTaskQueueHandlers

func RegisterTaskQueueHandlers(srv *server.Server) error

RegisterTaskQueueHandlers registers the task queue handlers for Source Index's commit ingestion.