ingestion_processors

Documentation

Index

• Constants
• func PrimaryBranchSQL(src ingestion.Source, configParams map[string]string, db *pgxpool.Pool) *sqlPrimaryIngester
• func TryjobSQL(ctx context.Context, src ingestion.Source, configParams map[string]string, ...) (ingestion.Processor, error)
• type LookupSystem

Constants

const (
	// SQLPrimaryBranch indicates that the primary branch ingester use the SQL backend.
	SQLPrimaryBranch = "sql_primary"
)

const (
	SQLSecondaryBranch = "sql_secondary"
)

Functions

func PrimaryBranchSQL

func PrimaryBranchSQL(src ingestion.Source, configParams map[string]string, db *pgxpool.Pool) *sqlPrimaryIngester

PrimaryBranchSQL creates a Processor that writes to the SQL backend and returns it. It panics if configuration is invalid.

func TryjobSQL

func TryjobSQL(ctx context.Context, src ingestion.Source, configParams map[string]string, client *http.Client, db *pgxpool.Pool) (ingestion.Processor, error)

TryjobSQL returns an ingestion.Processor which is modular and can support different CodeReviewSystems (e.g. "Gerrit", "GitHub") and different ContinuousIntegrationSystems (e.g. "BuildBucket", "CirrusCI"). This particular implementation stores the data in SQL.

Types

type LookupSystem

type LookupSystem interface {
	// Lookup returns the given CRS system, CL ID, PS Order or an error if it could not lookup
	// the CL information.
	Lookup(ctx context.Context, tjID string) (string, string, int, error)
}