nsq

Sep 4, 2023

Changes in this version

+ const Name

+ func Create(id, name string, conf *Config, workers map[eosc.RequireId]eosc.IWorker) (eosc.IWorker, error)

+ func NewFactory() eosc.IExtenderDriverFactory

+ func Register(register eosc.IExtenderDriverRegister)

+ type Config struct

+ Address []string

+ AuthSecret string

+ CountParamKey string

+ Params []*Param

+ PushMode string

+ Scopes []string

+ Topic string

+ type Counter struct

+ func NewCounter(key string, body interface{}, countExpr jp.Expr) *Counter

+ func (c *Counter) Add(count int64)

+ func (c *Counter) Count() int64

+ func (c *Counter) Generate(count int64) (interface{}, error)

+ func (c *Counter) Key() string

+ type CounterHandler struct

+ func (c *CounterHandler) Generate() ([][]byte, error)

+ func (c *CounterHandler) GetCounter(key string, variables map[string]string) ICounter

+ type ICounter interface

+ Add func(count int64)

+ Count func() int64

+ Generate func(count int64) (interface{}, error)

+ Key func() string

+ type Param struct

+ Key string

+ Type string

+ Value string