service

package
v1.12.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 22, 2021 License: MIT Imports: 24 Imported by: 16

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrPersistenceNotExists = errors.New("persistent data does not exists")
View Source 
var ErrTradeNotFound = errors.New("trade not found")

Functions

func NewDefaultTotpKey added in v1.4.0 

func NewDefaultTotpKey() (*otp.Key, error)

func ReformatMysqlDSN added in v1.11.0 

func ReformatMysqlDSN(dsn string) (string, error)

Types

type AggOrder added in v1.11.0 

type AggOrder struct {
	types.Order
	AveragePrice *float64 `json:"averagePrice" db:"average_price"`
}

type BacktestService 

type BacktestService struct {
	DB *sqlx.DB
}

func (*BacktestService) Insert 

func (s *BacktestService) Insert(kline types.KLine) error

func (*BacktestService) QueryKLinesBackward 

func (s *BacktestService) QueryKLinesBackward(exchange types.ExchangeName, symbol string, interval types.Interval, endTime time.Time) ([]types.KLine, error)

func (*BacktestService) QueryKLinesCh 

func (s *BacktestService) QueryKLinesCh(since, until time.Time, exchange types.Exchange, symbols []string, intervals []types.Interval) (chan types.KLine, chan error)

func (*BacktestService) QueryKLinesForward 

func (s *BacktestService) QueryKLinesForward(exchange types.ExchangeName, symbol string, interval types.Interval, startTime time.Time) ([]types.KLine, error)

func (*BacktestService) QueryLast 

func (s *BacktestService) QueryLast(ex types.ExchangeName, symbol string, interval types.Interval) (*types.KLine, error)

QueryLast queries the last order from the database

func (*BacktestService) Sync 

func (s *BacktestService) Sync(ctx context.Context, exchange types.Exchange, symbol string, startTime time.Time) error

type DatabaseService added in v1.11.0 

type DatabaseService struct {
	Driver string
	DSN    string
	DB     *sqlx.DB
}

func NewDatabaseService added in v1.11.0 

func NewDatabaseService(driver, dsn string) *DatabaseService

func (*DatabaseService) Close added in v1.11.0 

func (s *DatabaseService) Close() error

func (*DatabaseService) Connect added in v1.11.0 

func (s *DatabaseService) Connect() error

func (*DatabaseService) Upgrade added in v1.11.0 

func (s *DatabaseService) Upgrade(ctx context.Context) error

type JsonPersistenceConfig added in v1.12.0 

type JsonPersistenceConfig struct {
	Directory string `json:"directory"`
}

type JsonPersistenceService added in v1.12.0 

type JsonPersistenceService struct {
	Directory string
}

func (*JsonPersistenceService) NewStore added in v1.12.0 

func (s *JsonPersistenceService) NewStore(id string, subIDs ...string) Store

type JsonStore added in v1.12.0 

type JsonStore struct {
	ID        string
	Directory string
}

func (JsonStore) Load added in v1.12.0 

func (store JsonStore) Load(val interface{}) error

func (JsonStore) Reset added in v1.12.0 

func (store JsonStore) Reset() error

func (JsonStore) Save added in v1.12.0 

func (store JsonStore) Save(val interface{}) error

type MemoryService added in v1.12.0 

type MemoryService struct {
	Slots map[string]interface{}
}

func NewMemoryService added in v1.12.0 

func NewMemoryService() *MemoryService

func (*MemoryService) NewStore added in v1.12.0 

func (s *MemoryService) NewStore(id string, subIDs ...string) Store

type MemoryStore added in v1.12.0 

type MemoryStore struct {
	Key string
	// contains filtered or unexported fields
}

func (*MemoryStore) Load added in v1.12.0 

func (store *MemoryStore) Load(val interface{}) error

func (*MemoryStore) Reset added in v1.12.0 

func (store *MemoryStore) Reset() error

func (*MemoryStore) Save added in v1.12.0 

func (store *MemoryStore) Save(val interface{}) error

type OrderService 

type OrderService struct {
	DB *sqlx.DB
}

func (*OrderService) Insert 

func (s *OrderService) Insert(order types.Order) (err error)

func (*OrderService) Query 

func (s *OrderService) Query(options QueryOrdersOptions) ([]AggOrder, error)

func (*OrderService) QueryLast 

func (s *OrderService) QueryLast(ex types.ExchangeName, symbol string, isMargin bool, isIsolated bool) (*types.Order, error)

QueryLast queries the last order from the database

type PersistenceService added in v1.12.0 

type PersistenceService interface {
	NewStore(id string, subIDs ...string) Store
}

type PersistenceServiceFacade added in v1.12.0 

type PersistenceServiceFacade struct {
	Redis  *RedisPersistenceService
	Json   *JsonPersistenceService
	Memory *MemoryService
}

func (*PersistenceServiceFacade) Get added in v1.12.0 

func (facade *PersistenceServiceFacade) Get() PersistenceService

Get returns the preferred persistence service by fallbacks Redis will be preferred at the first position.

type QueryOrdersOptions added in v1.11.0 

type QueryOrdersOptions struct {
	Exchange types.ExchangeName
	Symbol   string
	LastGID  int64
	Ordering string
}

type QueryTradesOptions added in v1.11.0 

type QueryTradesOptions struct {
	Exchange types.ExchangeName
	Symbol   string
	LastGID  int64

	// ASC or DESC
	Ordering string
	Limit    int
}

type RedisPersistenceConfig added in v1.12.0 

type RedisPersistenceConfig struct {
	Host     string `json:"host" env:"REDIS_HOST"`
	Port     string `json:"port" env:"REDIS_PORT"`
	Password string `json:"password" env:"REDIS_PASSWORD"`
	DB       int    `json:"db" env:"REDIS_DB"`
}

type RedisPersistenceService added in v1.12.0 

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

func NewRedisPersistenceService added in v1.12.0 

func NewRedisPersistenceService(config *RedisPersistenceConfig) *RedisPersistenceService

func (*RedisPersistenceService) NewStore added in v1.12.0 

func (s *RedisPersistenceService) NewStore(id string, subIDs ...string) Store

type RedisStore added in v1.12.0 

type RedisStore struct {
	ID string
	// contains filtered or unexported fields
}

func (*RedisStore) Load added in v1.12.0 

func (store *RedisStore) Load(val interface{}) error

func (*RedisStore) Reset added in v1.12.0 

func (store *RedisStore) Reset() error

func (*RedisStore) Save added in v1.12.0 

func (store *RedisStore) Save(val interface{}) error

type Store added in v1.12.0 

type Store interface {
	Load(val interface{}) error
	Save(val interface{}) error
	Reset() error
}

type SyncService 

type SyncService struct {
	TradeService *TradeService
	OrderService *OrderService
}

func (*SyncService) SyncOrders 

func (s *SyncService) SyncOrders(ctx context.Context, exchange types.Exchange, symbol string, startTime time.Time) error

func (*SyncService) SyncSessionSymbols added in v1.11.1 

func (s *SyncService) SyncSessionSymbols(ctx context.Context, exchange types.Exchange, startTime time.Time, symbols ...string) error

SyncSessionSymbols syncs the trades from the given exchange session

func (*SyncService) SyncTrades 

func (s *SyncService) SyncTrades(ctx context.Context, exchange types.Exchange, symbol string) error

type TradeService 

type TradeService struct {
	DB *sqlx.DB
}

func NewTradeService 

func NewTradeService(db *sqlx.DB) *TradeService

func (*TradeService) Insert 

func (s *TradeService) Insert(trade types.Trade) error

func (*TradeService) Load added in v1.11.1 

func (s *TradeService) Load(ctx context.Context, id int64) (*types.Trade, error)

func (*TradeService) MarkStrategyID added in v1.11.1 

func (s *TradeService) MarkStrategyID(ctx context.Context, id int64, strategyID string) error

func (*TradeService) Query 

func (s *TradeService) Query(options QueryTradesOptions) ([]types.Trade, error)

func (*TradeService) QueryForTradingFeeCurrency 

func (s *TradeService) QueryForTradingFeeCurrency(ex types.ExchangeName, symbol string, feeCurrency string) ([]types.Trade, error)

func (*TradeService) QueryLast 

func (s *TradeService) QueryLast(ex types.ExchangeName, symbol string, isMargin bool, isIsolated bool, limit int) ([]types.Trade, error)

QueryLast queries the last trade from the database

func (*TradeService) QueryTradingVolume added in v1.11.0 

func (s *TradeService) QueryTradingVolume(startTime time.Time, options TradingVolumeQueryOptions) ([]TradingVolume, error)

func (*TradeService) UpdatePnL added in v1.11.1 

func (s *TradeService) UpdatePnL(ctx context.Context, id int64, pnl float64) error

type TradingVolume added in v1.11.0 

type TradingVolume struct {
	Year        int       `db:"year" json:"year"`
	Month       int       `db:"month" json:"month,omitempty"`
	Day         int       `db:"day" json:"day,omitempty"`
	Time        time.Time `json:"time,omitempty"`
	Exchange    string    `db:"exchange" json:"exchange,omitempty"`
	Symbol      string    `db:"symbol" json:"symbol,omitempty"`
	QuoteVolume float64   `db:"quote_volume" json:"quoteVolume"`
}

type TradingVolumeQueryOptions added in v1.11.0 

type TradingVolumeQueryOptions struct {
	GroupByPeriod string
	SegmentBy     string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.