pilosa

package module

Go to main page

Versions in this module

v0

v0.4.0

Jun 8, 2017

Changes in this version

+ const DefaultMaxWritesPerRequest

+ const DefaultMetrics

+ var BuildTime = "not recorded"

+ var ErrColumnRowLabelEqual = errors.New("column and row labels cannot be equal")

+ var ErrTooManyWrites = errors.New("too many write commands")

+ var Version = "v0.0.0"

+ func EncodeIndexes(a []*Index) []*internal.Index

type Cache

+ SetStats func(s StatsClient)

type Cluster

+ LongQueryTime time.Duration

type Config

+ MaxWritesPerRequest int

+ Metric struct{ ... }

type Duration

+ func (d Duration) MarshalTOML() ([]byte, error)

type Executor

+ MaxWritesPerRequest int

type ExpvarStatsClient

+ func (c *ExpvarStatsClient) CountWithCustomTags(name string, value int64, rate float64, tags []string)

+ func (c *ExpvarStatsClient) SetLogger(logger io.Writer)

type Fragment

+ CacheSize uint32

+ CacheType string

type Frame

+ Stats StatsClient

type Index

+ Stats StatsClient

type LRUCache

+ func (c *LRUCache) SetStats(s StatsClient)

type MultiStatsClient

+ func (a MultiStatsClient) CountWithCustomTags(name string, value int64, rate float64, tags []string)

+ func (a MultiStatsClient) SetLogger(logger io.Writer)

type RankCache

+ func (c *RankCache) SetStats(s StatsClient)

type Server

+ MaxWritesPerRequest int

+ MetricInterval time.Duration

+ Network string

type StatsClient

+ CountWithCustomTags func(name string, value int64, rate float64, tags []string)

+ SetLogger func(logger io.Writer)

v0.3.2

May 10, 2017

v0.3.1

Apr 30, 2017

Changes in this version

+ const AttrBlockSize

+ const AttrTypeBool

+ const AttrTypeFloat

+ const AttrTypeInt

+ const AttrTypeString

+ const CacheExt

+ const CacheTypeLRU

+ const CacheTypeRanked

+ const CopyExt

+ const DefaultAntiEntropyInterval

+ const DefaultCacheFlushInterval

+ const DefaultCacheSize

+ const DefaultCacheType

+ const DefaultClusterType

+ const DefaultColumnLabel

+ const DefaultFragmentMaxOpN

+ const DefaultFrame

+ const DefaultHost

+ const DefaultInternalPort

+ const DefaultInverseEnabled

+ const DefaultPartitionN

+ const DefaultPollingInterval

+ const DefaultPort

+ const DefaultReplicaN

+ const DefaultRowLabel

+ const HashBlockSize

+ const MessageTypeCreateFrame

+ const MessageTypeCreateIndex

+ const MessageTypeCreateSlice

+ const MessageTypeDeleteFrame

+ const MessageTypeDeleteIndex

+ const MinThreshold

+ const NodeStateDown

+ const NodeStateUp

+ const SliceWidth

+ const SnapshotExt

+ const ThresholdFactor

+ const TimeFormat

+ const ViewInverse

+ const ViewStandard

+ var ErrFragmentNotFound = errors.New("fragment not found")

+ var ErrFrameExists = errors.New("frame already exists")

+ var ErrFrameInverseDisabled = errors.New("frame inverse disabled")

+ var ErrFrameNotFound = errors.New("frame not found")

+ var ErrFrameRequired = errors.New("frame required")

+ var ErrHostRequired = errors.New("host required")

+ var ErrIndexExists = errors.New("index already exists")

+ var ErrIndexNotFound = errors.New("index not found")

+ var ErrIndexRequired = errors.New("index required")

+ var ErrInvalidCacheType = errors.New("invalid cache type")

+ var ErrInvalidTimeQuantum = errors.New("invalid time quantum")

+ var ErrInvalidView = errors.New("invalid view")

+ var ErrLabel = errors.New("invalid row or column label, must match [A-Za-z0-9_-]")

+ var ErrName = errors.New("invalid index or frame's name, must match [a-z0-9_-]")

+ var ErrQueryRequired = errors.New("query required")

+ var Expvar = expvar.NewMap("index")

+ var NopBroadcastReceiver = &nopBroadcastReceiver

+ func IsInverseView(name string) bool

+ func IsValidCacheType(v string) bool

+ func IsValidView(name string) bool

+ func MarshalImportPayload(index, frame string, slice uint64, bits []Bit) ([]byte, error)

+ func MarshalMessage(m proto.Message) ([]byte, error)

+ func NewRouter(handler *Handler) *mux.Router

+ func Pos(rowID, columnID uint64) uint64

+ func UnionStringSlice(a, b []string) []string

+ func UnmarshalMessage(buf []byte) (proto.Message, error)

+ func ValidateLabel(label string) error

+ func ValidateName(name string) error

+ func ViewByTimeUnit(name string, t time.Time, unit rune) string

+ func ViewsByTime(name string, t time.Time, q TimeQuantum) []string

+ func ViewsByTimeRange(name string, start, end time.Time, q TimeQuantum) []string

+ type AttrBlock struct

+ Checksum []byte

+ ID uint64

+ type AttrBlocks []AttrBlock

+ func (a AttrBlocks) Diff(other []AttrBlock) []uint64

+ type AttrStore struct

+ func NewAttrStore(path string) *AttrStore

+ func (s *AttrStore) Attrs(id uint64) (m map[string]interface{}, err error)

+ func (s *AttrStore) BlockData(i uint64) (map[uint64]map[string]interface{}, error)

+ func (s *AttrStore) Blocks() ([]AttrBlock, error)

+ func (s *AttrStore) Close() error

+ func (s *AttrStore) Open() error

+ func (s *AttrStore) Path() string

+ func (s *AttrStore) SetAttrs(id uint64, m map[string]interface{}) error

+ func (s *AttrStore) SetBulkAttrs(m map[uint64]map[string]interface{}) error

+ type Bit struct

+ ColumnID uint64

+ RowID uint64

+ Timestamp int64

+ type Bitmap struct

+ Attrs map[string]interface{}

+ func NewBitmap(bits ...uint64) *Bitmap

+ func Union(bitmaps []*Bitmap) *Bitmap

+ func (b *Bitmap) Bits() []uint64

+ func (b *Bitmap) ClearBit(i uint64) (changed bool)

+ func (b *Bitmap) Count() uint64

+ func (b *Bitmap) DecrementCount(i uint64)

+ func (b *Bitmap) Difference(other *Bitmap) *Bitmap

+ func (b *Bitmap) IncrementCount(i uint64)

+ func (b *Bitmap) Intersect(other *Bitmap) *Bitmap

+ func (b *Bitmap) IntersectionCount(other *Bitmap) uint64

+ func (b *Bitmap) InvalidateCount()

+ func (b *Bitmap) MarshalJSON() ([]byte, error)

+ func (b *Bitmap) Merge(other *Bitmap)

+ func (b *Bitmap) SetBit(i uint64) (changed bool)

+ func (b *Bitmap) Union(other *Bitmap) *Bitmap

+ type BitmapCache interface

+ Add func(id uint64, b *Bitmap)

+ Fetch func(id uint64) (*Bitmap, bool)

+ type BitmapPair struct

+ Count uint64

+ ID uint64

+ type BitmapPairs []BitmapPair

+ func (p BitmapPairs) Len() int

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

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

+ type BitmapSegment struct

+ func (s *BitmapSegment) Bits() []uint64

+ func (s *BitmapSegment) ClearBit(i uint64) (changed bool)

+ func (s *BitmapSegment) Count() uint64

+ func (s *BitmapSegment) Difference(other *BitmapSegment) *BitmapSegment

+ func (s *BitmapSegment) Intersect(other *BitmapSegment) *BitmapSegment

+ func (s *BitmapSegment) IntersectionCount(other *BitmapSegment) uint64

+ func (s *BitmapSegment) InvalidateCount()

+ func (s *BitmapSegment) Merge(other *BitmapSegment)

+ func (s *BitmapSegment) SetBit(i uint64) (changed bool)

+ func (s *BitmapSegment) Union(other *BitmapSegment) *BitmapSegment

+ type Bits []Bit

+ func (p Bits) ColumnIDs() []uint64

+ func (p Bits) GroupBySlice() map[uint64][]Bit

+ func (p Bits) Len() int

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

+ func (p Bits) RowIDs() []uint64

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

+ func (p Bits) Timestamps() []int64

+ type BitsByPos []Bit

+ func (p BitsByPos) Len() int

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

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

+ type BroadcastHandler interface

+ ReceiveMessage func(pb proto.Message) error

+ type BroadcastReceiver interface

+ Start func(BroadcastHandler) error

+ type Broadcaster interface

+ SendAsync func(pb proto.Message) error

+ SendSync func(pb proto.Message) error

+ var NopBroadcaster Broadcaster

+ type BufIterator struct

+ func NewBufIterator(itr Iterator) *BufIterator

+ func (itr *BufIterator) Next() (rowID, columnID uint64, eof bool)

+ func (itr *BufIterator) Peek() (rowID, columnID uint64, eof bool)

+ func (itr *BufIterator) Seek(rowID, columnID uint64)

+ func (itr *BufIterator) Unread()

+ type Cache interface

+ Add func(id uint64, n uint64)

+ BulkAdd func(id uint64, n uint64)

+ Get func(id uint64) uint64

+ IDs func() []uint64

+ Invalidate func()

+ Len func() int

+ Recalculate func()

+ Top func() []BitmapPair

+ type Client struct

+ HTTPClient *http.Client

+ func NewClient(host string) (*Client, error)

+ func (c *Client) BackupSlice(ctx context.Context, index, frame, view string, slice uint64) (io.ReadCloser, error)

+ func (c *Client) BackupTo(ctx context.Context, w io.Writer, index, frame, view string) error

+ func (c *Client) BlockData(ctx context.Context, index, frame, view string, slice uint64, block int) ([]uint64, []uint64, error)

+ func (c *Client) ColumnAttrDiff(ctx context.Context, index string, blks []AttrBlock) (map[uint64]map[string]interface{}, error)

+ func (c *Client) CreateFrame(ctx context.Context, index, frame string, opt FrameOptions) error

+ func (c *Client) CreateIndex(ctx context.Context, index string, opt IndexOptions) error

+ func (c *Client) ExecutePQL(ctx context.Context, index, query string) (interface{}, error)

+ func (c *Client) ExecuteQuery(ctx context.Context, index, query string, allowRedirect bool) (result interface{}, err error)

+ func (c *Client) ExportCSV(ctx context.Context, index, frame string, slice uint64, w io.Writer) error

+ func (c *Client) FragmentBlocks(ctx context.Context, index, frame, view string, slice uint64) ([]FragmentBlock, error)

+ func (c *Client) FragmentNodes(ctx context.Context, index string, slice uint64) ([]*Node, error)

+ func (c *Client) FrameViews(ctx context.Context, index, frame string) ([]string, error)

+ func (c *Client) Host() string

+ func (c *Client) Import(ctx context.Context, index, frame string, slice uint64, bits []Bit) error

+ func (c *Client) MaxInverseSliceByIndex(ctx context.Context) (map[string]uint64, error)

+ func (c *Client) MaxSliceByIndex(ctx context.Context) (map[string]uint64, error)

+ func (c *Client) RestoreFrame(ctx context.Context, host, index, frame string) error

+ func (c *Client) RestoreFrom(ctx context.Context, r io.Reader, index, frame, view string) error

+ func (c *Client) RowAttrDiff(ctx context.Context, index, frame string, blks []AttrBlock) (map[uint64]map[string]interface{}, error)

+ func (c *Client) Schema(ctx context.Context) ([]*IndexInfo, error)

+ type Cluster struct

+ Hasher Hasher

+ NodeSet NodeSet

+ Nodes []*Node

+ PartitionN int

+ ReplicaN int

+ func NewCluster() *Cluster

+ func (c *Cluster) FragmentNodes(index string, slice uint64) []*Node

+ func (c *Cluster) NodeByHost(host string) *Node

+ func (c *Cluster) NodeSetHosts() []string

+ func (c *Cluster) NodeStates() map[string]string

+ func (c *Cluster) OwnsFragment(host string, index string, slice uint64) bool

+ func (c *Cluster) OwnsSlices(index string, maxSlice uint64, host string) []uint64

+ func (c *Cluster) Partition(index string, slice uint64) int

+ func (c *Cluster) PartitionNodes(partitionID int) []*Node

+ func (c *Cluster) Status() *internal.ClusterStatus

+ type CmdIO struct

+ Stderr io.Writer

+ Stdin io.Reader

+ Stdout io.Writer

+ func NewCmdIO(stdin io.Reader, stdout, stderr io.Writer) *CmdIO

+ type ColumnAttrSet struct

+ Attrs map[string]interface{}

+ ID uint64

+ type Config struct

+ AntiEntropy struct{ ... }

+ Cluster struct{ ... }

+ DataDir string

+ Host string

+ LogPath string

+ Plugins struct{ ... }

+ func NewConfig() *Config

+ type Duration time.Duration

+ func (d *Duration) UnmarshalText(text []byte) error

+ func (d Duration) MarshalText() (text []byte, err error)

+ func (d Duration) String() string

+ type ExecOptions struct

+ Remote bool

+ type Executor struct

+ Cluster *Cluster

+ HTTPClient *http.Client

+ Holder *Holder

+ Host string

+ func NewExecutor() *Executor

+ func (e *Executor) Execute(ctx context.Context, index string, q *pql.Query, slices []uint64, ...) ([]interface{}, error)

+ type ExpvarStatsClient struct

+ func NewExpvarStatsClient() *ExpvarStatsClient

+ func (c *ExpvarStatsClient) Count(name string, value int64)

+ func (c *ExpvarStatsClient) Gauge(name string, value float64)

+ func (c *ExpvarStatsClient) Histogram(name string, value float64)

+ func (c *ExpvarStatsClient) Set(name string, value string)

+ func (c *ExpvarStatsClient) Tags() []string

+ func (c *ExpvarStatsClient) Timing(name string, value time.Duration)

+ func (c *ExpvarStatsClient) WithTags(tags ...string) StatsClient

+ type Fragment struct

+ LogOutput io.Writer

+ MaxOpN int

+ RowAttrStore *AttrStore

+ func NewFragment(path, index, frame, view string, slice uint64) *Fragment

+ func (f *Fragment) BlockData(id int) (rowIDs, columnIDs []uint64)

+ func (f *Fragment) BlockN() int

+ func (f *Fragment) Blocks() []FragmentBlock

+ func (f *Fragment) Cache() Cache

+ func (f *Fragment) CachePath() string

+ func (f *Fragment) Checksum() []byte

+ func (f *Fragment) ClearBit(rowID, columnID uint64) (bool, error)

+ func (f *Fragment) Close() error

+ func (f *Fragment) FlushCache() error

+ func (f *Fragment) ForEachBit(fn func(rowID, columnID uint64) error) error

+ func (f *Fragment) Frame() string

+ func (f *Fragment) Import(rowIDs, columnIDs []uint64) error

+ func (f *Fragment) Index() string

+ func (f *Fragment) InvalidateChecksums()

+ func (f *Fragment) MergeBlock(id int, data []PairSet) (sets, clears []PairSet, err error)

+ func (f *Fragment) Open() error

+ func (f *Fragment) Path() string

+ func (f *Fragment) ReadFrom(r io.Reader) (n int64, err error)

+ func (f *Fragment) RecalculateCache()

+ func (f *Fragment) Row(rowID uint64) *Bitmap

+ func (f *Fragment) SetBit(rowID, columnID uint64) (changed bool, err error)

+ func (f *Fragment) Slice() uint64

+ func (f *Fragment) Snapshot() error

+ func (f *Fragment) Top(opt TopOptions) ([]Pair, error)

+ func (f *Fragment) View() string

+ func (f *Fragment) WriteTo(w io.Writer) (n int64, err error)

+ type FragmentBlock struct

+ Checksum []byte

+ ID int

+ type FragmentSyncer struct

+ Closing <-chan struct{}

+ Cluster *Cluster

+ Fragment *Fragment

+ Host string

+ func (s *FragmentSyncer) SyncFragment() error

+ type Frame struct

+ LogOutput io.Writer

+ func NewFrame(path, index, name string) (*Frame, error)

+ func (f *Frame) CacheSize() uint32

+ func (f *Frame) CacheType() string

+ func (f *Frame) ClearBit(name string, rowID, colID uint64, t *time.Time) (changed bool, err error)

+ func (f *Frame) Close() error

+ func (f *Frame) CreateViewIfNotExists(name string) (*View, error)

+ func (f *Frame) Import(rowIDs, columnIDs []uint64, timestamps []*time.Time) error

+ func (f *Frame) Index() string

+ func (f *Frame) InverseEnabled() bool

+ func (f *Frame) MaxInverseSlice() uint64

+ func (f *Frame) MaxSlice() uint64

+ func (f *Frame) Name() string

+ func (f *Frame) Open() error

+ func (f *Frame) Options() FrameOptions

+ func (f *Frame) Path() string

+ func (f *Frame) RowAttrStore() *AttrStore

+ func (f *Frame) RowLabel() string

+ func (f *Frame) SetBit(name string, rowID, colID uint64, t *time.Time) (changed bool, err error)

+ func (f *Frame) SetCacheSize(v uint32) error

+ func (f *Frame) SetRowLabel(v string) error

+ func (f *Frame) SetTimeQuantum(q TimeQuantum) error

+ func (f *Frame) TimeQuantum() TimeQuantum

+ func (f *Frame) View(name string) *View

+ func (f *Frame) ViewPath(name string) string

+ func (f *Frame) Views() []*View

+ type FrameInfo struct

+ Name string

+ Views []*ViewInfo

+ type FrameOptions struct

+ CacheSize uint32

+ CacheType string

+ InverseEnabled bool

+ RowLabel string

+ TimeQuantum TimeQuantum

+ func (o *FrameOptions) Encode() *internal.FrameMeta

+ type Handler struct

+ Broadcaster Broadcaster

+ Cluster *Cluster

+ Executor interface{ ... }

+ Holder *Holder

+ Host string

+ LogOutput io.Writer

+ Router *mux.Router

+ StatusHandler StatusHandler

+ Version string

+ func NewHandler() *Handler

+ func (h *Handler) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type Hasher interface

+ Hash func(key uint64, n int) int

+ func NewHasher() Hasher

+ type Holder struct

+ Broadcaster Broadcaster

+ CacheFlushInterval time.Duration

+ LogOutput io.Writer

+ Path string

+ Stats StatsClient

+ func NewHolder() *Holder

+ func (h *Holder) Close() error

+ func (h *Holder) CreateIndex(name string, opt IndexOptions) (*Index, error)

+ func (h *Holder) CreateIndexIfNotExists(name string, opt IndexOptions) (*Index, error)

+ func (h *Holder) DeleteIndex(name string) error

+ func (h *Holder) Fragment(index, frame, view string, slice uint64) *Fragment

+ func (h *Holder) Frame(index, name string) *Frame

+ func (h *Holder) Index(name string) *Index

+ func (h *Holder) IndexPath(name string) string

+ func (h *Holder) Indexes() []*Index

+ func (h *Holder) MaxInverseSlices() map[string]uint64

+ func (h *Holder) MaxSlices() map[string]uint64

+ func (h *Holder) Open() error

+ func (h *Holder) Schema() []*IndexInfo

+ func (h *Holder) View(index, frame, name string) *View

+ type HolderSyncer struct

+ Closing <-chan struct{}

+ Cluster *Cluster

+ Holder *Holder

+ Host string

+ func (s *HolderSyncer) IsClosing() bool

+ func (s *HolderSyncer) SyncHolder() error

+ type Index struct

+ LogOutput io.Writer

+ func NewIndex(path, name string) (*Index, error)

+ func (i *Index) Close() error

+ func (i *Index) ColumnAttrStore() *AttrStore

+ func (i *Index) ColumnLabel() string

+ func (i *Index) CreateFrame(name string, opt FrameOptions) (*Frame, error)

+ func (i *Index) CreateFrameIfNotExists(name string, opt FrameOptions) (*Frame, error)

+ func (i *Index) DeleteFrame(name string) error

+ func (i *Index) Frame(name string) *Frame

+ func (i *Index) FramePath(name string) string

+ func (i *Index) Frames() []*Frame

+ func (i *Index) MaxInverseSlice() uint64

+ func (i *Index) MaxSlice() uint64

+ func (i *Index) Name() string

+ func (i *Index) Open() error

+ func (i *Index) Path() string

+ func (i *Index) SetColumnLabel(v string) error

+ func (i *Index) SetRemoteMaxInverseSlice(v uint64)

+ func (i *Index) SetRemoteMaxSlice(newmax uint64)

+ func (i *Index) SetTimeQuantum(q TimeQuantum) error

+ func (i *Index) TimeQuantum() TimeQuantum

+ type IndexInfo struct

+ Frames []*FrameInfo

+ Name string

+ func MergeSchemas(a, b []*IndexInfo) []*IndexInfo

+ type IndexOptions struct

+ ColumnLabel string

+ TimeQuantum TimeQuantum

+ func (o *IndexOptions) Encode() *internal.IndexMeta

+ type Iterator interface

+ Next func() (rowID, columnID uint64, eof bool)

+ Seek func(rowID, columnID uint64)

+ type LRUCache struct

+ func NewLRUCache(maxEntries uint32) *LRUCache

+ func (c *LRUCache) Add(id, n uint64)

+ func (c *LRUCache) BulkAdd(id, n uint64)

+ func (c *LRUCache) Get(id uint64) uint64

+ func (c *LRUCache) IDs() []uint64

+ func (c *LRUCache) Invalidate()

+ func (c *LRUCache) Len() int

+ func (c *LRUCache) Recalculate()

+ func (c *LRUCache) Top() []BitmapPair

+ type LimitIterator struct

+ func NewLimitIterator(itr Iterator, maxRowID, maxColumnID uint64) *LimitIterator

+ func (itr *LimitIterator) Next() (rowID, columnID uint64, eof bool)

+ func (itr *LimitIterator) Seek(rowID, columnID uint64)

+ type MultiStatsClient []StatsClient

+ func (a MultiStatsClient) Count(name string, value int64)

+ func (a MultiStatsClient) Gauge(name string, value float64)

+ func (a MultiStatsClient) Histogram(name string, value float64)

+ func (a MultiStatsClient) Set(name string, value string)

+ func (a MultiStatsClient) Tags() []string

+ func (a MultiStatsClient) Timing(name string, value time.Duration)

+ func (a MultiStatsClient) WithTags(tags ...string) StatsClient

+ type Node struct

+ Host string

+ InternalHost string

+ func (n *Node) SetState(s string)

+ func (n *Node) SetStatus(s *internal.NodeStatus)

+ type NodeSet interface

+ Nodes func() []*Node

+ Open func() error

+ type Nodes []*Node

+ func (a Nodes) Clone() []*Node

+ func (a Nodes) Contains(n *Node) bool

+ func (a Nodes) ContainsHost(host string) bool

+ func (a Nodes) Filter(n *Node) []*Node

+ func (a Nodes) FilterHost(host string) []*Node

+ func (a Nodes) Hosts() []string

+ type Pair struct

+ Count uint64

+ ID uint64

+ type PairHeap struct

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

+ type PairSet struct

+ ColumnIDs []uint64

+ RowIDs []uint64

+ type Pairs []Pair

+ func (p *Pairs) Pop() interface{}

+ func (p *Pairs) Push(x interface{})

+ func (p Pairs) Add(other []Pair) []Pair

+ func (p Pairs) Keys() []uint64

+ func (p Pairs) Len() int

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

+ func (p Pairs) String() string

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

+ type QueryRequest struct

+ ColumnAttrs bool

+ Index string

+ Quantum TimeQuantum

+ Query string

+ Remote bool

+ Slices []uint64

+ type QueryResponse struct

+ ColumnAttrSets []*ColumnAttrSet

+ Err error

+ Results []interface{}

+ func (resp *QueryResponse) MarshalJSON() ([]byte, error)

+ type RankCache struct

+ func NewRankCache(maxEntries uint32) *RankCache

+ func (c *RankCache) Add(id uint64, n uint64)

+ func (c *RankCache) BulkAdd(id uint64, n uint64)

+ func (c *RankCache) Get(id uint64) uint64

+ func (c *RankCache) IDs() []uint64

+ func (c *RankCache) Invalidate()

+ func (c *RankCache) Len() int

+ func (c *RankCache) ReadFrom(r io.Reader) (n int64, err error)

+ func (c *RankCache) Recalculate()

+ func (c *RankCache) Top() []BitmapPair

+ func (c *RankCache) WriteTo(w io.Writer) (n int64, err error)

+ type RoaringIterator struct

+ func NewRoaringIterator(itr *roaring.Iterator) *RoaringIterator

+ func (itr *RoaringIterator) Next() (rowID, columnID uint64, eof bool)

+ func (itr *RoaringIterator) Seek(bseek, pseek uint64)

+ type Server struct

+ AntiEntropyInterval time.Duration

+ BroadcastReceiver BroadcastReceiver

+ Broadcaster Broadcaster

+ Cluster *Cluster

+ Handler *Handler

+ Holder *Holder

+ Host string

+ LogOutput io.Writer

+ PollingInterval time.Duration

+ func NewServer() *Server

+ func (s *Server) Addr() net.Addr

+ func (s *Server) Close() error

+ func (s *Server) ClusterStatus() (proto.Message, error)

+ func (s *Server) HandleRemoteStatus(pb proto.Message) error

+ func (s *Server) LocalStatus() (proto.Message, error)

+ func (s *Server) Open() error

+ func (s *Server) ReceiveMessage(pb proto.Message) error

+ type SimpleCache struct

+ func (s *SimpleCache) Add(id uint64, b *Bitmap)

+ func (s *SimpleCache) Fetch(id uint64) (*Bitmap, bool)

+ type SliceIterator struct

+ func NewSliceIterator(rowIDs, columnIDs []uint64) *SliceIterator

+ func (itr *SliceIterator) Next() (rowID, columnID uint64, eof bool)

+ func (itr *SliceIterator) Seek(bseek, pseek uint64)

+ type StaticNodeSet struct

+ func NewStaticNodeSet() *StaticNodeSet

+ func (s *StaticNodeSet) Join(nodes []*Node) error

+ func (s *StaticNodeSet) Nodes() []*Node

+ func (s *StaticNodeSet) Open() error

+ type StatsClient interface

+ Count func(name string, value int64)

+ Gauge func(name string, value float64)

+ Histogram func(name string, value float64)

+ Set func(name string, value string)

+ Tags func() []string

+ Timing func(name string, value time.Duration)

+ WithTags func(tags ...string) StatsClient

+ var NopStatsClient StatsClient

+ type StatusHandler interface

+ ClusterStatus func() (proto.Message, error)

+ HandleRemoteStatus func(proto.Message) error

+ LocalStatus func() (proto.Message, error)

+ type TimeQuantum string

+ func ParseTimeQuantum(v string) (TimeQuantum, error)

+ func (q TimeQuantum) HasDay() bool

+ func (q TimeQuantum) HasHour() bool

+ func (q TimeQuantum) HasMonth() bool

+ func (q TimeQuantum) HasYear() bool

+ func (q TimeQuantum) Valid() bool

+ type TopOptions struct

+ FilterField string

+ FilterValues []interface{}

+ MinThreshold uint64

+ N int

+ RowIDs []uint64

+ Src *Bitmap

+ TanimotoThreshold uint64

+ type View struct

+ LogOutput io.Writer

+ RowAttrStore *AttrStore

+ func NewView(path, index, frame, name string, cacheSize uint32) *View

+ func (v *View) ClearBit(rowID, columnID uint64) (changed bool, err error)

+ func (v *View) Close() error

+ func (v *View) CreateFragmentIfNotExists(slice uint64) (*Fragment, error)

+ func (v *View) Fragment(slice uint64) *Fragment

+ func (v *View) FragmentPath(slice uint64) string

+ func (v *View) Fragments() []*Fragment

+ func (v *View) Frame() string

+ func (v *View) Index() string

+ func (v *View) MaxSlice() uint64

+ func (v *View) Name() string

+ func (v *View) Open() error

+ func (v *View) Path() string

+ func (v *View) SetBit(rowID, columnID uint64) (changed bool, err error)

+ type ViewInfo struct

+ Name string

v0.3.0

Feb 2, 2017

v0.2.6

Jun 16, 2017

v0.2.5

May 8, 2017

v0.2.4

Mar 7, 2017

v0.2.3

Mar 7, 2017

v0.2.2

Mar 6, 2017

v0.2.1

Feb 1, 2017

v0.2.0

Jan 19, 2017

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL