index

Documentation

Index

• func PrepareEnvelope(envelope *spec.Envelope) error
• type DateCache
  • func NewDateCache() *DateCache
  • func (d *DateCache) Expand(t time.Time) (string, string, string, string)
• type Indexable
  • func (x *Indexable) DocumentID() int32
  • func (x *Indexable) IndexableFields() map[string][]string
• type SearchIndex
  • func NewSearchIndex(root string, nOpenFD int, segmentStep int64, enableSegmentCache bool, ...) *SearchIndex
  • func (m *SearchIndex) Close()
  • func (m *SearchIndex) ExpandFromTo(from uint32, to uint32) []int64
  • func (m *SearchIndex) ForEach(qr *spec.SearchQueryRequest, limit uint32, ...) error
  • func (m *SearchIndex) Ingest(envelope *spec.Envelope) error
  • func (m *SearchIndex) ListSegments() ([]int64, error)
  • func (m *SearchIndex) LookupSingleSegment(ns int64) *Segment
• type Segment
  • func NewSegment(root string, fdc dsl.FileDescriptorCache, enableCache bool, ...) (*Segment, error)
  • func (s *Segment) Close()
  • func (s *Segment) Ingest(envelope *spec.Envelope) error
  • func (s *Segment) OpenForwardIndex() error
  • func (s *Segment) ReadForward(did int32) ([]byte, error)
  • func (s *Segment) ReadForwardDecode(did int32, m proto.Message) error
• type YM
• type YMD
• type YMDH

Functions

func PrepareEnvelope

func PrepareEnvelope(envelope *spec.Envelope) error

Types

type DateCache

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

func NewDateCache

func NewDateCache() *DateCache

func (*DateCache) Expand

func (d *DateCache) Expand(t time.Time) (string, string, string, string)

type Indexable

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

func (*Indexable) DocumentID

func (x *Indexable) DocumentID() int32

func (*Indexable) IndexableFields

func (x *Indexable) IndexableFields() map[string][]string

type SearchIndex

type SearchIndex struct {
	Segments map[string]*Segment

	SegmentStep int64

	sync.RWMutex
	// contains filtered or unexported fields
}

func NewSearchIndex

func NewSearchIndex(root string, nOpenFD int, segmentStep int64, enableSegmentCache bool, whitelist map[string]bool) *SearchIndex

func (*SearchIndex) Close

func (m *SearchIndex) Close()

func (*SearchIndex) ExpandFromTo

func (m *SearchIndex) ExpandFromTo(from uint32, to uint32) []int64

func (*SearchIndex) ForEach

func (m *SearchIndex) ForEach(qr *spec.SearchQueryRequest, limit uint32, cb func(*Segment, int32, float32) error) error

func (*SearchIndex) Ingest

func (m *SearchIndex) Ingest(envelope *spec.Envelope) error

func (*SearchIndex) ListSegments

func (m *SearchIndex) ListSegments() ([]int64, error)

func (*SearchIndex) LookupSingleSegment

func (m *SearchIndex) LookupSingleSegment(ns int64) *Segment

type Segment

type Segment struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSegment

func NewSegment(root string, fdc dsl.FileDescriptorCache, enableCache bool, whitelist map[string]bool) (*Segment, error)

func (*Segment) Close

func (s *Segment) Close()

func (*Segment) Ingest

func (s *Segment) Ingest(envelope *spec.Envelope) error

func (*Segment) OpenForwardIndex

func (s *Segment) OpenForwardIndex() error

func (*Segment) ReadForward

func (s *Segment) ReadForward(did int32) ([]byte, error)

func (*Segment) ReadForwardDecode

func (s *Segment) ReadForwardDecode(did int32, m proto.Message) error

type YM

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

yes this is 10% improvement

type YMD

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

type YMDH

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