cacheme

Documentation

Overview

nolint

Index

• Constants
• Variables
• type Client
  • func New(redis cacheme.RedisClient) *Client
  • func NewCluster(redis cacheme.RedisClient) *Client
  • func (c *Client) NewPipeline() *cacheme.CachePipeline
  • func (c *Client) Redis() cacheme.RedisClient
  • func (c *Client) SetLogger(l cacheme.Logger)
• type FooListPPromise
  • func (p *FooListPPromise) Result() ([]*model.Foo, error)
  • func (p *FooListPPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)
• type FooListPromise
  • func (p *FooListPromise) Result() ([]model.Foo, error)
  • func (p *FooListPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)
• type FooMapPromise
  • func (p *FooMapPromise) Result() (map[string]string, error)
  • func (p *FooMapPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)
• type FooMapSPromise
  • func (p *FooMapSPromise) Result() (map[model.Foo]model.Bar, error)
  • func (p *FooMapSPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)
• type FooPPromise
  • func (p *FooPPromise) Result() (*model.Foo, error)
  • func (p *FooPPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)
• type FooPromise
  • func (p *FooPromise) Result() (model.Foo, error)
  • func (p *FooPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)
• type SimpleFlightPromise
  • func (p *SimpleFlightPromise) Result() (string, error)
  • func (p *SimpleFlightPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)
• type SimplePromise
  • func (p *SimplePromise) Result() (string, error)
  • func (p *SimplePromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)

Constants

const (
	Hit   = "HIT"
	Miss  = "MISS"
	Fetch = "FETCH"
)

Variables

var FooCacheStore = &fooCache{tag: "Foo"}

var FooListCacheStore = &fooListCache{tag: "FooList"}

var FooListPCacheStore = &fooListPCache{tag: "FooListP"}

var FooMapCacheStore = &fooMapCache{tag: "FooMap"}

var FooMapSCacheStore = &fooMapSCache{tag: "FooMapS"}

var FooPCacheStore = &fooPCache{tag: "FooP"}

var SimpleCacheStore = &simpleCache{tag: "Simple"}

var SimpleFlightCacheStore = &simpleFlightCache{tag: "SimpleFlight"}

Types

type Client

type Client struct {
	SimpleCacheStore *simpleCache

	FooMapCacheStore *fooMapCache

	FooCacheStore *fooCache

	FooPCacheStore *fooPCache

	FooListCacheStore *fooListCache

	FooListPCacheStore *fooListPCache

	FooMapSCacheStore *fooMapSCache

	SimpleFlightCacheStore *simpleFlightCache
	// contains filtered or unexported fields
}

func New

func New(redis cacheme.RedisClient) *Client

func NewCluster

func NewCluster(redis cacheme.RedisClient) *Client

func (*Client) NewPipeline

func (c *Client) NewPipeline() *cacheme.CachePipeline

func (*Client) Redis

func (c *Client) Redis() cacheme.RedisClient

func (*Client) SetLogger

func (c *Client) SetLogger(l cacheme.Logger)

type FooListPPromise

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

func (*FooListPPromise) Result

func (p *FooListPPromise) Result() ([]*model.Foo, error)

func (*FooListPPromise) WaitExecute

func (p *FooListPPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)

type FooListPromise

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

func (*FooListPromise) Result

func (p *FooListPromise) Result() ([]model.Foo, error)

func (*FooListPromise) WaitExecute

func (p *FooListPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)

type FooMapPromise

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

func (*FooMapPromise) Result

func (p *FooMapPromise) Result() (map[string]string, error)

func (*FooMapPromise) WaitExecute

func (p *FooMapPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)

type FooMapSPromise

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

func (*FooMapSPromise) Result

func (p *FooMapSPromise) Result() (map[model.Foo]model.Bar, error)

func (*FooMapSPromise) WaitExecute

func (p *FooMapSPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)

type FooPPromise

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

func (*FooPPromise) Result

func (p *FooPPromise) Result() (*model.Foo, error)

func (*FooPPromise) WaitExecute

func (p *FooPPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)

type FooPromise

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

func (*FooPromise) Result

func (p *FooPromise) Result() (model.Foo, error)

func (*FooPromise) WaitExecute

func (p *FooPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)

type SimpleFlightPromise

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

func (*SimpleFlightPromise) Result

func (p *SimpleFlightPromise) Result() (string, error)

func (*SimpleFlightPromise) WaitExecute

func (p *SimpleFlightPromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)

type SimplePromise

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

func (*SimplePromise) Result

func (p *SimplePromise) Result() (string, error)

func (*SimplePromise) WaitExecute

func (p *SimplePromise) WaitExecute(cp *cacheme.CachePipeline, key string, ID string)