ntops

Documentation

Index

• Variables
• func EncodePair(k, v []byte) []byte
• type GroupEntry
  • func (g *GroupEntry) DecodeMsgpack(src *msgpack.Decoder) error
  • func (g *GroupEntry) EncodeMsgpack(dst *msgpack.Encoder) error
  • func (g *GroupEntry) Marshal() []byte
  • func (g *GroupEntry) Unmarshal(u []byte) error
• type GroupExpired
• type GroupOps
  • func (GroupOps) Consistent(p []byte, q interface{}) bool
  • func (g GroupOps) FirstSplit(P newtree.Elements, maxsize int) (newtree.Elements, newtree.Elements)
  • func (GroupOps) Penalty(E1, E2 []byte) (F float64)
  • func (GroupOps) Sort(E newtree.Elements)
  • func (GroupOps) Union(P newtree.Elements) []byte
• type GroupQuery
  • func (g *GroupQuery) ExtractGroupCount(b []byte) (uint64, bool)
• type StrOps
  • func (s StrOps) Consistent(p []byte, q interface{}) bool
  • func (s StrOps) FirstSplit(P newtree.Elements, maxsize int) (newtree.Elements, newtree.Elements)
  • func (s StrOps) Penalty(E1, E2 []byte) float64
  • func (s StrOps) Sort(E newtree.Elements)
  • func (s StrOps) Union(P newtree.Elements) []byte
• type StrRange

Variables

var EIsSumary = errors.New("IsSumary")

var GroupOpsImpl newtree.TreeOps = GroupOps{}

var StrOpsImpl newtree.TreeOps = StrOps{}

Functions

func EncodePair

func EncodePair(k, v []byte) []byte

Types

type GroupEntry

type GroupEntry struct {
	GroupID uint64
	Article uint64
	Expires uint64
	Value   []byte
}

func (*GroupEntry) DecodeMsgpack

func (g *GroupEntry) DecodeMsgpack(src *msgpack.Decoder) error

func (*GroupEntry) EncodeMsgpack

func (g *GroupEntry) EncodeMsgpack(dst *msgpack.Encoder) error

func (*GroupEntry) Marshal

func (g *GroupEntry) Marshal() []byte

func (*GroupEntry) Unmarshal

func (g *GroupEntry) Unmarshal(u []byte) error

type GroupExpired

type GroupExpired struct {
	Timestamp uint64
}

type GroupOps

type GroupOps struct{}

func (GroupOps) Consistent

func (GroupOps) Consistent(p []byte, q interface{}) bool

func (GroupOps) FirstSplit

func (g GroupOps) FirstSplit(P newtree.Elements, maxsize int) (newtree.Elements, newtree.Elements)

func (GroupOps) Penalty

func (GroupOps) Penalty(E1, E2 []byte) (F float64)

func (GroupOps) Sort

func (GroupOps) Sort(E newtree.Elements)

func (GroupOps) Union

func (GroupOps) Union(P newtree.Elements) []byte

type GroupQuery

type GroupQuery struct {
	GroupID     uint64
	ArticleLow  uint64
	ArticleHigh uint64
}

func (*GroupQuery) ExtractGroupCount

func (g *GroupQuery) ExtractGroupCount(b []byte) (uint64, bool)

type StrOps

type StrOps struct{}

func (StrOps) Consistent

func (s StrOps) Consistent(p []byte, q interface{}) bool

func (StrOps) FirstSplit

func (s StrOps) FirstSplit(P newtree.Elements, maxsize int) (newtree.Elements, newtree.Elements)

func (StrOps) Penalty

func (s StrOps) Penalty(E1, E2 []byte) float64

func (StrOps) Sort

func (s StrOps) Sort(E newtree.Elements)

func (StrOps) Union

func (s StrOps) Union(P newtree.Elements) []byte

type StrRange

type StrRange struct {
	Low, High []byte
}