redisHelpers

package

v0.0.0-...-48849e1 Latest Latest Go to latest Published: Mar 18, 2021 License: MIT Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/rsheasby/gocrypt

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)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL