dynamodb

Documentation

Overview

Package dynamodb implements a dynamodb backed ingestion.Committer.

The storage structure uses a key-value mapping for each chain ingestor to the latest commit. For example:

| ingestor | latest |
|----------|--------|
|   kin2   |   v    |
|   kin3   |   v    |
|   kin4   |   v    |

The commit function uses an atomic compare-and-swap to ensure that the parent matches the stored latest, and that the new latest is 'older' than the previous latest.

Index

• func New(client dynamodbiface.ClientAPI) ingestion.Committer

Functions

func New

func New(client dynamodbiface.ClientAPI) ingestion.Committer