teacache

Documentation

Index

• Variables
• func AllCacheTypes() []maps.Map
• func FindType(typeCode string) maps.Map
• func FindTypeName(typeCode string) string
• func ProcessAfterRequest(req *teaproxy.Request, writer *teaproxy.ResponseWriter) bool
• func ProcessBeforeRequest(req *teaproxy.Request, writer *teaproxy.ResponseWriter) bool
• func ResetCachePolicyManager(filename string)
• type FileManager
  • func NewFileManager() *FileManager
  • func (this *FileManager) Clean() error
  • func (this *FileManager) Close() error
  • func (this *FileManager) Delete(key string) error
  • func (this *FileManager) Read(key string) (data []byte, err error)
  • func (this *FileManager) SetOptions(options map[string]interface{})
  • func (this *FileManager) Stat() (size int64, countKeys int, err error)
  • func (this *FileManager) Write(key string, data []byte) error
• type Item
  • func NewItem() *Item
  • func (this *Item) Decode(data []byte)
  • func (this *Item) Encode() (data []byte)
• type LevelDBManager
  • func NewLevelDBManager() *LevelDBManager
  • func (this *LevelDBManager) Clean() error
  • func (this *LevelDBManager) CleanExpired() error
  • func (this *LevelDBManager) Close() error
  • func (this *LevelDBManager) Delete(key string) error
  • func (this *LevelDBManager) Read(key string) (data []byte, err error)
  • func (this *LevelDBManager) SetOptions(options map[string]interface{})
  • func (this *LevelDBManager) Stat() (size int64, countKeys int, err error)
  • func (this *LevelDBManager) Write(key string, data []byte) error
• type Manager
  • func (this *Manager) Id() string
  • func (this *Manager) SetId(id string)
• type ManagerInterface
  • func FindCachePolicyManager(filename string) ManagerInterface
  • func NewManagerFromConfig(config *shared.CachePolicy) ManagerInterface
• type MemoryManager
  • func NewMemoryManager() *MemoryManager
  • func (this *MemoryManager) Clean() error
  • func (this *MemoryManager) Close() error
  • func (this *MemoryManager) Delete(key string) error
  • func (this *MemoryManager) Read(key string) (data []byte, err error)
  • func (this *MemoryManager) SetOptions(options map[string]interface{})
  • func (this *MemoryManager) Stat() (size int64, countKeys int, err error)
  • func (this *MemoryManager) Write(key string, data []byte) error
• type RedisManager
  • func NewRedisManager() *RedisManager
  • func (this *RedisManager) Clean() error
  • func (this *RedisManager) Close() error
  • func (this *RedisManager) Delete(key string) error
  • func (this *RedisManager) Read(key string) (data []byte, err error)
  • func (this *RedisManager) SetOptions(options map[string]interface{})
  • func (this *RedisManager) Stat() (size int64, countKeys int, err error)
  • func (this *RedisManager) Write(key string, data []byte) error

Variables

var ErrNotFound = errors.New("cache not found")

Functions

func AllCacheTypes

func AllCacheTypes() []maps.Map

所有的缓存配置

func FindType

func FindType(typeCode string) maps.Map

查找类型信息

func FindTypeName

func FindTypeName(typeCode string) string

查找类型名称

func ProcessAfterRequest

func ProcessAfterRequest(req *teaproxy.Request, writer *teaproxy.ResponseWriter) bool

请求之后处理

func ProcessBeforeRequest

func ProcessBeforeRequest(req *teaproxy.Request, writer *teaproxy.ResponseWriter) bool

请求之前处理

func ResetCachePolicyManager

func ResetCachePolicyManager(filename string)

重置管理器

Types

type FileManager

type FileManager struct {
	Manager

	Capacity float64       // 容量
	Life     time.Duration // 有效期
	// contains filtered or unexported fields
}

文件缓存管理器

func NewFileManager

func NewFileManager() *FileManager

func (*FileManager) Clean

func (this *FileManager) Clean() error

清理

func (*FileManager) Close

func (this *FileManager) Close() error

func (*FileManager) Delete

func (this *FileManager) Delete(key string) error

删除

func (*FileManager) Read

func (this *FileManager) Read(key string) (data []byte, err error)

读取

func (*FileManager) SetOptions

func (this *FileManager) SetOptions(options map[string]interface{})

func (*FileManager) Stat

func (this *FileManager) Stat() (size int64, countKeys int, err error)

统计

func (*FileManager) Write

func (this *FileManager) Write(key string, data []byte) error

写入

type Item

type Item struct {
	Header []byte
	Body   []byte
}

缓存条目

func NewItem

func NewItem() *Item

获取新对象

func (*Item) Decode

func (this *Item) Decode(data []byte)

func (*Item) Encode

func (this *Item) Encode() (data []byte)

type LevelDBManager

type LevelDBManager struct {
	Manager

	Capacity float64       // 容量
	Life     time.Duration // 有效期
	// contains filtered or unexported fields
}

Leveldb缓存管理器

func NewLevelDBManager

func NewLevelDBManager() *LevelDBManager

func (*LevelDBManager) Clean

func (this *LevelDBManager) Clean() error

清理

func (*LevelDBManager) CleanExpired

func (this *LevelDBManager) CleanExpired() error

func (*LevelDBManager) Close

func (this *LevelDBManager) Close() error

关闭

func (*LevelDBManager) Delete

func (this *LevelDBManager) Delete(key string) error

删除

func (*LevelDBManager) Read

func (this *LevelDBManager) Read(key string) (data []byte, err error)

func (*LevelDBManager) SetOptions

func (this *LevelDBManager) SetOptions(options map[string]interface{})

func (*LevelDBManager) Stat

func (this *LevelDBManager) Stat() (size int64, countKeys int, err error)

统计

func (*LevelDBManager) Write

func (this *LevelDBManager) Write(key string, data []byte) error

type Manager

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

func (*Manager) Id

func (this *Manager) Id() string

获取ID

func (*Manager) SetId

func (this *Manager) SetId(id string)

设置ID

type ManagerInterface

type ManagerInterface interface {
	// 设置ID
	SetId(id string)

	// 写入
	Write(key string, data []byte) error

	// 读取
	Read(key string) (data []byte, err error)

	// 删除
	Delete(key string) error

	// 设置选项
	SetOptions(options map[string]interface{})

	// 统计
	Stat() (size int64, countKeys int, err error)

	// 清理
	Clean() error

	// 关闭
	Close() error
}

缓存管理接口

func FindCachePolicyManager

func FindCachePolicyManager(filename string) ManagerInterface

获取管理器

func NewManagerFromConfig

func NewManagerFromConfig(config *shared.CachePolicy) ManagerInterface

获取新的管理对象

type MemoryManager

type MemoryManager struct {
	Manager

	Capacity float64       // 容量
	Life     time.Duration // 有效期
	// contains filtered or unexported fields
}

内存缓存管理器

func NewMemoryManager

func NewMemoryManager() *MemoryManager

func (*MemoryManager) Clean

func (this *MemoryManager) Clean() error

清理

func (*MemoryManager) Close

func (this *MemoryManager) Close() error

关闭

func (*MemoryManager) Delete

func (this *MemoryManager) Delete(key string) error

删除

func (*MemoryManager) Read

func (this *MemoryManager) Read(key string) (data []byte, err error)

func (*MemoryManager) SetOptions

func (this *MemoryManager) SetOptions(options map[string]interface{})

func (*MemoryManager) Stat

func (this *MemoryManager) Stat() (size int64, countKeys int, err error)

统计

func (*MemoryManager) Write

func (this *MemoryManager) Write(key string, data []byte) error

type RedisManager

type RedisManager struct {
	Manager

	Capacity float64       // 容量
	Life     time.Duration // 有效期

	Network  string
	Host     string
	Port     int
	Password string
	Sock     string
	// contains filtered or unexported fields
}

内存缓存管理器

func NewRedisManager

func NewRedisManager() *RedisManager

func (*RedisManager) Clean

func (this *RedisManager) Clean() error

清理

func (*RedisManager) Close

func (this *RedisManager) Close() error

关闭

func (*RedisManager) Delete

func (this *RedisManager) Delete(key string) error

删除

func (*RedisManager) Read

func (this *RedisManager) Read(key string) (data []byte, err error)

func (*RedisManager) SetOptions

func (this *RedisManager) SetOptions(options map[string]interface{})

func (*RedisManager) Stat

func (this *RedisManager) Stat() (size int64, countKeys int, err error)

统计

func (*RedisManager) Write

func (this *RedisManager) Write(key string, data []byte) error