persistence

Documentation

Index

• Variables
• func NewCandleMockRepository(candleTableName, timeFormat, productCode string, duration time.Duration) repository.CandleRepository
• func NewCandleRepository(db DB, candleTableName, timeFormat string) repository.CandleRepository
• func NewCookie(name string, path string, maxAge int, secureCookie *securecookie.SecureCookie) repository.Cookie
• func NewMySQLTransaction(dsn string) *sql.Tx
• func NewSessionRepository(db DB) repository.SessionRepository
• func NewSignalEventRepository(db DB, timeFormat string) repository.SignalEventRepository
• func NewTradeParamsRepository(db DB) repository.TradeParamsRepository
• func NewUserRepository(db DB) repository.UserRepository
• type DB

Variables

var (
	MYSQL_DATABASE = os.Getenv("MYSQL_DATABASE")
	GCS_BUCKET     = os.Getenv("GCS_BUCKET")
)

Functions

func NewCandleMockRepository

func NewCandleMockRepository(candleTableName, timeFormat, productCode string, duration time.Duration) repository.CandleRepository

func NewCandleRepository

func NewCandleRepository(db DB, candleTableName, timeFormat string) repository.CandleRepository

func NewCookie

func NewCookie(name string, path string, maxAge int, secureCookie *securecookie.SecureCookie) repository.Cookie

func NewMySQLTransaction

func NewMySQLTransaction(dsn string) *sql.Tx

func NewSessionRepository

func NewSessionRepository(db DB) repository.SessionRepository

func NewSignalEventRepository

func NewSignalEventRepository(db DB, timeFormat string) repository.SignalEventRepository

func NewTradeParamsRepository

func NewTradeParamsRepository(db DB) repository.TradeParamsRepository

func NewUserRepository

func NewUserRepository(db DB) repository.UserRepository

Types

type DB

type DB interface {
	Exec(query string, args ...interface{}) (sql.Result, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
}