classify

Documentation

Index

• type CategoryHandler
• type Classify
  • func New() *Classify
  • func NewWithMode(mode string, handlers ...CategoryHandler) *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) Clear()
  • 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 MethodType
• type Streamer
  • func NewStreamer(mode string, handlers ...CategoryHandler) *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) Clear()
  • func (stream *Streamer) RangeCounted(do func(counted interface{}) bool)
  • func (stream *Streamer) SeekGE(item interface{}, iterfunc func(counted interface{}) bool)
  • func (stream *Streamer) SeekGEReverse(item interface{}, iterfunc func(counted interface{}) bool)
  • func (stream *Streamer) SetCountHandler(countHandler CountHandler) *Streamer
  • func (stream *Streamer) SetCreateCountedHandler(createHandler CreateCountedHandler) *Streamer

Types

type CategoryHandler

type CategoryHandler func(item interface{}) interface{}

CategoryHandler 处理结构体字段的返回值

type Classify

type Classify struct {
	Values *treequeue.Queue
	// contains filtered or unexported fields
}

分类

func New

func New() *Classify

func NewWithMode

func NewWithMode(mode string, handlers ...CategoryHandler) *Classify

func (*Classify) AddCategory

func (clsfy *Classify) AddCategory(name string, handler CategoryHandler) *Classify

func (*Classify) Build

func (clsfy *Classify) Build(mode string, handlers ...CategoryHandler)

func (*Classify) Categorys

func (clsfy *Classify) Categorys() string

func (*Classify) Clear

func (clsfy *Classify) Clear()

func (*Classify) Collect

func (clsfy *Classify) Collect()

func (*Classify) CollectCategory

func (clsfy *Classify) CollectCategory(handler CategoryHandler)

func (*Classify) Get

func (clsfy *Classify) Get(out interface{}, vPaths ...interface{})

func (*Classify) Keys

func (clsfy *Classify) Keys(paths ...interface{}) (result []interface{})

func (*Classify) Put

func (clsfy *Classify) Put(v interface{})

func (*Classify) PutSlice

func (clsfy *Classify) PutSlice(items interface{})

type CountHandler

type CountHandler func(counted interface{}, item interface{})

type CreateCountedHandler

type CreateCountedHandler func(item interface{}) interface{}

type MethodType

type MethodType int

1 是字段( 2 是方法< 3 结尾收集@

const (
	MT_UNKNOWN MethodType = 0 // 0 未知
	MT_FIELD   MethodType = 1 // 1 字段 KEY a-zA-Z
	MT_METHOD  MethodType = 2 // 2 方法 函数 <>
	MT_COLLECT MethodType = 3 // 3 收集操作 @
)

type Streamer

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

Streamer 流计算. 用于分段时间聚合, 分类聚合...等

func NewStreamer

func NewStreamer(mode string, handlers ...CategoryHandler) *Streamer

NewStreamer CreateCountedHandler CountHandler Add 都必须要使用地址传入

func (*Streamer) Add

func (stream *Streamer) Add(item interface{})

Add 添加到处理队列处理. 汇聚成counted. 通过 Seek RangeCounted获取结果

func (*Streamer) AddCategory

func (stream *Streamer) AddCategory(handler CategoryHandler) *Streamer

AddCategory 添加类别的处理方法

func (*Streamer) Build

func (stream *Streamer) Build(mode string, handlers ...CategoryHandler)

func (*Streamer) Clear

func (stream *Streamer) Clear()

func (*Streamer) RangeCounted

func (stream *Streamer) RangeCounted(do func(counted interface{}) bool)

RangeCounted 从小到大遍历 counted 对象

func (*Streamer) SeekGE

func (stream *Streamer) SeekGE(item interface{}, iterfunc func(counted interface{}) bool)

SeekGE 定位到 item 字节序列后的点. 然后从小到大遍历 [1 2 3] 参数为2 则 第一个item为2 [1 3] 参数为2 则 第一个item为3

func (*Streamer) SeekGEReverse

func (stream *Streamer) SeekGEReverse(item interface{}, iterfunc func(counted interface{}) bool)

Seek 定位到 item 字节序列后的点. 然后从大到小遍历 [1 2 3] 参数为2 则 第一个item为2 [1 3] 参数为2 则 第一个item为1.

func (*Streamer) SetCountHandler

func (stream *Streamer) SetCountHandler(countHandler CountHandler) *Streamer

SetCountHandler 设置计算过程

func (*Streamer) SetCreateCountedHandler

func (stream *Streamer) SetCreateCountedHandler(createHandler CreateCountedHandler) *Streamer

SetCreateCountedHandler 设置被计算生成的对象 通过所有Add item汇聚成handler 返回的结果