pipeline

package

v0.5.0 Latest Latest Go to latest Published: Aug 6, 2026 License: MIT Imports: 3 Imported by: 0

Details

Package pipeline carries one event-origin timestamp and the latest real cache-transaction commit through refresh fan-out.

This section is empty.

This section is empty.

func CacheCommittedAt(ctx context.Context) time.Time

CacheCommittedAt returns the latest real entity-transaction commit observed while processing this refresh. Fan-out-only jobs therefore return zero.

func EventReceivedAt(ctx context.Context) time.Time

EventReceivedAt returns the PostgreSQL receipt timestamp carried by ctx.

func MarkCacheCommitted(ctx context.Context, committedAt time.Time)

MarkCacheCommitted records a PostgreSQL timestamp obtained from the real entity-writer transaction immediately before its successful commit.

func WithEvent(ctx context.Context, receivedAt time.Time) context.Context

WithEvent returns a context that preserves the PostgreSQL webhook receipt timestamp and tracks the latest authoritative cache commit in this refresh.

This section is empty.