cockroach

Documentation

Index

• Variables
• type AssetService
  • func (ps *AssetService) Create(assets ...asset.Asset) error
  • func (ps *AssetService) Delete(assets ...asset.Asset) error
  • func (ps *AssetService) Read(symbols ...string) ([]asset.Asset, error)
  • func (ps *AssetService) Update(assets ...asset.Asset) error
• type CandlestickService
  • func (css *CandlestickService) Create(cs *candlestick.List) error
  • func (css *CandlestickService) Delete(cs *candlestick.List) error
  • func (css *CandlestickService) Read(cs *candlestick.List, start, end timestamp.Timestamp, limit uint) error
  • func (css *CandlestickService) Update(cs *candlestick.List) error
• type Config
  • func (c Config) URL() string
  • func (c Config) Validate() error
• type Database
  • func New(c Config) (*Database, error)
  • func (s *Database) Assets() db.AssetService
  • func (s *Database) Candlesticks() db.CandlestickService
  • func (s *Database) Exchanges() db.ExchangeService
  • func (s *Database) Pairs() db.PairService
  • func (s *Database) Periods() db.PeriodService
• type ExchangeService
  • func (ps *ExchangeService) Create(exchanges ...exchange.Exchange) error
  • func (ps *ExchangeService) Delete(exchanges ...exchange.Exchange) error
  • func (ps *ExchangeService) GetAndSetLockedExpiration(fn func(time.Time) (*time.Time, error)) error
  • func (ps *ExchangeService) Read(names ...string) ([]exchange.Exchange, error)
  • func (ps *ExchangeService) SetPairs(exchangeName string, pairs []pair.Pair) error
  • func (ps *ExchangeService) Update(exchanges ...exchange.Exchange) error
• type Migrator
  • func NewMigrator(c Config) Migrator
  • func (m *Migrator) Create() error
  • func (m *Migrator) Migrate() error
  • func (m *Migrator) Reset() error
• type PairService
  • func (ps *PairService) Create(pairs ...pair.Pair) error
  • func (ps *PairService) Delete(pairs ...pair.Pair) error
  • func (ps *PairService) Read(pairs ...pair.Pair) ([]pair.Pair, error)
  • func (ps *PairService) ReadPerExchange(exchangeName string) ([]pair.Pair, error)
  • func (ps *PairService) Update(pairs ...pair.Pair) error
• type PeriodService
  • func (ps *PeriodService) Create(periods ...period.Period) error
  • func (ps *PeriodService) Delete(periods ...period.Period) error
  • func (ps *PeriodService) Read(names ...string) ([]period.Period, error)
  • func (ps *PeriodService) Update(periods ...period.Period) error

Variables

var (
	ErrNoUserInConfig = errors.New("no-cockroach-user-in-config")
	ErrNoHostInConfig = errors.New("no-cockroach-host-in-config")
	ErrNoPortInConfig = errors.New("no-cockroach-port-in-config")
)

var (
	DefaultGormConfig = &gorm.Config{
		Logger: logger.Default.LogMode(logger.Silent),
	}
)

var (
	ErrCandlestickNotFound = errors.New("candlestick-not-found")
)

Types

type AssetService

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

func (*AssetService) Create

func (ps *AssetService) Create(assets ...asset.Asset) error

func (*AssetService) Delete

func (ps *AssetService) Delete(assets ...asset.Asset) error

func (*AssetService) Read

func (ps *AssetService) Read(symbols ...string) ([]asset.Asset, error)

func (*AssetService) Update

func (ps *AssetService) Update(assets ...asset.Asset) error

type CandlestickService

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

func (*CandlestickService) Create

func (css *CandlestickService) Create(cs *candlestick.List) error

func (*CandlestickService) Delete

func (css *CandlestickService) Delete(cs *candlestick.List) error

func (*CandlestickService) Read

func (css *CandlestickService) Read(cs *candlestick.List, start, end timestamp.Timestamp, limit uint) error

func (*CandlestickService) Update

func (css *CandlestickService) Update(cs *candlestick.List) error

type Config

type Config struct {
	User     string
	Password string
	Host     string
	Port     int
	Database string
}

func (Config) URL

func (c Config) URL() string

func (Config) Validate

func (c Config) Validate() error

type Database

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

func New

func New(c Config) (*Database, error)

func (*Database) Assets

func (s *Database) Assets() db.AssetService

func (*Database) Candlesticks

func (s *Database) Candlesticks() db.CandlestickService

func (*Database) Exchanges

func (s *Database) Exchanges() db.ExchangeService

func (*Database) Pairs

func (s *Database) Pairs() db.PairService

func (*Database) Periods

func (s *Database) Periods() db.PeriodService

type ExchangeService

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

func (*ExchangeService) Create

func (ps *ExchangeService) Create(exchanges ...exchange.Exchange) error

func (*ExchangeService) Delete

func (ps *ExchangeService) Delete(exchanges ...exchange.Exchange) error

func (*ExchangeService) GetAndSetLockedExpiration

func (ps *ExchangeService) GetAndSetLockedExpiration(fn func(time.Time) (*time.Time, error)) error

func (*ExchangeService) Read

func (ps *ExchangeService) Read(names ...string) ([]exchange.Exchange, error)

func (*ExchangeService) SetPairs

func (ps *ExchangeService) SetPairs(exchangeName string, pairs []pair.Pair) error

func (*ExchangeService) Update

func (ps *ExchangeService) Update(exchanges ...exchange.Exchange) error

type Migrator

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

func NewMigrator

func NewMigrator(c Config) Migrator

func (*Migrator) Create

func (m *Migrator) Create() error

func (*Migrator) Migrate

func (m *Migrator) Migrate() error

func (*Migrator) Reset

func (m *Migrator) Reset() error

type PairService

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

func (*PairService) Create

func (ps *PairService) Create(pairs ...pair.Pair) error

func (*PairService) Delete

func (ps *PairService) Delete(pairs ...pair.Pair) error

func (*PairService) Read

func (ps *PairService) Read(pairs ...pair.Pair) ([]pair.Pair, error)

func (*PairService) ReadPerExchange

func (ps *PairService) ReadPerExchange(exchangeName string) ([]pair.Pair, error)

func (*PairService) Update

func (ps *PairService) Update(pairs ...pair.Pair) error

type PeriodService

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

func (*PeriodService) Create

func (ps *PeriodService) Create(periods ...period.Period) error

func (*PeriodService) Delete

func (ps *PeriodService) Delete(periods ...period.Period) error

func (*PeriodService) Read

func (ps *PeriodService) Read(names ...string) ([]period.Period, error)

func (*PeriodService) Update

func (ps *PeriodService) Update(periods ...period.Period) error