repository

Documentation

Index

• func NewRepositoryImpl(config *configs.Secrets, db *sqlx.DB, influxClient *influxdb2.Client) *impl
• type Repository
  • func NewRepository(config *configs.Secrets, db *sqlx.DB, influxClient *influxdb2.Client) Repository

Functions

func NewRepositoryImpl

func NewRepositoryImpl(
	config *configs.Secrets,
	db *sqlx.DB,
	influxClient *influxdb2.Client,
) *impl

Types

type Repository

type Repository interface {
	GetLastSync(
		ctx context.Context,
		exchange string,
		pair *models.Symbol,
	) (*models.LastSync, error)
	UpsertLastSync(
		ctx context.Context,
		exchange string,
		pair *models.Symbol,
		lastSyncTime time.Time,
	) error
	UpsertOHLCVData(
		ohlcvData []*models.OHLCVMarketData,
		exchange string,
		pair *models.Symbol,
	)
	GetOHLCVData(
		context context.Context,
		base string,
		quote null.String,
		exchange null.String,
		start time.Time,
		end time.Time,
	) ([]*models.OHLCVMarketData, error)
}

func NewRepository

func NewRepository(
	config *configs.Secrets,
	db *sqlx.DB,
	influxClient *influxdb2.Client,
) Repository