warekv

Documentation

Index

• type CacheOption
  • func DefaultCacheOption() *CacheOption
• type WareEngine
  • func Default() *WareEngine
  • func Engine() *WareEngine
  • func New(option *WareEngineOption) *WareEngine
  • func (e *WareEngine) Close()
  • func (e *WareEngine) Delete(key *storage.Key)
  • func (e *WareEngine) DeleteInTime(key *storage.Key)
  • func (e *WareEngine) Get(key *storage.Key) storage.Value
  • func (e *WareEngine) Notify(key string, newVal interface{}, event int)
  • func (e *WareEngine) Set(key *storage.Key, value storage.Value)
  • func (e *WareEngine) SetInTime(key *storage.Key, value storage.Value)
  • func (e *WareEngine) Subscribe(option *manager.SubscribeManifest)
• type WareEngineOption
  • func DefaultOption() *WareEngineOption

Types

type CacheOption

type CacheOption struct {
	Open     bool   `yaml:"Open"`
	Strategy string `yaml:"Strategy"`
	MaxBytes uint64 `yaml:"MaxBytes"`
}

func DefaultCacheOption

func DefaultCacheOption() *CacheOption

type WareEngine

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

func Default

func Default() *WareEngine

func Engine

func Engine() *WareEngine

func New

func New(option *WareEngineOption) *WareEngine

func (*WareEngine) Close

func (e *WareEngine) Close()

func (*WareEngine) Delete

func (e *WareEngine) Delete(key *storage.Key)

func (*WareEngine) DeleteInTime

func (e *WareEngine) DeleteInTime(key *storage.Key)

func (*WareEngine) Get

func (e *WareEngine) Get(key *storage.Key) storage.Value

func (*WareEngine) Notify

func (e *WareEngine) Notify(key string, newVal interface{}, event int)

func (*WareEngine) Set

func (e *WareEngine) Set(key *storage.Key, value storage.Value)

func (*WareEngine) SetInTime

func (e *WareEngine) SetInTime(key *storage.Key, value storage.Value)

func (*WareEngine) Subscribe

func (e *WareEngine) Subscribe(option *manager.SubscribeManifest)

type WareEngineOption

type WareEngineOption struct {
	Shard       *storage.ShardOption           `yaml:"Shard"`
	GC          *storage.WareGCOption          `yaml:"GC"`
	Subscriber  *manager.SubscribeCenterOption `yaml:"Subscriber"`
	MachineInfo *machine.WareInfoOption        `yaml:"MachineInfo"`
	Cache       *CacheOption                   `yaml:"Cache"`
}

func DefaultOption

func DefaultOption() *WareEngineOption