repo

package

v0.0.0-...-a9b3359 Latest Latest Go to latest Published: Jul 2, 2024 License: MIT Imports: 8 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

func New(conf config.Database) (
	pr *PostgresRepo,
	err error,
)

func (pr *PostgresRepo) AddPool(
	ctx c.Context, pool entities.Pool, table string,
) (
	err error,
)

func (pr *PostgresRepo) AddToken(
	ctx c.Context, table string, token entities.Token,
) (
	err error,
)

func (pr *PostgresRepo) GetByTokens(
	ctx c.Context, table string, pair entities.TokenPair,
) (
	pools []entities.Pool,
	err error,
)

func (pr *PostgresRepo) GetStorage() trade.Storage

func (pr *PostgresRepo) GetTokenByAddress(
	ctx c.Context, table string, address string,
) (
	token entities.Token,
	err error,
)

func (pr *PostgresRepo) ListPools(
	ctx c.Context, table string,
) (
	pools []entities.Pool,
	err error,
)

func (pr *PostgresRepo) ListTokens(
	ctx c.Context, table string,
) (
	tokens []entities.Token,
	err error,
)

func (pr *PostgresRepo) RemovePool(
	ctx c.Context, table string, pool entities.Pool,
) (
	err error,
)

func (pr *PostgresRepo) RemovePools(
	ctx c.Context, table string, pools []entities.Pool,
) (
	out []entities.Pool,
	err error,
)

func (pr *PostgresRepo) RemoveToken(
	ctx c.Context, table string, token entities.Token,
) (
	err error,
)

func (pr *PostgresRepo) RemoveTokens(
	ctx c.Context, table string, tokens []entities.Token,
) (
	out []entities.Token,
	err error,
)

func (pr *PostgresRepo) StorePools(
	ctx c.Context, table string, pools []entities.Pool,
) (
	err error,
)

func (pr *PostgresRepo) StoreTokens(
	ctx c.Context, table string, tokens []entities.Token,
) (
	err error,
)

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

func NewStorage(files map[string]string) (
	st *Storage,
	err error,
)

func (s *Storage) AddPool(
	ctx c.Context,
	pool entities.Pool,
	where string,
) (
	err error,
)

func (s *Storage) AddToken(
	ctx c.Context,
	where string,
	token entities.Token,
) (
	err error,
)

func (s *Storage) ClearAll(ctx c.Context) (
	err error,
)

func (s *Storage) GetByTokens(
	ctx c.Context,
	where string,
	tokens entities.TokenPair,
) (
	pools []entities.Pool,
	err error,
)

func (s *Storage) GetStorage() trade.Storage

func (s *Storage) GetTokenByAddress(
	ctx c.Context,
	where, address string,
) (
	token entities.Token,
	err error,
)

func (s *Storage) ListPools(
	ctx c.Context,
	where string,
) (
	pools []entities.Pool,
	err error,
)

func (s *Storage) ListTokens(
	ctx c.Context,
	where string,
) (
	tokens []entities.Token,
	err error,
)

func (s *Storage) RemovePool(
	ctx c.Context,
	where string,
	pool entities.Pool,
) (
	err error,
)

func (s *Storage) RemovePools(
	ctx c.Context,
	where string,
	pools []entities.Pool,
) (
	out []entities.Pool,
	err error,
)

func (s *Storage) RemoveToken(
	ctx c.Context,
	where string,
	token entities.Token,
) (
	err error,
)

func (s *Storage) RemoveTokens(
	ctx c.Context,
	where string,
	tokens []entities.Token,
) (
	out []entities.Token,
	err error,
)

func (s *Storage) StorePools(
	ctx c.Context,
	where string,
	pools []entities.Pool,
) (
	err error,
)

func (s *Storage) StoreTokens(
	ctx c.Context,
	where string,
	tokens []entities.Token,
) (
	err error,
)