redis

Documentation

Index

• Variables
• type Config
  • func (c *Config) Load() *Config
  • func (c Config) Validate() error
• type DB
  • func New() (*DB, error)
  • func (db *DB) ClearAllSymbolListenersCount(ctx context.Context) error
  • func (db *DB) ClearSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) error
  • func (db *DB) DecrementSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)
  • func (db *DB) GetSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)
  • func (db *DB) IncrementSymbolListenerSubscribers(ctx context.Context, exchange, pairSymbol string) (int64, error)

Variables

var (
	ErrInvalidConfig = errors.New("invalid redis config")
)

Types

type Config

type Config struct {
	Address  string
	Password string
}

func (*Config) Load

func (c *Config) Load() *Config

func (Config) Validate

func (c Config) Validate() error

type DB

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

func New

func New() (*DB, error)

func (*DB) ClearAllSymbolListenersCount

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

func (*DB) ClearSymbolListenerSubscribers

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

func (*DB) DecrementSymbolListenerSubscribers

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

func (*DB) GetSymbolListenerSubscribers

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

func (*DB) IncrementSymbolListenerSubscribers

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