redis

Documentation

Index

• Constants
• Variables
• func Disconnect() error
• func InitRedis(cfg *RedisConfig) error
• type RedisConfig
  • func LoadRedisConfig() (*RedisConfig, error)
• type RedisDB
  • func GetCurrRedisDB() (*RedisDB, bool)
  • func (r *RedisDB) CommitTransaction(serverTransactionID uuid.UUID, status metrics.Status) error
  • func (r *RedisDB) DelKey(serverTransactionID uuid.UUID)
  • func (r *RedisDB) ExistsTransaction(serverTransactionID uuid.UUID) bool
  • func (r *RedisDB) GetTransactionStatus(serverTransactionID uuid.UUID, status metrics.Status) (metrics.Status, error)
  • func (r *RedisDB) UpdateStatus(serverTransactionID uuid.UUID, status metrics.Status) error

Constants

const (
	TransactionTable = "transactionTable"
)

Variables

var (
	TransactionAlreadyExistsError = fmt.Errorf("transactionAlreadyExistsError")
	TransactionNotFoundError      = fmt.Errorf("transactionNotFoundError")
	ChangedKeyErr                 = fmt.Errorf("the key changed at the time of the request")
)

Functions

func Disconnect

func Disconnect() error

func InitRedis

func InitRedis(cfg *RedisConfig) error

Types

type RedisConfig

type RedisConfig struct {
	Host     string
	Port     string
	Password string
	DB       int
}

func LoadRedisConfig

func LoadRedisConfig() (*RedisConfig, error)

type RedisDB

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

func GetCurrRedisDB

func GetCurrRedisDB() (*RedisDB, bool)

func (*RedisDB) CommitTransaction

func (r *RedisDB) CommitTransaction(serverTransactionID uuid.UUID, status metrics.Status) error

func (*RedisDB) DelKey

func (r *RedisDB) DelKey(serverTransactionID uuid.UUID)

func (*RedisDB) ExistsTransaction

func (r *RedisDB) ExistsTransaction(serverTransactionID uuid.UUID) bool

func (*RedisDB) GetTransactionStatus

func (r *RedisDB) GetTransactionStatus(serverTransactionID uuid.UUID, status metrics.Status) (metrics.Status, error)

func (*RedisDB) UpdateStatus

func (r *RedisDB) UpdateStatus(serverTransactionID uuid.UUID, status metrics.Status) error