netmap

Oct 11, 2019

Changes in this version

type Aggregator

+ func NewMaxAgg() Aggregator

type Normalizer

+ func NewConstNorm(value float64) Normalizer

+ func NewMaxNorm(max float64) Normalizer

+ func NewReverseMinNorm(min float64) Normalizer

+ func NewSigmoidNorm(scale float64) Normalizer

Oct 2, 2019

Changes in this version

+ func PriceWeightFunc(n Node) float64

type Aggregator

+ func NewMeanAgg() Aggregator

+ func NewMeanIQRAgg() Aggregator

+ func NewMeanSumAgg() Aggregator

+ func NewMinAgg() Aggregator

+ Clear func()

+ type AggregatorFactory struct

+ New func() Aggregator

type Bucket

+ func (b *Bucket) TraverseTree(af AggregatorFactory, wf WeightFunc)

Sep 9, 2019

Changes in this version

type Filter

+ func (m *Filter) MarshalToSizedBuffer(dAtA []byte) (int, error)

type PlacementRule

+ func (m *PlacementRule) MarshalToSizedBuffer(dAtA []byte) (int, error)

type SFGroup

+ func (m *SFGroup) MarshalToSizedBuffer(dAtA []byte) (int, error)

type Select

+ func (m *Select) MarshalToSizedBuffer(dAtA []byte) (int, error)

type SimpleFilter

+ func (*SimpleFilter) XXX_OneofWrappers() []interface{}

+ func (m *SimpleFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

type SimpleFilter_FArgs

+ func (m *SimpleFilter_FArgs) MarshalToSizedBuffer(dAtA []byte) (int, error)

type SimpleFilter_Value

+ func (m *SimpleFilter_Value) MarshalToSizedBuffer(dAtA []byte) (int, error)

type SimpleFilters

+ func (m *SimpleFilters) MarshalToSizedBuffer(dAtA []byte) (int, error)

Jul 23, 2019

Changes in this version

+ func CapWeightFunc(n Node) float64

+ type Aggregator interface

+ Add func(Node)

+ Compute func() float64

type Bucket

+ func (b *Bucket) Traverse(a Aggregator) Aggregator

type Node

+ C uint64

+ P uint64

+ type Normalizer interface

+ Normalize func(w float64) float64

+ type WeightFunc = func(n Node) float64

+ func NewWeightFunc(capNorm, priceNorm Normalizer) WeightFunc

May 30, 2019

Changes in this version

type Bucket

+ func (b *Bucket) AddStrawNode(n Node, opts ...string) error

+ type Node struct

+ N uint32

+ W uint64

+ func (n *Node) Read(r io.Reader) error

+ func (n Node) Hash() uint64

+ func (n Node) Write(w io.Writer) error

+ type Nodes []Node

+ func (n *Nodes) Read(r io.Reader) error

+ func (n Nodes) Len() int

+ func (n Nodes) Less(i, j int) bool

+ func (n Nodes) Nodes() []uint32

+ func (n Nodes) Swap(i, j int)

+ func (n Nodes) Weights() []uint64

+ func (n Nodes) Write(w io.Writer) error

Apr 5, 2019

Changes in this version

type SFGroup

+ Exclude []uint32

+ func (m *SFGroup) GetExclude() []uint32

Feb 8, 2019

Changes in this version

+ type Uint32Slice []uint32

+ func (p Uint32Slice) Len() int

+ func (p Uint32Slice) Less(i, j int) bool

+ func (p Uint32Slice) Swap(i, j int)

Feb 7, 2019

Changes in this version

+ const NodesBucket

+ const Separator

+ var ErrIntOverflowSelector = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthSelector = fmt.Errorf("proto: negative length found during unmarshaling")

+ var Operation_name = map[int32]string

+ var Operation_value = map[string]int32

+ var Type_name = map[int32]string

+ var Type_value = map[string]int32

+ type Bucket struct

+ Key string

+ Value string

+ func (b *Bucket) AddBucket(o string, n []int32) error

+ func (b *Bucket) AddChild(c Bucket)

+ func (b *Bucket) AddNode(n int32, opts ...string) error

+ func (b *Bucket) FindGraph(pivot []byte, ss ...SFGroup) (c *Bucket)

+ func (b *Bucket) FindNodes(pivot []byte, ss ...SFGroup) (nodes []int32)

+ func (b *Bucket) Merge(b1 Bucket)

+ func (b *Bucket) Read(r io.Reader) error

+ func (b *Bucket) UnmarshalBinary(data []byte) (err error)

+ func (b *Bucket) UpdateIndices(tr map[int32]int32) Bucket

+ func (b Bucket) CheckConflicts(b1 Bucket) bool

+ func (b Bucket) Children() []Bucket

+ func (b Bucket) Copy() Bucket

+ func (b Bucket) Dump(name string) error

+ func (b Bucket) DumpWithSelection(name string, b1 Bucket) error

+ func (b Bucket) Equals(b1 Bucket) bool

+ func (b Bucket) GetMaxSelection(ss []Select, fs []Filter) (r *Bucket)

+ func (b Bucket) GetNodesByOption(opts ...string) []int32

+ func (b Bucket) GetSelection(ss []Select, pivot []byte) *Bucket

+ func (b Bucket) Hash() uint64

+ func (b Bucket) IsValid() bool

+ func (b Bucket) MarshalBinary() ([]byte, error)

+ func (b Bucket) Name() string

+ func (b Bucket) Nodelist() (r []int32)

+ func (b Bucket) Sdump() (string, error)

+ func (b Bucket) SdumpWithSelection(b1 Bucket) (string, error)

+ func (b Bucket) Write(w io.Writer) error

+ type Filter struct

+ F *SimpleFilter

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Filter) Descriptor() ([]byte, []int)

+ func (*Filter) ProtoMessage()

+ func (f Filter) Check(b Bucket) bool

+ func (f Filter) Filter(bs ...Bucket) []Bucket

+ func (m *Filter) GetF() *SimpleFilter

+ func (m *Filter) GetKey() string

+ func (m *Filter) Marshal() (dAtA []byte, err error)

+ func (m *Filter) MarshalTo(dAtA []byte) (int, error)

+ func (m *Filter) Reset()

+ func (m *Filter) Size() (n int)

+ func (m *Filter) String() string

+ func (m *Filter) Unmarshal(dAtA []byte) error

+ func (m *Filter) XXX_DiscardUnknown()

+ func (m *Filter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Filter) XXX_Merge(src proto.Message)

+ func (m *Filter) XXX_Size() int

+ func (m *Filter) XXX_Unmarshal(b []byte) error

+ type FilterFunc func([]int32) []int32

+ type Graph = *gographviz.Graph

+ type Int32Slice []int32

+ func (p Int32Slice) Len() int

+ func (p Int32Slice) Less(i, j int) bool

+ func (p Int32Slice) Swap(i, j int)

+ type Operation int32

+ const Operation_AND

+ const Operation_EQ

+ const Operation_GE

+ const Operation_GT

+ const Operation_LE

+ const Operation_LT

+ const Operation_NE

+ const Operation_NP

+ const Operation_OR

+ func (Operation) EnumDescriptor() ([]byte, []int)

+ func (x Operation) String() string

+ type PlacementRule struct

+ ReplFactor uint32

+ SFGroups []SFGroup

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PlacementRule) Descriptor() ([]byte, []int)

+ func (*PlacementRule) ProtoMessage()

+ func (m *PlacementRule) GetReplFactor() uint32

+ func (m *PlacementRule) GetSFGroups() []SFGroup

+ func (m *PlacementRule) Marshal() (dAtA []byte, err error)

+ func (m *PlacementRule) MarshalTo(dAtA []byte) (int, error)

+ func (m *PlacementRule) Reset()

+ func (m *PlacementRule) Size() (n int)

+ func (m *PlacementRule) String() string

+ func (m *PlacementRule) Unmarshal(dAtA []byte) error

+ func (m *PlacementRule) XXX_DiscardUnknown()

+ func (m *PlacementRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PlacementRule) XXX_Merge(src proto.Message)

+ func (m *PlacementRule) XXX_Size() int

+ func (m *PlacementRule) XXX_Unmarshal(b []byte) error

+ type Policy struct

+ NodeCount int

+ ReplFactor int

+ Size int64

+ type SFGroup struct

+ Filters []Filter

+ Selectors []Select

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SFGroup) Descriptor() ([]byte, []int)

+ func (*SFGroup) ProtoMessage()

+ func (m *SFGroup) GetFilters() []Filter

+ func (m *SFGroup) GetSelectors() []Select

+ func (m *SFGroup) Marshal() (dAtA []byte, err error)

+ func (m *SFGroup) MarshalTo(dAtA []byte) (int, error)

+ func (m *SFGroup) Reset()

+ func (m *SFGroup) Size() (n int)

+ func (m *SFGroup) String() string

+ func (m *SFGroup) Unmarshal(dAtA []byte) error

+ func (m *SFGroup) XXX_DiscardUnknown()

+ func (m *SFGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SFGroup) XXX_Merge(src proto.Message)

+ func (m *SFGroup) XXX_Size() int

+ func (m *SFGroup) XXX_Unmarshal(b []byte) error

+ type Select struct

+ Count uint32

+ Key string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*Select) Descriptor() ([]byte, []int)

+ func (*Select) ProtoMessage()

+ func (m *Select) GetCount() uint32

+ func (m *Select) GetKey() string

+ func (m *Select) Marshal() (dAtA []byte, err error)

+ func (m *Select) MarshalTo(dAtA []byte) (int, error)

+ func (m *Select) Reset()

+ func (m *Select) Size() (n int)

+ func (m *Select) String() string

+ func (m *Select) Unmarshal(dAtA []byte) error

+ func (m *Select) XXX_DiscardUnknown()

+ func (m *Select) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Select) XXX_Merge(src proto.Message)

+ func (m *Select) XXX_Size() int

+ func (m *Select) XXX_Unmarshal(b []byte) error

+ type SimpleFilter struct

+ Args isSimpleFilter_Args

+ Op Operation

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func FilterAND(fs ...*SimpleFilter) *SimpleFilter

+ func FilterEQ(v string) *SimpleFilter

+ func FilterGE(v int64) *SimpleFilter

+ func FilterGT(v int64) *SimpleFilter

+ func FilterIn(values ...string) *SimpleFilter

+ func FilterLE(v int64) *SimpleFilter

+ func FilterLT(v int64) *SimpleFilter

+ func FilterNE(v string) *SimpleFilter

+ func FilterNotIn(values ...string) *SimpleFilter

+ func FilterOR(fs ...*SimpleFilter) *SimpleFilter

+ func NewFilter(op Operation, value string) *SimpleFilter

+ func (*SimpleFilter) Descriptor() ([]byte, []int)

+ func (*SimpleFilter) ProtoMessage()

+ func (*SimpleFilter) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *SimpleFilter) GetArgs() isSimpleFilter_Args

+ func (m *SimpleFilter) GetFArgs() *SimpleFilters

+ func (m *SimpleFilter) GetOp() Operation

+ func (m *SimpleFilter) GetValue() string

+ func (m *SimpleFilter) Marshal() (dAtA []byte, err error)

+ func (m *SimpleFilter) MarshalTo(dAtA []byte) (int, error)

+ func (m *SimpleFilter) Reset()

+ func (m *SimpleFilter) Size() (n int)

+ func (m *SimpleFilter) String() string

+ func (m *SimpleFilter) Unmarshal(dAtA []byte) error

+ func (m *SimpleFilter) XXX_DiscardUnknown()

+ func (m *SimpleFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SimpleFilter) XXX_Merge(src proto.Message)

+ func (m *SimpleFilter) XXX_Size() int

+ func (m *SimpleFilter) XXX_Unmarshal(b []byte) error

+ func (sf SimpleFilter) Check(value string) bool

+ type SimpleFilter_FArgs struct

+ FArgs *SimpleFilters

+ func (m *SimpleFilter_FArgs) MarshalTo(dAtA []byte) (int, error)

+ func (m *SimpleFilter_FArgs) Size() (n int)

+ type SimpleFilter_Value struct

+ Value string

+ func (m *SimpleFilter_Value) MarshalTo(dAtA []byte) (int, error)

+ func (m *SimpleFilter_Value) Size() (n int)

+ type SimpleFilters struct

+ Filters []*SimpleFilter

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*SimpleFilters) Descriptor() ([]byte, []int)

+ func (*SimpleFilters) ProtoMessage()

+ func (m *SimpleFilters) GetFilters() []*SimpleFilter

+ func (m *SimpleFilters) Marshal() (dAtA []byte, err error)

+ func (m *SimpleFilters) MarshalTo(dAtA []byte) (int, error)

+ func (m *SimpleFilters) Reset()

+ func (m *SimpleFilters) Size() (n int)

+ func (m *SimpleFilters) String() string

+ func (m *SimpleFilters) Unmarshal(dAtA []byte) error

+ func (m *SimpleFilters) XXX_DiscardUnknown()

+ func (m *SimpleFilters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SimpleFilters) XXX_Merge(src proto.Message)

+ func (m *SimpleFilters) XXX_Size() int

+ func (m *SimpleFilters) XXX_Unmarshal(b []byte) error

+ type Type int32

+ const Type_Integer

+ const Type_String

+ func (Type) EnumDescriptor() ([]byte, []int)

+ func (x Type) String() string