store

type Config struct {
	// Storage is the storage implementation.
	Storage Storage

	// Transport is an implementation of transport used to fetch prices from feeds.
	Transport transport.Service

	// Models is the list of models which are supported by the store.
	Models []string

	// Recoverers is the list of recoverers which are used to recover the
	// feed's address from the data point.
	Recoverers []datapoint.Recoverer

	// Logger is a current logger interface used by the Store.
	// The Logger is required to monitor asynchronous processes.
	Logger log.Logger
}

type DataPointProvider interface {
	// LatestFrom returns the latest data point from a given address.
	LatestFrom(ctx context.Context, from types.Address, model string) (StoredDataPoint, bool, error)

	// Latest returns the latest data points from all addresses.
	Latest(ctx context.Context, model string) (map[types.Address]StoredDataPoint, error)
}

type MemoryStorage struct {
	// contains filtered or unexported fields
}

type Storage interface {
	// Add adds a data point to the store.
	//
	// Adding a data point with a timestamp older than the latest data point
	// for the same address and model will be ignored.
	Add(ctx context.Context, point StoredDataPoint) error

	// LatestFrom returns the latest data point from a given address.
	LatestFrom(ctx context.Context, from types.Address, model string) (point StoredDataPoint, ok bool, err error)

	// Latest returns the latest data points from all addresses.
	Latest(ctx context.Context, model string) (points map[types.Address]StoredDataPoint, err error)
}

type Store struct {
	// contains filtered or unexported fields
}

type StoredDataPoint struct {
	Model     string
	DataPoint datapoint.Point
	From      types.Address
	Signature types.Signature
}