database

Documentation

Index

• Variables
• func Connect(config *Config)
• func Init(cfg *Config) (err error)
• type BinanceDepthResponse
  • func (resp *BinanceDepthResponse) InsertIntoDatabase(sym string) error
• type BinanceFuturesDepthResponse
  • func (resp *BinanceFuturesDepthResponse) InsertIntoDatabase(sym string) error
• type Config
• type Tabler

Variables

var (
	DBTableMarketName string
)

Functions

func Connect

func Connect(config *Config)

func Init

func Init(cfg *Config) (err error)

Types

type BinanceDepthResponse

type BinanceDepthResponse struct {
	Snapshot *binance.DepthResponse
	Response *binance.WsDepthEvent
}

func (*BinanceDepthResponse) InsertIntoDatabase

func (resp *BinanceDepthResponse) InsertIntoDatabase(sym string) error

type BinanceFuturesDepthResponse

type BinanceFuturesDepthResponse struct {
	Snapshot *futures.DepthResponse
	Response *futures.WsDepthEvent
}

func (*BinanceFuturesDepthResponse) InsertIntoDatabase

func (resp *BinanceFuturesDepthResponse) InsertIntoDatabase(sym string) error

type Config

type Config struct {
	DBName            string `mapstructure:"POSTGRES_DB"`
	DBUser            string `mapstructure:"POSTGRES_USER"`
	DBPassword        string `mapstructure:"POSTGRES_PASSWORD"`
	DBServer          string `mapstructure:"POSTGRES_SERVER"`
	DBPort            string `mapstructure:"POSTGRES_PORT"`
	Debug             bool   `mapstructure:"Debug"`
	DBTableMarketName string
	DBDeleteOldSnap   bool
}

type Tabler

type Tabler interface {
	TableName() string
}