postgres

func (*Store) Ack ¶

func (s *Store) Ack(ctx context.Context, logEntry *schemalog.LogEntry) error

func (*Store) Close ¶

func (s *Store) Close() error

func (*Store) Fetch ¶

func (s *Store) Fetch(ctx context.Context, schemaName string, version int) (*schemalog.LogEntry, error)

Fetch retrieves the log entry for the schema and version provided.

func (*Store) FetchLast ¶ added in v0.4.0

func (s *Store) FetchLast(ctx context.Context, schemaName string, ackedOnly bool) (*schemalog.LogEntry, error)

FetchLast retrieves the latest schema log entry for schemaName. If ackedOnly is set, the function returns the last acked entry. If ackedOnly is NOT set, the function returns the latest entry no matter the acked flag.

func (*Store) Insert ¶ added in v0.3.0

func (s *Store) Insert(ctx context.Context, schemaName string) (*schemalog.LogEntry, error)

Insert inserts a new schema log for the schema name on input. It will insert a new row with the latest schema view with an incremented version, or if no row exists for the schema, with version 1.