checkpoint

type CheckpointManager interface {
	GetCheckpoint(Id string) (string, time.Time, error)
	SetCheckpoint(Id string, sequenceNumber string) error
}

type DynamoCheckpointManager struct {
	sync.Mutex
	StorageConfig
	// contains filtered or unexported fields
}

type InMemoryCheckpointManager struct {
	sync.Mutex
	StorageConfig
	// contains filtered or unexported fields
}

type StorageConfig struct {
	Env                    string
	StorageType            string
	Table                  string
	Region                 string
	UpdateFrequencySeconds int
}