redisHelpers

Documentation

Index

• func GetRedisTime(pool ConnGetter) (redisTime time.Time, err error)
• func GetRequest(ctx context.Context, pool ConnGetter, logger *log.Logger) (request *protocol.Request, err error)
• func PublishResponse(res *protocol.Response, responseKey string, pool ConnGetter, ...)
• type ConnGetter
• type MockPool
  • func NewMockPool() (mp *MockPool)
  • func (mp *MockPool) Get() (conn redis.Conn)

Functions

func GetRedisTime

func GetRedisTime(pool ConnGetter) (redisTime time.Time, err error)

GetRedisTime returns the redis server's current timestamp

func GetRequest

func GetRequest(ctx context.Context, pool ConnGetter, logger *log.Logger) (request *protocol.Request, err error)

GetRequest retrieves a hash request from redis. If no requests are currently in the queue, it blocks until one is available.

func PublishResponse

func PublishResponse(res *protocol.Response, responseKey string, pool ConnGetter, logger *log.Logger)

PublishResponse publishes the provided response via redis, including automatic retry and responseKey concatenation with the prefix from the config package.

Types

type ConnGetter

type ConnGetter interface {
	// Get returns a redis connection instance.
	Get() redis.Conn
}

type MockPool

type MockPool struct {
	Conn *redigomock.Conn
}

func NewMockPool

func NewMockPool() (mp *MockPool)

func (*MockPool) Get

func (mp *MockPool) Get() (conn redis.Conn)

Get returns a redis connection instance.