tradingstore

package module

Go to main page

Versions in this module

v0

v0.3.0

Apr 15, 2025

Changes in this version

+ const COLUMN_DESCRIPTION

+ const COLUMN_SOFT_DELETED_AT

+ const COLUMN_TIMEFRAMES

+ const TIMEFRAME_15_MINUTES

+ const TIMEFRAME_1_DAY

+ const TIMEFRAME_1_HOUR

+ const TIMEFRAME_1_MINUTE

+ const TIMEFRAME_1_MONTH

+ const TIMEFRAME_1_WEEK

+ const TIMEFRAME_1_YEAR

+ const TIMEFRAME_30_MINUTES

+ const TIMEFRAME_4_HOURS

+ const TIMEFRAME_5_MINUTES

type InstrumentInterface

+ AssetClass func() string

+ Description func() string

+ Exchange func() string

+ SetTimeframes func(timeframes []string) InstrumentInterface

+ Symbol func() string

+ Timeframes func() []string

type NewStoreOptions

+ PriceTableNamePrefix string

+ UseMultipleExchanges bool

type Price

+ func (price *Price) Close() string

+ func (price *Price) CloseFloat() float64

+ func (price *Price) High() string

+ func (price *Price) HighFloat() float64

+ func (price *Price) Low() string

+ func (price *Price) LowFloat() float64

+ func (price *Price) Open() string

+ func (price *Price) OpenFloat() float64

+ func (price *Price) Time() string

+ func (price *Price) TimeCarbon() *carbon.Carbon

+ func (price *Price) Volume() string

+ func (price *Price) VolumeFloat() float64

type PriceInterface

+ Close func() string

+ CloseFloat func() float64

+ High func() string

+ HighFloat func() float64

+ Low func() string

+ LowFloat func() float64

+ Open func() string

+ OpenFloat func() float64

+ Time func() string

+ TimeCarbon func() *carbon.Carbon

+ Volume func() string

+ VolumeFloat func() float64

type Store

+ func (store *Store) AutoMigrateInstruments(ctx context.Context) error

+ func (store *Store) AutoMigratePrices(ctx context.Context) error

+ func (store *Store) PriceTableName(symbol string, exchange string, timeframe string) string

type StoreInterface

+ AutoMigrateInstruments func(ctx context.Context) error

+ AutoMigratePrices func(ctx context.Context) error

v0.2.0

Apr 14, 2025

v0.1.0

Apr 14, 2025

Changes in this version

+ const ASSET_CLASS_CURRENCY

+ const ASSET_CLASS_ETF

+ const ASSET_CLASS_INDEX

+ const ASSET_CLASS_REIT

+ const ASSET_CLASS_STOCK

+ const ASSET_CLASS_UNKNOWN

+ const COLUMN_ASSET_CLASS

+ const COLUMN_CLOSE

+ const COLUMN_CREATED_AT

+ const COLUMN_DELETED_AT

+ const COLUMN_EXCHANGE

+ const COLUMN_HIGH

+ const COLUMN_ID

+ const COLUMN_LOW

+ const COLUMN_OPEN

+ const COLUMN_SYMBOL

+ const COLUMN_TIME

+ const COLUMN_UPDATED_AT

+ const COLUMN_VOLUME

+ const NIL_FLOAT

+ type Instrument struct

+ func (i *Instrument) CreatedAt() string

+ func (i *Instrument) DeletedAt() string

+ func (i *Instrument) SetCreatedAt(createdAt string) *Instrument

+ func (i *Instrument) SetDeletedAt(deletedAt string) *Instrument

+ func (i *Instrument) SetUpdatedAt(updatedAt string) *Instrument

+ func (i *Instrument) UpdatedAt() string

+ func (instrument *Instrument) GetAssetClass() string

+ func (instrument *Instrument) GetDescription() string

+ func (instrument *Instrument) GetExchange() string

+ func (instrument *Instrument) GetSymbol() string

+ func (instrument *Instrument) ID() string

+ func (instrument *Instrument) SetAssetClass(assetClass string) InstrumentInterface

+ func (instrument *Instrument) SetDescription(description string) InstrumentInterface

+ func (instrument *Instrument) SetExchange(exchange string) InstrumentInterface

+ func (instrument *Instrument) SetID(id string) InstrumentInterface

+ func (instrument *Instrument) SetSymbol(symbol string) InstrumentInterface

+ type InstrumentInterface interface

+ Data func() map[string]string

+ DataChanged func() map[string]string

+ GetAssetClass func() string

+ GetDescription func() string

+ GetExchange func() string

+ GetSymbol func() string

+ ID func() string

+ MarkAsNotDirty func()

+ SetAssetClass func(assetClass string) InstrumentInterface

+ SetDescription func(description string) InstrumentInterface

+ SetExchange func(exchange string) InstrumentInterface

+ SetID func(id string) InstrumentInterface

+ SetSymbol func(symbol string) InstrumentInterface

+ func NewInstrument() InstrumentInterface

+ func NewInstrumentFromExistingData(data map[string]string) InstrumentInterface

+ type InstrumentQuery struct

+ func (iq *InstrumentQuery) AssetClass() string

+ func (iq *InstrumentQuery) Columns() []string

+ func (iq *InstrumentQuery) Exchange() string

+ func (iq *InstrumentQuery) HasAssetClass() bool

+ func (iq *InstrumentQuery) HasExchange() bool

+ func (iq *InstrumentQuery) HasID() bool

+ func (iq *InstrumentQuery) HasIDIn() bool

+ func (iq *InstrumentQuery) HasLimit() bool

+ func (iq *InstrumentQuery) HasOffset() bool

+ func (iq *InstrumentQuery) HasOrderBy() bool

+ func (iq *InstrumentQuery) HasSortDirection() bool

+ func (iq *InstrumentQuery) HasSymbol() bool

+ func (iq *InstrumentQuery) HasSymbolLike() bool

+ func (iq *InstrumentQuery) ID() string

+ func (iq *InstrumentQuery) IDIn() []string

+ func (iq *InstrumentQuery) IsCountOnly() bool

+ func (iq *InstrumentQuery) Limit() int

+ func (iq *InstrumentQuery) Offset() int

+ func (iq *InstrumentQuery) OrderBy() string

+ func (iq *InstrumentQuery) SetAssetClass(assetClass string) InstrumentQueryInterface

+ func (iq *InstrumentQuery) SetCountOnly(countOnly bool) InstrumentQueryInterface

+ func (iq *InstrumentQuery) SetExchange(exchange string) InstrumentQueryInterface

+ func (iq *InstrumentQuery) SetID(id string) InstrumentQueryInterface

+ func (iq *InstrumentQuery) SetIDIn(ids []string) InstrumentQueryInterface

+ func (iq *InstrumentQuery) SetLimit(limit int) InstrumentQueryInterface

+ func (iq *InstrumentQuery) SetOffset(offset int) InstrumentQueryInterface

+ func (iq *InstrumentQuery) SetOrderBy(orderBy string) InstrumentQueryInterface

+ func (iq *InstrumentQuery) SetSortDirection(sortDirection string) InstrumentQueryInterface

+ func (iq *InstrumentQuery) SetSymbol(symbol string) InstrumentQueryInterface

+ func (iq *InstrumentQuery) SetSymbolLike(symbolLike string) InstrumentQueryInterface

+ func (iq *InstrumentQuery) SortDirection() string

+ func (iq *InstrumentQuery) Symbol() string

+ func (iq *InstrumentQuery) SymbolLike() string

+ func (iq *InstrumentQuery) Validate() error

+ type InstrumentQueryInterface interface

+ AssetClass func() string

+ Columns func() []string

+ Exchange func() string

+ HasAssetClass func() bool

+ HasExchange func() bool

+ HasID func() bool

+ HasIDIn func() bool

+ HasLimit func() bool

+ HasOffset func() bool

+ HasOrderBy func() bool

+ HasSortDirection func() bool

+ HasSymbol func() bool

+ HasSymbolLike func() bool

+ ID func() string

+ IDIn func() []string

+ IsCountOnly func() bool

+ Limit func() int

+ Offset func() int

+ OrderBy func() string

+ SetAssetClass func(assetClass string) InstrumentQueryInterface

+ SetCountOnly func(countOnly bool) InstrumentQueryInterface

+ SetExchange func(exchange string) InstrumentQueryInterface

+ SetID func(id string) InstrumentQueryInterface

+ SetIDIn func(ids []string) InstrumentQueryInterface

+ SetLimit func(limit int) InstrumentQueryInterface

+ SetOffset func(offset int) InstrumentQueryInterface

+ SetOrderBy func(orderBy string) InstrumentQueryInterface

+ SetSortDirection func(sortDirection string) InstrumentQueryInterface

+ SetSymbol func(symbol string) InstrumentQueryInterface

+ SetSymbolLike func(symbolLike string) InstrumentQueryInterface

+ SortDirection func() string

+ Symbol func() string

+ SymbolLike func() string

+ Validate func() error

+ func NewInstrumentQuery() InstrumentQueryInterface

+ type NewStoreOptions struct

+ AutomigrateEnabled bool

+ DB *sql.DB

+ DbDriverName string

+ DebugEnabled bool

+ InstrumentTableName string

+ PriceTableName string

+ type Price struct

+ func (price *Price) GetClose() string

+ func (price *Price) GetCloseFloat() float64

+ func (price *Price) GetHigh() string

+ func (price *Price) GetHighFloat() float64

+ func (price *Price) GetLow() string

+ func (price *Price) GetLowFloat() float64

+ func (price *Price) GetOpen() string

+ func (price *Price) GetOpenFloat() float64

+ func (price *Price) GetTime() string

+ func (price *Price) GetTimeCarbon() carbon.Carbon

+ func (price *Price) GetVolume() string

+ func (price *Price) GetVolumeFloat() float64

+ func (price *Price) ID() string

+ func (price *Price) SetClose(close string) PriceInterface

+ func (price *Price) SetHigh(high string) PriceInterface

+ func (price *Price) SetID(id string) PriceInterface

+ func (price *Price) SetLow(low string) PriceInterface

+ func (price *Price) SetOpen(open string) PriceInterface

+ func (price *Price) SetTime(timeUtc string) PriceInterface

+ func (price *Price) SetVolume(volume string) PriceInterface

+ type PriceInterface interface

+ Data func() map[string]string

+ DataChanged func() map[string]string

+ GetClose func() string

+ GetCloseFloat func() float64

+ GetHigh func() string

+ GetHighFloat func() float64

+ GetLow func() string

+ GetLowFloat func() float64

+ GetOpen func() string

+ GetOpenFloat func() float64

+ GetTime func() string

+ GetTimeCarbon func() carbon.Carbon

+ GetVolume func() string

+ GetVolumeFloat func() float64

+ ID func() string

+ MarkAsNotDirty func()

+ SetClose func(close string) PriceInterface

+ SetHigh func(high string) PriceInterface

+ SetID func(id string) PriceInterface

+ SetLow func(low string) PriceInterface

+ SetOpen func(open string) PriceInterface

+ SetTime func(time string) PriceInterface

+ SetVolume func(volume string) PriceInterface

+ func NewPrice() PriceInterface

+ func NewPriceFromExistingData(data map[string]string) PriceInterface

+ type PriceQueryInterface interface

+ Columns func() []string

+ HasCountOnly func() bool

+ HasID func() bool

+ HasIDIn func() bool

+ HasLimit func() bool

+ HasOffset func() bool

+ HasOrderBy func() bool

+ HasSortDirection func() bool

+ HasTime func() bool

+ HasTimeGte func() bool

+ HasTimeLte func() bool

+ ID func() string

+ IDIn func() []string

+ IsCountOnly func() bool

+ Limit func() int

+ Offset func() int

+ OrderBy func() string

+ SetColumns func(columns []string) PriceQueryInterface

+ SetCountOnly func(countOnly bool) PriceQueryInterface

+ SetID func(id string) PriceQueryInterface

+ SetIDIn func(idIn []string) PriceQueryInterface

+ SetLimit func(limit int) PriceQueryInterface

+ SetOffset func(offset int) PriceQueryInterface

+ SetOrderBy func(orderBy string) PriceQueryInterface

+ SetSortDirection func(sortDirection string) PriceQueryInterface

+ SetTime func(createdAt string) PriceQueryInterface

+ SetTimeGte func(createdAtGte string) PriceQueryInterface

+ SetTimeLte func(createdAtLte string) PriceQueryInterface

+ SortDirection func() string

+ Time func() string

+ TimeGte func() string

+ TimeLte func() string

+ Validate func() error

+ func NewPriceQuery() PriceQueryInterface

+ func PriceQuery() PriceQueryInterface

+ type Store struct

+ func (st *Store) DB() *sql.DB

+ func (st *Store) EnableDebug(debug bool)

+ func (store *Store) AutoMigrate() error

+ func (store *Store) InstrumentCount(ctx context.Context, options InstrumentQueryInterface) (int64, error)

+ func (store *Store) InstrumentCreate(ctx context.Context, instrument InstrumentInterface) error

+ func (store *Store) InstrumentDelete(ctx context.Context, instrument InstrumentInterface) error

+ func (store *Store) InstrumentDeleteByID(ctx context.Context, id string) error

+ func (store *Store) InstrumentExists(ctx context.Context, options InstrumentQueryInterface) (bool, error)

+ func (store *Store) InstrumentFindByID(ctx context.Context, id string) (InstrumentInterface, error)

+ func (store *Store) InstrumentList(ctx context.Context, options InstrumentQueryInterface) ([]InstrumentInterface, error)

+ func (store *Store) InstrumentUpdate(ctx context.Context, instrument InstrumentInterface) error

+ func (store *Store) PriceCount(ctx context.Context, options PriceQueryInterface) (int64, error)

+ func (store *Store) PriceCreate(ctx context.Context, price PriceInterface) error

+ func (store *Store) PriceDelete(ctx context.Context, price PriceInterface) error

+ func (store *Store) PriceDeleteByID(ctx context.Context, id string) error

+ func (store *Store) PriceExists(ctx context.Context, options PriceQueryInterface) (bool, error)

+ func (store *Store) PriceFindByID(ctx context.Context, id string) (PriceInterface, error)

+ func (store *Store) PriceList(ctx context.Context, options PriceQueryInterface) ([]PriceInterface, error)

+ func (store *Store) PriceUpdate(ctx context.Context, price PriceInterface) error

+ type StoreInterface interface

+ AutoMigrate func() error

+ DB func() *sql.DB

+ EnableDebug func(bool)

+ InstrumentCount func(ctx context.Context, options InstrumentQueryInterface) (int64, error)

+ InstrumentCreate func(ctx context.Context, instrument InstrumentInterface) error

+ InstrumentDelete func(ctx context.Context, instrument InstrumentInterface) error

+ InstrumentDeleteByID func(ctx context.Context, id string) error

+ InstrumentExists func(ctx context.Context, options InstrumentQueryInterface) (bool, error)

+ InstrumentFindByID func(ctx context.Context, id string) (InstrumentInterface, error)

+ InstrumentList func(ctx context.Context, options InstrumentQueryInterface) ([]InstrumentInterface, error)

+ InstrumentUpdate func(ctx context.Context, instrument InstrumentInterface) error

+ PriceCount func(ctx context.Context, options PriceQueryInterface) (int64, error)

+ PriceCreate func(ctx context.Context, price PriceInterface) error

+ PriceDelete func(ctx context.Context, price PriceInterface) error

+ PriceDeleteByID func(ctx context.Context, id string) error

+ PriceExists func(ctx context.Context, options PriceQueryInterface) (bool, error)

+ PriceFindByID func(ctx context.Context, id string) (PriceInterface, error)

+ PriceList func(ctx context.Context, options PriceQueryInterface) ([]PriceInterface, error)

+ PriceUpdate func(ctx context.Context, price PriceInterface) error

+ func NewStore(opts NewStoreOptions) (StoreInterface, error)

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