ingester

Documentation

Index

• func NotificationToFlowExecution(ctx context.Context, n *louhi.Notification, ts time.Time) *louhi.FlowExecution
• type Ingester
  • func NewIngester(db louhi.DB, g gerrit.GerritInterface, repos []gitiles.GitilesRepo) *Ingester
  • func (i *Ingester) UpdateFlowFromNotification(ctx context.Context, n *louhi.Notification, ts time.Time) error

Functions

func NotificationToFlowExecution

func NotificationToFlowExecution(ctx context.Context, n *louhi.Notification, ts time.Time) *louhi.FlowExecution

NotificationToFlowExecution converts a Notification to a FlowExecution. Note that, since not all Notifications contain all of the information about the flow, the returned FlowExecution may not be complete.

Types

type Ingester

type Ingester struct {
	// contains filtered or unexported fields
}

Ingester is used for ingesting Louhi Notifications into a DB.

func NewIngester

func NewIngester(db louhi.DB, g gerrit.GerritInterface, repos []gitiles.GitilesRepo) *Ingester

NewIngester returns an Ingester instance.

func (*Ingester) UpdateFlowFromNotification

func (i *Ingester) UpdateFlowFromNotification(ctx context.Context, n *louhi.Notification, ts time.Time) error

UpdateFlowFromNotification retrieves the FlowExecution from the DB, updates it from the Notifaction, and updates it into the DB.