sql

Documentation

Index

• type DB
  • func New(cfg config.SQL) (*DB, error)
  • func (sqldb *DB) ClearAllSymbolListenersCount(ctx context.Context) error
  • func (sqldb *DB) ClearSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) error
  • func (sqldb *DB) DecrementSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)
  • func (sqldb *DB) GetSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)
  • func (sqldb *DB) IncrementSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)
  • func (d *DB) Reset() error

Types

type DB

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

func New

func New(cfg config.SQL) (*DB, error)

func (*DB) ClearAllSymbolListenersCount

func (sqldb *DB) ClearAllSymbolListenersCount(ctx context.Context) error

func (*DB) ClearSymbolListenerSubscribers

func (sqldb *DB) ClearSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) error

func (*DB) DecrementSymbolListenerSubscribers

func (sqldb *DB) DecrementSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)

func (*DB) GetSymbolListenerSubscribers

func (sqldb *DB) GetSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)

func (*DB) IncrementSymbolListenerSubscribers

func (sqldb *DB) IncrementSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)

func (*DB) Reset

func (d *DB) Reset() error