utils

Documentation

Index

• Variables
• func OpenDB(cfg Config) (*sql.DB, error)
• func OpenMySQL(user, password, database, host, port string) (*sql.DB, error)
• func OpenPostgres(user, password, database, host, port string) (*sql.DB, error)
• func OpenRedis(redisAddress, redisPassword string) *redis.Client
• func ValidateFilePath(path string) error
• type Config
  • func NewConfig(filePath string) (*Config, error)
  • func (c Config) CopyToHash() error
  • func (c Config) CopyToList() error
  • func (c Config) CopyToString() error
• type PipelineHook
  • func (p PipelineHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error
  • func (p PipelineHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error
  • func (p PipelineHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)
  • func (p PipelineHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)

Variables

var CTX = context.Background()

CTX is the global context for Redis

Functions

func OpenDB

func OpenDB(cfg Config) (*sql.DB, error)

func OpenMySQL

func OpenMySQL(user, password, database, host, port string) (*sql.DB, error)

OpenMySQL opens a MySQL connection with a desired user, password, database name, host, and port

func OpenPostgres

func OpenPostgres(user, password, database, host, port string) (*sql.DB, error)

OpenPostgres opens a PostgreSQL connection with a desired user, password database name, host and port

func OpenRedis

func OpenRedis(redisAddress, redisPassword string) *redis.Client

OpenRedis opens a redis connection with a desired address and password

func ValidateFilePath

func ValidateFilePath(path string) error

ValidateFilePath validates the filepath of a given file

Types

type Config

type Config struct {
	SQLType     string  `yaml:"sqltype"`
	SQLUser     string  `yaml:"sqluser"`
	SQLPassword string  `yaml:"sqlpassword"`
	SQLDatabase string  `yaml:"sqldatabase"`
	SQLHost     string  `yaml:"sqlhost"`
	SQLPort     string  `yaml:"sqlport"`
	SQLTable    string  `yaml:"sqltable"`
	RedisAddr   string  `yaml:"redisaddr"`
	RedisPass   string  `yaml:"redispass"`
	LogLevel    *uint8  `yaml:"log_level"`
	LogFilename *string `yaml:"log_filename"`
}

Config is the configuration struct for redisql

func NewConfig

func NewConfig(filePath string) (*Config, error)

NewConfig initializes a new object of Config structure

func (Config) CopyToHash

func (c Config) CopyToHash() error

CopyToHash reads a desired SQL table's rows and writes them to Redis hashes

func (Config) CopyToList

func (c Config) CopyToList() error

CopyToList reads a desired SQL table's rows and writes them to Redis lists

func (Config) CopyToString

func (c Config) CopyToString() error

CopyToString reads a desired SQL table's rows and writes them to Redis strings

type PipelineHook

type PipelineHook struct {
}

func (PipelineHook) AfterProcess

func (p PipelineHook) AfterProcess(ctx context.Context, cmd redis.Cmder) error

Required to implement a hook

func (PipelineHook) AfterProcessPipeline

func (p PipelineHook) AfterProcessPipeline(ctx context.Context, cmds []redis.Cmder) error

func (PipelineHook) BeforeProcess

func (p PipelineHook) BeforeProcess(ctx context.Context, cmd redis.Cmder) (context.Context, error)

Required to implement a hook

func (PipelineHook) BeforeProcessPipeline

func (p PipelineHook) BeforeProcessPipeline(ctx context.Context, cmds []redis.Cmder) (context.Context, error)