Method Append

asset/sql_repository.go:170–190

Append adds the given snapshots to the asset with the given name.

(name string, snapshots <-chan *Snapshot)

// Append adds the given snapshots to the asset with the given name.
func (s *SQLRepository) Append(name string, snapshots <-chan *Snapshot) error {
	go func() {
		for snapshot := range snapshots {
			_, err := s.appendQuery.Exec(
				name,
				snapshot.Date,
				snapshot.Open,
				snapshot.High,
				snapshot.Low,
				snapshot.Close,
				snapshot.Volume,
			)

			if err != nil {
				log.Printf("unable to append snapshot: %v", err)
			}
		}
	}()

	return nil
}

// Drop drops the snapshots table.
func (s *SQLRepository) Drop() error {