bittrex

package

v0.0.0-...-afd3e11 Latest Latest Go to latest Published: Feb 28, 2021 License: AGPL-3.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/eupholio/eupholio

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func ValidateColumnNames(names []string) error
type ColumnID
type DepositExtractor
- func NewDepositExtractor() *DepositExtractor
- func (e *DepositExtractor) Execute(ctx context.Context, db boil.ContextExecutor, reader io.Reader, ...) error
type Extractor
- func NewExtractor() *Extractor
- func (e *Extractor) Execute(ctx context.Context, db boil.ContextExecutor, reader io.Reader, ...) error
type OrderHistory
- func Extract(reader io.Reader) (*OrderHistory, error)
type Record
- func MakeRecords(head []string, rows [][]string) ([]Record, error)
- func (r Record) Closed() (time.Time, error)
- func (r Record) Commission() *decimal.Big
- func (r Record) Condition() string
- func (r Record) ConditionTarget() *decimal.Big
- func (r Record) Exchange() string
- func (r Record) Get(id ColumnID) string
- func (r Record) ImmediateOrCancel() bool
- func (r Record) IsConditional() bool
- func (r Record) Limit() *decimal.Big
- func (r Record) OrderType() int
- func (r Record) Price() *decimal.Big
- func (r Record) PricePerUnit() *decimal.Big
- func (r Record) Quantity() *decimal.Big
- func (r Record) QuantityRemaining() *decimal.Big
- func (r Record) TimeInForce() string
- func (r Record) TimeInForceTypeID() (int, error)
- func (r Record) TimeStamp() (time.Time, error)
- func (r Record) UUID() string
type Repository
- func NewRepository(db boil.ContextExecutor) Repository
type Translator
- func NewTranslator(baseCurrency currency.Symbol) *Translator
- func (t *Translator) Translate(ctx context.Context, repository eupholio.Repository, start, end time.Time) error
type WithdrawExtractor
- func NewWithdrawExtractor() *WithdrawExtractor
- func (e *WithdrawExtractor) Execute(ctx context.Context, db boil.ContextExecutor, reader io.Reader, ...) error

Constants ¶

View Source

const (
	LimitSell = "LIMIT_SELL"
	LimitBuy  = "LIMIT_BUY"
)

View Source

const (
	OrderTypeUnknown int = iota
	OrderTypeLimitSell
	OrderTypeLimitBuy
)

View Source

const (
	UUIDColumn              = "Uuid"
	ExchangeColumn          = "Exchange"
	TimeStampColumn         = "TimeStamp"
	OrderTypeColumn         = "OrderType"
	LimitColumn             = "Limit"
	QuantityColumn          = "Quantity"
	QuantityRemainingColumn = "QuantityRemaining"
	CommissionColumn        = "Commission"
	PriceColumn             = "Price"
	PricePerUnitColumn      = "PricePerUnit"
	IsConditionalColumn     = "IsConditional"
	ConditionColumn         = "Condition"
	ConditionTargetColumn   = "ConditionTarget"
	ImmediateOrCancelColumn = "ImmediateOrCancel"
	ClosedColumn            = "Closed"
	TimeInForceTypeIDColumn = "TimeInForceTypeId"
	TimeInForceColumn       = "TimeInForce"
)

Column names

View Source

const WalletCode = "BITTREX"

Variables ¶

This section is empty.

Functions ¶

func ValidateColumnNames ¶

func ValidateColumnNames(names []string) error

ValidateColumnNames checks columns

Types ¶

type ColumnID ¶

type ColumnID int

CokumnID is index type for columns

const (
	UUID ColumnID = iota
	Exchange
	TimeStamp
	OrderType
	Limit
	Quantity
	QuantityRemaining
	Commission
	Price
	PricePerUnit
	IsConditional
	Condition
	ConditionTarget
	ImmediateOrCancel
	Closed
	TimeInForceTypeID
	TimeInForce
)

Column Index

type DepositExtractor ¶

type DepositExtractor struct {
}

DepositExtractor loads depoist history

func NewDepositExtractor ¶

func NewDepositExtractor() *DepositExtractor

func (*DepositExtractor) Execute ¶

func (e *DepositExtractor) Execute(ctx context.Context, db boil.ContextExecutor, reader io.Reader, options ...eupholio.Option) error

type Extractor ¶

type Extractor struct {
}

Extractor for Bittrex

func NewExtractor ¶

func NewExtractor() *Extractor

NewExtractor create an executor for Bittrex

func (*Extractor) Execute ¶

func (e *Extractor) Execute(ctx context.Context, db boil.ContextExecutor, reader io.Reader, options ...eupholio.Option) error

Execute performs ETL

type OrderHistory ¶

type OrderHistory struct {
	Orders models.BittrexOrderHistorySlice
}

func Extract ¶

func Extract(reader io.Reader) (*OrderHistory, error)

Extract extracts transactions from a reader

type Record ¶

type Record []string

func MakeRecords ¶

func MakeRecords(head []string, rows [][]string) ([]Record, error)

func (Record) Closed ¶

func (r Record) Closed() (time.Time, error)

func (Record) Commission ¶

func (r Record) Commission() *decimal.Big

func (Record) Condition ¶

func (r Record) Condition() string

func (Record) ConditionTarget ¶

func (r Record) ConditionTarget() *decimal.Big

func (Record) Exchange ¶

func (r Record) Exchange() string

func (Record) Get ¶

func (r Record) Get(id ColumnID) string

func (Record) ImmediateOrCancel ¶

func (r Record) ImmediateOrCancel() bool

func (Record) IsConditional ¶

func (r Record) IsConditional() bool

func (Record) Limit ¶

func (r Record) Limit() *decimal.Big

func (Record) OrderType ¶

func (r Record) OrderType() int

func (Record) Price ¶

func (r Record) Price() *decimal.Big

func (Record) PricePerUnit ¶

func (r Record) PricePerUnit() *decimal.Big

func (Record) Quantity ¶

func (r Record) Quantity() *decimal.Big

func (Record) QuantityRemaining ¶

func (r Record) QuantityRemaining() *decimal.Big

func (Record) TimeInForce ¶

func (r Record) TimeInForce() string

func (Record) TimeInForceTypeID ¶

func (r Record) TimeInForceTypeID() (int, error)

func (Record) TimeStamp ¶

func (r Record) TimeStamp() (time.Time, error)

func (Record) UUID ¶

func (r Record) UUID() string

type Repository ¶

type Repository interface {
	FindOrderHistories(ctx context.Context, start, end time.Time) (models.BittrexOrderHistorySlice, error)
	FindDepositHistories(ctx context.Context, start, end time.Time) (models.BittrexDepositHistorySlice, error)
	FindWithdrawHistories(ctx context.Context, start, end time.Time) (models.BittrexWithdrawHistorySlice, error)
}

func NewRepository ¶

func NewRepository(db boil.ContextExecutor) Repository

type Translator ¶

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

Translator is a translator for BitTrex

func NewTranslator ¶

func NewTranslator(baseCurrency currency.Symbol) *Translator

NewTranslator create a translator for BitTrex

func (*Translator) Translate ¶

func (t *Translator) Translate(ctx context.Context, repository eupholio.Repository, start, end time.Time) error

Translate stores extracted transaction data to transaction table

type WithdrawExtractor ¶

type WithdrawExtractor struct {
}

WithdrawExtractor loads withdraw history

func NewWithdrawExtractor ¶

func NewWithdrawExtractor() *WithdrawExtractor

func (*WithdrawExtractor) Execute ¶

func (e *WithdrawExtractor) Execute(ctx context.Context, db boil.ContextExecutor, reader io.Reader, options ...eupholio.Option) error

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL