cache_strategy

Documentation

Index

• Constants
• func Register(register eosc.IExtenderDriverRegister)
• type ActuatorSet
• type CacheGetCompleteHandler
  • func NewCacheGetCompleteHandler(orgHandler eocontext.CompleteHandler, validTime int, uri string) *CacheGetCompleteHandler
  • func (c *CacheGetCompleteHandler) Complete(ctx eocontext.EoContext) error
• type CacheValidTime
  • func (l *CacheValidTime) CheckSkill(skill string) bool
  • func (l *CacheValidTime) Destroy() error
  • func (l *CacheValidTime) Id() string
  • func (l *CacheValidTime) Reset(v interface{}, workers map[eosc.RequireId]eosc.IWorker) error
  • func (l *CacheValidTime) Start() error
  • func (l *CacheValidTime) Stop() error
• type CacheValidTimeHandler
  • func NewCacheValidTimeHandler(conf *Config) (*CacheValidTimeHandler, error)
• type Config
• type Controller
  • func NewController() *Controller
  • func (c *Controller) AllWorkers() []string
  • func (c *Controller) Check(cfg interface{}) (profession, name, driver, desc string, err error)
  • func (c *Controller) ConfigType() reflect.Type
  • func (c *Controller) Del(id string)
  • func (c *Controller) Get() interface{}
  • func (c *Controller) Mode() eosc.SettingMode
  • func (c *Controller) Set(conf interface{}) (err error)
  • func (c *Controller) Store(id string)
• type IController

Constants

const Name = "strategy-cache"

Functions

func Register

func Register(register eosc.IExtenderDriverRegister)

Register 注册http路由驱动工厂

Types

type ActuatorSet

type ActuatorSet interface {
	Set(string, *CacheValidTimeHandler)
	Del(id string)
}

type CacheGetCompleteHandler

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

func NewCacheGetCompleteHandler

func NewCacheGetCompleteHandler(orgHandler eocontext.CompleteHandler, validTime int, uri string) *CacheGetCompleteHandler

func (*CacheGetCompleteHandler) Complete

func (c *CacheGetCompleteHandler) Complete(ctx eocontext.EoContext) error

type CacheValidTime

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

func (*CacheValidTime) CheckSkill

func (l *CacheValidTime) CheckSkill(skill string) bool

func (*CacheValidTime) Destroy

func (l *CacheValidTime) Destroy() error

func (*CacheValidTime) Id

func (l *CacheValidTime) Id() string

func (*CacheValidTime) Reset

func (l *CacheValidTime) Reset(v interface{}, workers map[eosc.RequireId]eosc.IWorker) error

func (*CacheValidTime) Start

func (l *CacheValidTime) Start() error

func (*CacheValidTime) Stop

func (l *CacheValidTime) Stop() error

type CacheValidTimeHandler

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

func NewCacheValidTimeHandler

func NewCacheValidTimeHandler(conf *Config) (*CacheValidTimeHandler, error)

type Config

type Config struct {
	Name        string                `json:"name" skip:"skip"`
	Description string                `json:"description" skip:"skip"`
	Stop        bool                  `json:"stop"`
	Priority    int                   `json:"priority" label:"优先级" description:"1-999"`
	Filters     strategy.FilterConfig `json:"filters" label:"过滤规则"`
	ValidTime   int                   `json:"valid_time" label:"有效期" description:"有效期"`
}

type Controller

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

func NewController

func NewController() *Controller

func (*Controller) AllWorkers

func (c *Controller) AllWorkers() []string

func (*Controller) Check

func (c *Controller) Check(cfg interface{}) (profession, name, driver, desc string, err error)

func (*Controller) ConfigType

func (c *Controller) ConfigType() reflect.Type

func (*Controller) Del

func (c *Controller) Del(id string)

func (*Controller) Get

func (c *Controller) Get() interface{}

func (*Controller) Mode

func (c *Controller) Mode() eosc.SettingMode

func (*Controller) Set

func (c *Controller) Set(conf interface{}) (err error)

func (*Controller) Store

func (c *Controller) Store(id string)

type IController

type IController interface {
	Store(id string)
	Del(id string)
}