repository

Documentation

Index

• Constants
• func CreateTables(ctx context.Context, conn *pgxpool.Pool) error
• func Recreate(ctx context.Context, conn *pgxpool.Pool) error
• type Asset
  • func (db *Asset) Delete(ctx context.Context, symbol string) error
  • func (db *Asset) Get(ctx context.Context, symbol string) (*pb.Asset, error)
  • func (db *Asset) List(ctx context.Context) ([]*pb.Asset, error)
  • func (db *Asset) ListBySymbols(ctx context.Context, symbols []string) ([]*pb.Asset, error)
  • func (db *Asset) Store(ctx context.Context, symbol, name string) error
• type OHLC
  • func (db *OHLC) Exists(ctx context.Context, symbols []string, start, end *pb.Date) (bool, error)
  • func (db *OHLC) MinMax(ctx context.Context) (*pb.Date, *pb.Date, error)
  • func (db *OHLC) Store(ctx context.Context, symbol string, t time.Time, o, h, l, c float64, v int) error

Constants

const AssetTable = `CREATE TABLE IF NOT EXISTS asset (
symbol text primary key,
name text);
`

const OHLCTable = `` /* 183-byte string literal not displayed */

Functions

func CreateTables

func CreateTables(ctx context.Context, conn *pgxpool.Pool) error

func Recreate

func Recreate(ctx context.Context, conn *pgxpool.Pool) error

Types

type Asset

type Asset struct {
	Conn postgres.Query
}

func (*Asset) Delete

func (db *Asset) Delete(ctx context.Context, symbol string) error

func (*Asset) Get

func (db *Asset) Get(ctx context.Context, symbol string) (*pb.Asset, error)

func (*Asset) List

func (db *Asset) List(ctx context.Context) ([]*pb.Asset, error)

func (*Asset) ListBySymbols

func (db *Asset) ListBySymbols(ctx context.Context, symbols []string) ([]*pb.Asset, error)

func (*Asset) Store

func (db *Asset) Store(ctx context.Context, symbol, name string) error

type OHLC

type OHLC struct {
	Conn postgres.Query
}

func (*OHLC) Exists

func (db *OHLC) Exists(ctx context.Context, symbols []string, start, end *pb.Date) (bool, error)

func (*OHLC) MinMax

func (db *OHLC) MinMax(ctx context.Context) (*pb.Date, *pb.Date, error)

func (*OHLC) Store

func (db *OHLC) Store(ctx context.Context, symbol string, t time.Time, o, h, l, c float64, v int) error