redis

Documentation

Index

• Variables
• func FormatCacheKey(req *http.Request) string
• type CacheReader
  • func (c *CacheReader) Close() error
  • func (c *CacheReader) Read(p []byte) (int, error)
  • func (c *CacheReader) WriteTo(w io.Writer) (int64, error)
• type CacheWriter
  • func (c *CacheWriter) Close() error
  • func (c *CacheWriter) Write(p []byte) (int, error)
• type Client
  • func Connect(conf *config.Config) (*Client, error)
  • func (c *Client) Close()
  • func (c *Client) Get(ctx context.Context, req *http.Request, httpTimeout time.Duration) (*http.Response, error)
  • func (c *Client) NewWriter(ctx context.Context, req *http.Request, resp *http.Response, ...) (io.WriteCloser, error)
  • func (c *Client) Ping(ctx context.Context) error

Variables

var ErrNotExist = errors.New("key not found")

Functions

func FormatCacheKey

func FormatCacheKey(req *http.Request) string

Types

type CacheReader

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

func (*CacheReader) Close

func (c *CacheReader) Close() error

func (*CacheReader) Read

func (c *CacheReader) Read(p []byte) (int, error)

func (*CacheReader) WriteTo

func (c *CacheReader) WriteTo(w io.Writer) (int64, error)

type CacheWriter

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

func (*CacheWriter) Close

func (c *CacheWriter) Close() error

func (*CacheWriter) Write

func (c *CacheWriter) Write(p []byte) (int, error)

type Client

type Client struct {
	rueidis.Client
}

func Connect

func Connect(conf *config.Config) (*Client, error)

func (*Client) Close

func (c *Client) Close()

func (*Client) Get

func (c *Client) Get(ctx context.Context, req *http.Request, httpTimeout time.Duration) (*http.Response, error)

func (*Client) NewWriter

func (c *Client) NewWriter(ctx context.Context, req *http.Request, resp *http.Response, expiration time.Duration) (io.WriteCloser, error)

func (*Client) Ping

func (c *Client) Ping(ctx context.Context) error