Documentation
¶
Index ¶
- type CategoryHandler
- type Classify
- func (clsfy *Classify) AddCategory(name string, handler CategoryHandler) *Classify
- func (clsfy *Classify) Build(mode string, handlers ...CategoryHandler)
- func (clsfy *Classify) Categorys() string
- func (clsfy *Classify) Collect()
- func (clsfy *Classify) CollectCategory(handler CategoryHandler)
- func (clsfy *Classify) Get(out interface{}, vPaths ...interface{})
- func (clsfy *Classify) Keys(paths ...interface{}) (result []interface{})
- func (clsfy *Classify) Put(v interface{})
- func (clsfy *Classify) PutSlice(items interface{})
- type CountHandler
- type CreateCountedHandler
- type Streamer
- func (stream *Streamer) Add(item interface{})
- func (stream *Streamer) AddCategory(handler CategoryHandler) *Streamer
- func (stream *Streamer) Build(mode string, handlers ...CategoryHandler)
- func (stream *Streamer) RangeItems(do func(item interface{}) bool)
- func (stream *Streamer) SetCountHandler(countHandler CountHandler) *Streamer
- func (stream *Streamer) SetCreateCountedHandler(createHandler CreateCountedHandler) *Streamer
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CategoryHandler ¶
type CategoryHandler func(item interface{}) interface{}
type Classify ¶
分类
func NewWithMode ¶ added in v1.0.3
func NewWithMode(mode string, handlers ...CategoryHandler) *Classify
func (*Classify) AddCategory ¶
func (clsfy *Classify) AddCategory(name string, handler CategoryHandler) *Classify
func (*Classify) Build ¶ added in v1.0.0
func (clsfy *Classify) Build(mode string, handlers ...CategoryHandler)
func (*Classify) CollectCategory ¶
func (clsfy *Classify) CollectCategory(handler CategoryHandler)
type CountHandler ¶ added in v1.1.0
type CountHandler func(counted interface{}, item interface{})
type CreateCountedHandler ¶ added in v1.1.0
type CreateCountedHandler func(item interface{}) interface{}
type Streamer ¶ added in v1.1.0
type Streamer struct {
// contains filtered or unexported fields
}
Streamer 流计算
func NewStreamer ¶ added in v1.1.0
func NewStreamer(mode string, handlers ...CategoryHandler) *Streamer
NewStreamer CreateCountedHandler CountHandler Add 都必须要使用地址传入
func (*Streamer) AddCategory ¶ added in v1.1.0
func (stream *Streamer) AddCategory(handler CategoryHandler) *Streamer
func (*Streamer) Build ¶ added in v1.1.0
func (stream *Streamer) Build(mode string, handlers ...CategoryHandler)
func (*Streamer) RangeItems ¶ added in v1.1.0
func (*Streamer) SetCountHandler ¶ added in v1.1.0
func (stream *Streamer) SetCountHandler(countHandler CountHandler) *Streamer
func (*Streamer) SetCreateCountedHandler ¶ added in v1.1.0
func (stream *Streamer) SetCreateCountedHandler(createHandler CreateCountedHandler) *Streamer
Click to show internal directories.
Click to hide internal directories.