redis

type BorrowFunc ¶ added in v0.0.4

type BorrowFunc func(c redigo.Conn, t time.Time) error

func NewSamplingBorrow(mod float64) BorrowFunc

type LogWrapper ¶

type LogWrapper struct {
	Logger *log.Logger
}

LogWrapper wraps a standard Logger to implement the Logger interface.

func NewLogWrapper() *LogWrapper

func (l *LogWrapper) Error(ctx context.Context, format string, args ...interface{})

func (l *LogWrapper) Info(ctx context.Context, format string, args ...interface{})

func (l *LogWrapper) Warn(ctx context.Context, format string, args ...interface{})

type Logger ¶

type Logger interface {
	Info(context.Context, string, ...interface{})
	Warn(context.Context, string, ...interface{})
	Error(context.Context, string, ...interface{})
}

Logger is a minimal interface for a logger

type Sender ¶

type Sender interface {
	Send(string, ...interface{}) error
}

Sender is an interface that is compatible with the redis.Send(..) function.

type Subscriber ¶

type Subscriber struct {
	Logger Logger
	// contains filtered or unexported fields
}

Subscriber subscribes to a Redis key, and writes receive messages to a channel.

func NewSubscriber(logger Logger, pool *redigo.Pool, key string, out chan []byte) Subscriber

func (s *Subscriber) Run(ctx context.Context) error