pilosa

package module

Go to main page

Versions in this module

v1

v1.4.1

Oct 8, 2020

v1.4.0

Sep 17, 2019

Changes in this version

+ func OptAPIImportWorkerPoolSize(size int) apiOption

type API

+ func (api *API) ApplySchema(ctx context.Context, s *Schema, remote bool) error

+ func (api *API) Close() error

type FieldOptions

+ Base int64

+ BitDepth uint

type InternalClient

+ PostSchema func(ctx context.Context, uri *URI, s *Schema, remote bool) error

type Row

+ func (r *Row) Any() bool

+ func (r *Row) Freeze()

type Server

+ func (s *Server) UpAndDown() error

type ServerOption

+ func OptServerExecutorPoolSize(size int) ServerOption

v1.3.1

May 1, 2019

v1.3.0

Apr 16, 2019

Changes in this version

type ColumnAttrSet

+ func (cas ColumnAttrSet) MarshalJSON() ([]byte, error)

type IndexInfo

+ ShardWidth uint64

type Row

+ func (r *Row) IsEmpty() bool

+ func (r *Row) Shift(n int64) (*Row, error)

type SystemInfo

+ CPUCores func() (physical int, logical int, err error)

+ CPUMHz func() (int, error)

+ CPUModel func() string

v1.2.0

Dec 20, 2018

Changes in this version

+ const FieldTypeBool

+ var ErrExpectedFieldListArgument = errors.New("expected field list argument")

+ var ErrFieldsArgumentRequired = errors.New("fields argument required")

+ var ErrQueryCancelled = errors.New("query cancelled")

+ var ErrQueryTimeout = errors.New("query timeout")

+ var ErrTranslateReadTargetUndersized = errors.New("pilosa: translate read target is undersized")

type API

+ func (api *API) AvailableShardsByIndex(ctx context.Context) map[string]*roaring.Bitmap

+ func (api *API) DeleteAvailableShard(_ context.Context, indexName, fieldName string, shardID uint64) error

+ func (api *API) FragmentData(ctx context.Context, indexName, fieldName, viewName string, shard uint64) (io.WriterTo, error)

+ func (api *API) ImportRoaring(ctx context.Context, indexName, fieldName string, shard uint64, remote bool, ...) (err error)

+ func (api *API) TranslateKeys(body io.Reader) ([]byte, error)

type CreateShardMessage

+ Field string

+ type DeleteAvailableShardMessage struct

+ Field string

+ Index string

+ ShardID uint64

type Field

+ func (f *Field) AddRemoteAvailableShards(b *roaring.Bitmap) error

+ func (f *Field) AvailableShards() *roaring.Bitmap

+ func (f *Field) RemoveAvailableShard(v uint64) error

type FieldOption

+ func OptFieldTypeBool() FieldOption

type FieldOptions

+ NoStandardView bool

+ type FieldRow struct

+ Field string

+ RowID uint64

+ RowKey string

+ func (fr FieldRow) MarshalJSON() ([]byte, error)

+ func (fr FieldRow) String() string

+ type FieldStatus struct

+ AvailableShards *roaring.Bitmap

+ Name string

+ type GroupCount struct

+ Count uint64

+ Group []FieldRow

+ func (g GroupCount) Compare(o GroupCount) int

+ type ImportOption func(*ImportOptions) error

+ func OptImportOptionsClear(c bool) ImportOption

+ func OptImportOptionsIgnoreKeyCheck(b bool) ImportOption

+ type ImportOptions struct

+ Clear bool

+ IgnoreKeyCheck bool

+ type ImportRoaringRequest struct

+ Clear bool

+ Views map[string][]byte

type Index

+ func (i *Index) AvailableShards() *roaring.Bitmap

type IndexOptions

+ TrackExistence bool

+ type IndexStatus struct

+ Fields []*FieldStatus

+ Name string

type InternalClient

+ CreateFieldWithOptions func(ctx context.Context, index, field string, opt FieldOptions) error

+ EnsureFieldWithOptions func(ctx context.Context, index, field string, opt FieldOptions) error

+ ImportRoaring func(ctx context.Context, uri *URI, index, field string, shard uint64, remote bool, ...) error

type Node

+ State string

type NodeStatus

+ Indexes []*IndexStatus

type ResizeInstruction

+ NodeStatus *NodeStatus

+ type RowIDs []uint64

+ type RowIdentifiers struct

+ Keys []string

+ Rows []uint64

type ServerOption

+ func OptServerTranslateFileMapSize(mapSize int) ServerOption

type SystemInfo

+ CPUArch func() string

+ type TranslateFileOption func(f *TranslateFile) error

+ func OptTranslateFileLogger(l logger.Logger) TranslateFileOption

+ func OptTranslateFileMapSize(mapSize int) TranslateFileOption

+ type TranslateKeysRequest struct

+ Field string

+ Index string

+ Keys []string

+ type TranslateKeysResponse struct

+ IDs []uint64

v1.1.0

Aug 21, 2018

Changes in this version

+ const ClusterStateDegraded

+ const FieldTypeMutex

type FieldOption

+ func OptFieldTypeMutex(cacheType string, cacheSize uint32) FieldOption

type FieldValue

+ ColumnKey string

type Holder

+ NewPrimaryTranslateStore func(interface{}) TranslateStore

type InternalClient

+ ImportValueK func(ctx context.Context, index, field string, vals []FieldValue) error

+ Nodes func(ctx context.Context) ([]*Node, error)

type ServerOption

+ func OptServerPrimaryTranslateStoreFunc(tf func(interface{}) TranslateStore) ServerOption

type TranslateFile

+ func (s *TranslateFile) SetPrimaryStore(id string, ts TranslateStore)

v1.0.2

Aug 1, 2018

Changes in this version

type IndexInfo

+ Options IndexOptions

type LogEntry

+ Field []byte

type Row

+ func (r *Row) Intersect(other *Row) *Row

v1.0.1

Jul 12, 2018

v1.0.0

Jul 10, 2018

Changes in this version

+ const DefaultFieldType

+ const FieldTypeSet

+ const FieldTypeTime

+ const LogEntryTypeInsertColumn

+ const LogEntryTypeInsertRow

+ const ShardWidth

+ var ErrBSIGroupExists = errors.New("bsigroup already exists")

+ var ErrBSIGroupNameRequired = errors.New("bsigroup name required")

+ var ErrBSIGroupNotFound = errors.New("bsigroup not found")

+ var ErrBSIGroupValueTooHigh = errors.New("bsigroup value too high")

+ var ErrBSIGroupValueTooLow = errors.New("bsigroup value too low")

+ var ErrClusterDoesNotOwnShard = errors.New("cluster does not own shard")

+ var ErrFieldRequired = errors.New("field required")

+ var ErrInvalidBSIGroupRange = errors.New("invalid bsigroup range")

+ var ErrInvalidBSIGroupType = errors.New("invalid bsigroup type")

+ var ErrInvalidBSIGroupValueType = errors.New("invalid bsigroup value type")

+ var ErrNotImplemented = errors.New("not implemented")

+ var ErrReplicationNotSupported = errors.New("pilosa: replication not supported")

+ var ErrTranslateStoreClosed = errors.New("pilosa: translate store closed")

+ var ErrTranslateStoreReadOnly = errors.New("pilosa: operation not supported, translate store read only")

+ var ErrTranslateStoreReaderClosed = errors.New("pilosa: translate store reader closed")

+ func MarshalInternalMessage(m Message, s Serializer) ([]byte, error)

+ func OptAPIServer(s *Server) apiOption

type API

+ Serializer Serializer

+ func (api *API) Field(ctx context.Context, indexName, fieldName string) (*Field, error)

+ func (api *API) FieldAttrDiff(ctx context.Context, indexName string, fieldName string, blocks []AttrBlock) (map[uint64]map[string]interface{}, error)

+ func (api *API) GetTranslateData(ctx context.Context, w io.WriteCloser, offset int64) error

+ func (api *API) MaxShards(ctx context.Context) map[string]uint64

+ func (api *API) Node() *Node

+ func (api *API) ShardNodes(ctx context.Context, indexName string, shard uint64) ([]*Node, error)

type BadRequestError

+ func NewBadRequestError(err error) BadRequestError

+ type BlockDataRequest struct

+ Block uint64

+ Field string

+ Index string

+ Shard uint64

+ View string

+ type BlockDataResponse struct

+ ColumnIDs []uint64

+ RowIDs []uint64

+ type ClusterStatus struct

+ ClusterID string

+ Nodes []*Node

+ State string

type ColumnAttrSet

+ Key string

+ type ConflictError struct

+ type CreateFieldMessage struct

+ Field string

+ Index string

+ Meta *FieldOptions

+ type CreateIndexMessage struct

+ Index string

+ Meta *IndexOptions

+ type CreateShardMessage struct

+ Index string

+ Shard uint64

+ type CreateViewMessage struct

+ Field string

+ Index string

+ View string

+ type DeleteFieldMessage struct

+ Field string

+ Index string

+ type DeleteIndexMessage struct

+ Index string

+ type DeleteViewMessage struct

+ Field string

+ Index string

+ View string

type Field

+ Stats StatsClient

+ func NewField(path, index, name string, opts FieldOption) (*Field, error)

+ func (f *Field) CacheSize() uint32

+ func (f *Field) ClearBit(rowID, colID uint64) (changed bool, err error)

+ func (f *Field) Close() error

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

+ func (f *Field) Index() string

+ func (f *Field) Open() error

+ func (f *Field) Options() FieldOptions

+ func (f *Field) Path() string

+ func (f *Field) Range(name string, op pql.Token, predicate int64) (*Row, error)

+ func (f *Field) Row(rowID uint64) (*Row, error)

+ func (f *Field) RowAttrStore() AttrStore

+ func (f *Field) RowTime(rowID uint64, time time.Time, quantum string) (*Row, error)

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

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

+ func (f *Field) SetValue(columnID uint64, value int64) (changed bool, err error)

+ func (f *Field) Sum(filter *Row, name string) (sum, count int64, err error)

+ func (f *Field) TimeQuantum() TimeQuantum

+ func (f *Field) Value(columnID uint64) (value int64, exists bool, err error)

+ type FieldInfo struct

+ Name string

+ Options FieldOptions

+ Views []*ViewInfo

+ type FieldOption func(fo *FieldOptions) error

+ func OptFieldKeys() FieldOption

+ func OptFieldTypeDefault() FieldOption

+ func OptFieldTypeInt(min, max int64) FieldOption

+ func OptFieldTypeSet(cacheType string, cacheSize uint32) FieldOption

+ func OptFieldTypeTime(timeQuantum TimeQuantum) FieldOption

+ type FieldOptions struct

+ CacheSize uint32

+ CacheType string

+ Keys bool

+ Max int64

+ Min int64

+ TimeQuantum TimeQuantum

+ Type string

+ func (o *FieldOptions) MarshalJSON() ([]byte, error)

type Handler

+ var NopHandler Handler = nopHandler{}

+ Close func() error

+ Serve func() error

type Holder

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

+ type ImportRequest struct

+ ColumnIDs []uint64

+ ColumnKeys []string

+ Field string

+ Index string

+ RowIDs []uint64

+ RowKeys []string

+ Shard uint64

+ Timestamps []int64

+ type ImportResponse struct

+ Err string

+ type ImportValueRequest struct

+ ColumnIDs []uint64

+ ColumnKeys []string

+ Field string

+ Index string

+ Shard uint64

+ Values []int64

type Index

+ func (i *Index) CreateField(name string, opts ...FieldOption) (*Field, error)

+ func (i *Index) CreateFieldIfNotExists(name string, opts FieldOption) (*Field, error)

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

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

+ func (i *Index) Fields() []*Field

+ func (i *Index) Keys() bool

type IndexInfo

+ Fields []*FieldInfo

type IndexOptions

+ Keys bool

type InternalClient

+ CreateField func(ctx context.Context, index, field string) error

+ EnsureField func(ctx context.Context, indexName string, fieldName string) error

+ MaxShardByIndex func(ctx context.Context) (map[string]uint64, error)

+ RetrieveShardFromURI func(ctx context.Context, index, field string, shard uint64, uri URI) (io.ReadCloser, error)

+ type InternalQueryClient interface

+ QueryNode func(ctx context.Context, uri *URI, index string, queryRequest *QueryRequest) (*QueryResponse, error)

+ type LogEntry struct

+ Frame []byte

+ IDs []uint64

+ Index []byte

+ Keys [][]byte

+ Length uint64

+ Type uint8

+ func (e *LogEntry) ReadFrom(r io.Reader) (_ int64, err error)

+ func (e *LogEntry) WriteTo(w io.Writer) (_ int64, err error)

+ type Message interface

+ type NodeStateMessage struct

+ NodeID string

+ State string

+ type NodeStatus struct

+ MaxShards map[string]uint64

+ Node *Node

+ Schema *Schema

+ type NotFoundError struct

type QueryRequest

+ ExcludeColumns bool

+ ExcludeRowAttrs bool

+ Shards []uint64

+ type RecalculateCaches struct

+ type ResizeInstruction struct

+ ClusterStatus *ClusterStatus

+ Coordinator *Node

+ JobID int64

+ Node *Node

+ Schema *Schema

+ Sources []*ResizeSource

+ type ResizeInstructionComplete struct

+ Error string

+ JobID int64

+ Node *Node

+ type ResizeSource struct

+ Field string

+ Index string

+ Node *Node

+ Shard uint64

+ View string

+ type Row struct

+ Attrs map[string]interface{}

+ Keys []string

+ func NewRow(columns ...uint64) *Row

+ func (r *Row) Columns() []uint64

+ func (r *Row) Count() uint64

+ func (r *Row) Difference(other *Row) *Row

+ func (r *Row) MarshalJSON() ([]byte, error)

+ func (r *Row) Merge(other *Row)

+ func (r *Row) Segments() []rowSegment

+ func (r *Row) SetBit(i uint64) (changed bool)

+ func (r *Row) Union(other *Row) *Row

+ func (r *Row) Xor(other *Row) *Row

+ type Schema struct

+ Indexes []*IndexInfo

+ type Serializer interface

+ Marshal func(Message) ([]byte, error)

+ Unmarshal func([]byte, Message) error

type Server

+ func (s *Server) SyncData() error

type ServerOption

+ func OptServerClusterDisabled(disabled bool, hosts []string) ServerOption

+ func OptServerClusterHasher(h Hasher) ServerOption

+ func OptServerInternalClient(c InternalClient) ServerOption

+ func OptServerIsCoordinator(is bool) ServerOption

+ func OptServerNodeID(nodeID string) ServerOption

+ func OptServerPrimaryTranslateStore(store TranslateStore) ServerOption

+ func OptServerSerializer(ser Serializer) ServerOption

+ type SetCoordinatorMessage struct

+ New *Node

+ type TranslateFile struct

+ Path string

+ PrimaryTranslateStore TranslateStore

+ func NewTranslateFile() *TranslateFile

+ func (s *TranslateFile) Close() (err error)

+ func (s *TranslateFile) Closing() <-chan struct{}

+ func (s *TranslateFile) Open() (err error)

+ func (s *TranslateFile) Reader(ctx context.Context, offset int64) (io.ReadCloser, error)

+ func (s *TranslateFile) TranslateColumnToString(index string, value uint64) (string, error)

+ func (s *TranslateFile) TranslateColumnsToUint64(index string, values []string) ([]uint64, error)

+ func (s *TranslateFile) TranslateRowToString(index, frame string, id uint64) (string, error)

+ func (s *TranslateFile) TranslateRowsToUint64(index, frame string, values []string) ([]uint64, error)

+ func (s *TranslateFile) WriteNotify() <-chan struct{}

+ type TranslateStore interface

+ Reader func(ctx context.Context, off int64) (io.ReadCloser, error)

+ TranslateColumnToString func(index string, values uint64) (string, error)

+ TranslateColumnsToUint64 func(index string, values []string) ([]uint64, error)

+ TranslateRowToString func(index, frame string, values uint64) (string, error)

+ TranslateRowsToUint64 func(index, frame string, values []string) ([]uint64, error)

+ type UpdateCoordinatorMessage struct

+ New *Node

v1.0.0-alpha.1

Jul 6, 2018

v0

v0.10.1

May 22, 2018

v0.10.0

May 15, 2018

Changes in this version

+ var Enterprise = "0"

+ var EnterpriseEnabled = false

type API

+ func (api *API) Info() ServerInfo

type InternalClient

+ Query func(ctx context.Context, index string, queryRequest *internal.QueryRequest) (*internal.QueryResponse, error)

+ QueryNode func(ctx context.Context, uri *URI, index string, ...) (*internal.QueryResponse, error)

type InternalHTTPClient

+ func (c *InternalHTTPClient) Query(ctx context.Context, index string, queryRequest *internal.QueryRequest) (*internal.QueryResponse, error)

+ func (c *InternalHTTPClient) QueryNode(ctx context.Context, uri *URI, index string, ...) (*internal.QueryResponse, error)

+ type ServerInfo struct

+ SliceWidth uint64

v0.9.0

May 4, 2018

Changes in this version

+ const ClusterStateNormal

+ const ClusterStateResizing

+ const ClusterStateStarting

+ const MessageTypeClusterStatus

+ const MessageTypeCreateField

+ const MessageTypeCreateView

+ const MessageTypeDeleteField

+ const MessageTypeNodeEvent

+ const MessageTypeNodeState

+ const MessageTypeRecalculateCaches

+ const MessageTypeResizeInstruction

+ const MessageTypeResizeInstructionComplete

+ const MessageTypeSetCoordinator

+ const MessageTypeUpdateCoordinator

+ const NodeStateLoading

+ const NodeStateReady

+ const QueryResultTypeBitmap

+ const QueryResultTypeBool

+ const QueryResultTypeNil

+ const QueryResultTypePairs

+ const QueryResultTypeUint64

+ const QueryResultTypeValCount

+ const ResizeJobActionAdd

+ const ResizeJobActionRemove

+ const ResizeJobStateAborted

+ const ResizeJobStateDone

+ const ResizeJobStateRunning

+ var ErrClusterDoesNotOwnSlice = errors.New("cluster does not own slice")

+ var ErrNodeIDNotExists = errors.New("node with provided ID does not exist")

+ var ErrNodeNotCoordinator = errors.New("node is not the coordinator")

+ var ErrResizeNotRunning = errors.New("no resize job currently running")

+ var NopEventReceiver = &nopEventReceiver

+ func DecodeAttrs(v []byte) (map[string]interface{}, error)

+ func EncodeAttrs(attr map[string]interface{}) ([]byte, error)

+ func EncodeNode(n *Node) *internal.Node

+ func EncodeNodes(a []*Node) []*internal.Node

+ func SliceDiff(a, b []uint64) []uint64

+ func StringSlicesAreEqual(a, b []string) bool

+ type API struct

+ BroadcastHandler BroadcastHandler

+ Broadcaster Broadcaster

+ Cluster *Cluster

+ Executor interface{ ... }

+ Holder *Holder

+ Logger Logger

+ RemoteClient *http.Client

+ StatusHandler StatusHandler

+ URI URI

+ func NewAPI() *API

+ func (api *API) ClusterMessage(ctx context.Context, reqBody io.Reader) error

+ func (api *API) CreateField(ctx context.Context, indexName string, frameName string, field *Field) error

+ func (api *API) CreateFrame(ctx context.Context, indexName string, frameName string, options FrameOptions) (*Frame, error)

+ func (api *API) CreateIndex(ctx context.Context, indexName string, options IndexOptions) (*Index, error)

+ func (api *API) CreateInputDefinition(ctx context.Context, indexName string, inputDefName string, ...) error

+ func (api *API) DeleteField(ctx context.Context, indexName string, frameName string, fieldName string) error

+ func (api *API) DeleteFrame(ctx context.Context, indexName string, frameName string) error

+ func (api *API) DeleteIndex(ctx context.Context, indexName string) error

+ func (api *API) DeleteInputDefinition(ctx context.Context, indexName string, inputDefName string) error

+ func (api *API) DeleteView(ctx context.Context, indexName string, frameName string, viewName string) error

+ func (api *API) ExportCSV(ctx context.Context, indexName string, frameName string, viewName string, ...) error

+ func (api *API) Fields(ctx context.Context, indexName string, frameName string) ([]*Field, error)

+ func (api *API) FragmentBlockData(ctx context.Context, body io.Reader) ([]byte, error)

+ func (api *API) FragmentBlocks(ctx context.Context, indexName string, frameName string, viewName string, ...) ([]FragmentBlock, error)

+ func (api *API) FrameAttrDiff(ctx context.Context, indexName string, frameName string, blocks []AttrBlock) (map[uint64]map[string]interface{}, error)

+ func (api *API) Hosts(ctx context.Context) []*Node

+ func (api *API) Import(ctx context.Context, req internal.ImportRequest) error

+ func (api *API) ImportValue(ctx context.Context, req internal.ImportValueRequest) error

+ func (api *API) Index(ctx context.Context, indexName string) (*Index, error)

+ func (api *API) IndexAttrDiff(ctx context.Context, indexName string, blocks []AttrBlock) (map[uint64]map[string]interface{}, error)

+ func (api *API) InputDefinition(ctx context.Context, indexName string, inputDefName string) (*InputDefinition, error)

+ func (api *API) LocalID() string

+ func (api *API) LongQueryTime() time.Duration

+ func (api *API) MarshalFragment(ctx context.Context, indexName string, frameName string, viewName string, ...) (io.WriterTo, error)

+ func (api *API) MaxInverseSlices(ctx context.Context) map[string]uint64

+ func (api *API) MaxSlices(ctx context.Context) map[string]uint64

+ func (api *API) Query(ctx context.Context, req *QueryRequest) (QueryResponse, error)

+ func (api *API) RecalculateCaches(ctx context.Context) error

+ func (api *API) RemoveNode(id string) (*Node, error)

+ func (api *API) ResizeAbort() error

+ func (api *API) RestoreFrame(ctx context.Context, indexName string, frameName string, host *URI) error

+ func (api *API) Schema(ctx context.Context) []*IndexInfo

+ func (api *API) SetCoordinator(ctx context.Context, id string) (oldNode, newNode *Node, err error)

+ func (api *API) SliceNodes(ctx context.Context, indexName string, slice uint64) ([]*Node, error)

+ func (api *API) State() string

+ func (api *API) StatsWithTags(tags []string) StatsClient

+ func (api *API) UnmarshalFragment(ctx context.Context, indexName string, frameName string, viewName string, ...) error

+ func (api *API) Version() string

+ func (api *API) Views(ctx context.Context, indexName string, frameName string) ([]*View, error)

+ func (api *API) WriteInput(ctx context.Context, indexName string, inputDefName string, reqs []interface{}) error

+ type ApiMethodNotAllowedError struct

type AttrStore

+ var NopAttrStore AttrStore

+ func NewNopAttrStore(string) AttrStore

+ type BadRequestError struct

type Bit

+ ColumnKey string

+ RowKey string

type Bits

+ func (p Bits) ColumnKeys() []string

+ func (p Bits) RowKeys() []string

type Broadcaster

+ SendTo func(to *Node, pb proto.Message) error

type Cluster

+ Broadcaster Broadcaster

+ Coordinator string

+ EventReceiver EventReceiver

+ Holder *Holder

+ ID string

+ Logger Logger

+ MemberSet MemberSet

+ Node *Node

+ Path string

+ RemoteClient *http.Client

+ Static bool

+ Topology *Topology

+ func (c *Cluster) AddNode(node *Node) error

+ func (c *Cluster) Close() error

+ func (c *Cluster) CompleteCurrentJob(state string) error

+ func (c *Cluster) ContainsSlices(index string, maxSlice uint64, node *Node) []uint64

+ func (c *Cluster) CoordinatorNode() *Node

+ func (c *Cluster) FollowResizeInstruction(instr *internal.ResizeInstruction) error

+ func (c *Cluster) IsCoordinator() bool

+ func (c *Cluster) Job(id int64) *ResizeJob

+ func (c *Cluster) ListenForJoins()

+ func (c *Cluster) MarkResizeInstructionComplete(complete *internal.ResizeInstructionComplete) error

+ func (c *Cluster) MergeClusterStatus(cs *internal.ClusterStatus) error

+ func (c *Cluster) NodeByID(id string) *Node

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

+ func (c *Cluster) NodeLeave(node *Node) error

+ func (c *Cluster) Open() error

+ func (c *Cluster) OwnsSlice(nodeID string, index string, slice uint64) bool

+ func (c *Cluster) ReceiveEvent(e *NodeEvent) error

+ func (c *Cluster) ReceiveNodeState(nodeID string, state string) error

+ func (c *Cluster) RemoveNode(node *Node) error

+ func (c *Cluster) SetCoordinator(n *Node) error

+ func (c *Cluster) SetNodeState(state string) error

+ func (c *Cluster) SetState(state string)

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

+ func (c *Cluster) State() string

+ func (c *Cluster) UpdateCoordinator(n *Node) bool

+ type DiagnosticsCollector struct

+ Logger Logger

+ VersionURL string

+ func NewDiagnosticsCollector(host string) *DiagnosticsCollector

+ func (d *DiagnosticsCollector) CheckVersion() error

+ func (d *DiagnosticsCollector) EnrichWithMemoryInfo()

+ func (d *DiagnosticsCollector) EnrichWithOSInfo()

+ func (d *DiagnosticsCollector) EnrichWithSchemaProperties()

+ func (d *DiagnosticsCollector) Flush() error

+ func (d *DiagnosticsCollector) Set(name string, value interface{})

+ func (d *DiagnosticsCollector) SetVersion(v string)

+ type EventHandler interface

+ ReceiveEvent func(e *NodeEvent) error

+ type EventReceiver interface

+ Start func(EventHandler) error

type Executor

+ Node *Node

+ type FileSystem interface

+ New func() (http.FileSystem, error)

+ var NopFileSystem FileSystem

type Fragment

+ Logger Logger

+ func (f *Fragment) FieldMax(filter *Bitmap, bitDepth uint) (max, count uint64, err error)

+ func (f *Fragment) FieldMin(filter *Bitmap, bitDepth uint) (min, count uint64, err error)

type FragmentSyncer

+ Node *Node

type Frame

+ Logger Logger

+ func (f *Frame) FieldMax(filter *Bitmap, name string) (max, count int64, err error)

+ func (f *Frame) FieldMin(filter *Bitmap, name string) (min, count int64, err error)

+ func (f *Frame) Fields() []*Field

+ func (f *Frame) HasField(name string) bool

type FrameInfo

+ Options FrameOptions

+ type GCNotifier interface

+ AfterGC func() <-chan struct{}

+ Close func()

+ var NopGCNotifier GCNotifier

+ type Gossiper interface

+ SendAsync func(pb proto.Message) error

+ var NopGossiper Gossiper

type Handler

+ API *API

+ FileSystem FileSystem

+ Logger Logger

type Holder

+ Logger Logger

+ NewAttrStore func(string) AttrStore

+ func (h *Holder) ApplySchema(schema *internal.Schema) error

+ func (h *Holder) EncodeMaxSlices() *internal.MaxSlices

+ func (h *Holder) EncodeSchema() *internal.Schema

+ func (h *Holder) HasData() (bool, error)

+ type HolderCleaner struct

+ Closing <-chan struct{}

+ Cluster *Cluster

+ Holder *Holder

+ Node *Node

+ func (c *HolderCleaner) CleanHolder() error

+ func (c *HolderCleaner) IsClosing() bool

type HolderSyncer

+ Node *Node

+ Stats StatsClient

type Index

+ Logger Logger

+ NewAttrStore func(string) AttrStore

+ func (i *Index) InputDefinitions() []*InputDefinition

type InternalClient

+ ImportK func(ctx context.Context, index, frame string, bits []Bit) error

+ NodeID func(uri *URI) (string, error)

+ SendMessage func(ctx context.Context, pb proto.Message) error

type InternalHTTPClient

+ func (c *InternalHTTPClient) ImportK(ctx context.Context, index, frame string, bits []Bit) error

+ func (c *InternalHTTPClient) NodeID(uri *URI) (string, error)

+ func (c *InternalHTTPClient) RetrieveSliceFromURI(ctx context.Context, index, frame, view string, slice uint64, uri URI) (io.ReadCloser, error)

+ func (c *InternalHTTPClient) SendMessage(ctx context.Context, pb proto.Message) error

+ type Logger interface

+ Debugf func(format string, v ...interface{})

+ Printf func(format string, v ...interface{})

+ var NopLogger Logger

+ type MemberSet interface

+ Open func(n *Node) error

type Node

+ ID string

+ IsCoordinator bool

+ func DecodeNode(node *internal.Node) *Node

+ func DecodeNodes(a []*internal.Node) []*Node

+ func (n Node) String() string

+ type NodeEvent struct

+ Event NodeEventType

+ Node *Node

+ func DecodeNodeEvent(ne *internal.NodeEventMessage) *NodeEvent

+ type NodeEventType int

+ const NodeJoin

+ const NodeLeave

+ const NodeUpdate

+ type NodeIDs []string

+ func (n NodeIDs) ContainsID(id string) bool

+ func (n NodeIDs) Len() int

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

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

type Nodes

+ func (a Nodes) ContainsID(id string) bool

+ func (a Nodes) FilterID(id string) []*Node

+ func (a Nodes) FilterURI(uri URI) []*Node

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

+ func (a Nodes) URIs() []URI

+ type NopSystemInfo struct

+ func NewNopSystemInfo() *NopSystemInfo

+ func (n *NopSystemInfo) Family() (string, error)

+ func (n *NopSystemInfo) KernelVersion() (string, error)

+ func (n *NopSystemInfo) MemFree() (uint64, error)

+ func (n *NopSystemInfo) MemTotal() (uint64, error)

+ func (n *NopSystemInfo) MemUsed() (uint64, error)

+ func (n *NopSystemInfo) OSVersion() (string, error)

+ func (n *NopSystemInfo) Platform() (string, error)

+ func (n *NopSystemInfo) Uptime() (uint64, error)

type Pair

+ Key string

+ type ResizeJob struct

+ Broadcaster Broadcaster

+ ID int64

+ IDs map[string]bool

+ Instructions []*internal.ResizeInstruction

+ Logger Logger

+ func NewResizeJob(existingNodes []*Node, node *Node, action string) *ResizeJob

+ func (j *ResizeJob) Run() error

+ func (j *ResizeJob) SetState(state string)

+ func (j *ResizeJob) State() string

type Server

+ Gossiper Gossiper

+ NewAttrStore func(string) AttrStore

+ NodeID string

+ func (s *Server) LoadNodeID() string

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

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

+ func (s *Server) SendTo(to *Node, pb proto.Message) error

+ type ServerOption func(s *Server) error

+ func OptServerAntiEntropyInterval(interval time.Duration) ServerOption

+ func OptServerAttrStoreFunc(af func(string) AttrStore) ServerOption

+ func OptServerDataDir(dir string) ServerOption

+ func OptServerDiagnosticsInterval(dur time.Duration) ServerOption

+ func OptServerGCNotifier(gcn GCNotifier) ServerOption

+ func OptServerHandler(h *Handler) ServerOption

+ func OptServerListener(ln net.Listener) ServerOption

+ func OptServerLogger(l Logger) ServerOption

+ func OptServerLongQueryTime(dur time.Duration) ServerOption

+ func OptServerMaxWritesPerRequest(n int) ServerOption

+ func OptServerMetricInterval(dur time.Duration) ServerOption

+ func OptServerRemoteClient(c *http.Client) ServerOption

+ func OptServerReplicaN(n int) ServerOption

+ func OptServerStatsClient(sc StatsClient) ServerOption

+ func OptServerSystemInfo(si SystemInfo) ServerOption

+ func OptServerURI(uri *URI) ServerOption

+ type StandardLogger struct

+ func NewStandardLogger(w io.Writer) *StandardLogger

+ func (s *StandardLogger) Debugf(format string, v ...interface{})

+ func (s *StandardLogger) Logger() *log.Logger

+ func (s *StandardLogger) Printf(format string, v ...interface{})

+ type StaticMemberSet struct

+ func NewStaticMemberSet(nodes []*Node) *StaticMemberSet

+ func (s *StaticMemberSet) Open(n *Node) error

+ type SystemInfo interface

+ Family func() (string, error)

+ KernelVersion func() (string, error)

+ MemFree func() (uint64, error)

+ MemTotal func() (uint64, error)

+ MemUsed func() (uint64, error)

+ OSVersion func() (string, error)

+ Platform func() (string, error)

+ Uptime func() (uint64, error)

+ type Topology struct

+ ClusterID string

+ NodeIDs []string

+ func NewTopology() *Topology

+ func (t *Topology) AddID(nodeID string) bool

+ func (t *Topology) ContainsID(id string) bool

+ func (t *Topology) Encode() *internal.Topology

+ func (t *Topology) RemoveID(nodeID string) bool

type URI

+ func DecodeURI(i *internal.URI) URI

+ func (u *URI) MarshalJSON() ([]byte, error)

+ func (u *URI) UnmarshalJSON(b []byte) error

+ func (u URI) Encode() *internal.URI

+ type URIs []URI

+ func (u URIs) HostPortStrings() []string

+ type ValCount struct

+ Count int64

+ Val int64

+ func (vc *ValCount) Add(other ValCount) ValCount

+ func (vc *ValCount) Larger(other ValCount) ValCount

+ func (vc *ValCount) Smaller(other ValCount) ValCount

+ type VerboseLogger struct

+ func NewVerboseLogger(w io.Writer) *VerboseLogger

+ func (vb *VerboseLogger) Debugf(format string, v ...interface{})

+ func (vb *VerboseLogger) Logger() *log.Logger

+ func (vb *VerboseLogger) Printf(format string, v ...interface{})

type View

+ Logger Logger

+ func (v *View) DeleteFragment(slice uint64) error

+ func (v *View) FieldMax(filter *Bitmap, bitDepth uint) (max, count uint64, err error)

+ func (v *View) FieldMin(filter *Bitmap, bitDepth uint) (min, count uint64, err error)

v0.8.8

Feb 19, 2018

v0.8.7

Feb 12, 2018

v0.8.6

Feb 9, 2018

v0.8.5

Jan 18, 2018

v0.8.4

Jan 10, 2018

Changes in this version

+ func DecodeAttrsMap(m map[uint64]*internal.AttrMap) map[uint64]map[string]interface

+ func EncodeAttrBlocks(a []AttrBlock) []*internal.AttrBlock

type Cluster

+ MaxWritesPerRequest int

v0.8.3

Dec 12, 2017

v0.8.2

Dec 5, 2017

Changes in this version

+ func GetHTTPClient(t *tls.Config) *http.Client

type FragmentSyncer

+ RemoteClient *http.Client

type Handler

+ RemoteClient *http.Client

type HolderSyncer

+ RemoteClient *http.Client

type Server

+ RemoteClient *http.Client

v0.8.1

Nov 15, 2017

v0.8.0

Nov 15, 2017

Changes in this version

+ const DefaultDiagnosticServer

+ type ClientOptions struct

+ TLS *tls.Config

type Config

+ Gossip struct{ ... }

+ TLS TLSConfig

type Executor

+ Scheme string

type ExpvarStatsClient

+ func (c *ExpvarStatsClient) Close() error

+ func (c *ExpvarStatsClient) Open()

type FragmentSyncer

+ ClientOptions *ClientOptions

type Frame

+ func (f *Frame) RecalculateCaches()

type Handler

+ ClientOptions *ClientOptions

+ URI *URI

type Holder

+ func (h *Holder) RecalculateCaches()

type HolderSyncer

+ ClientOptions *ClientOptions

+ URI *URI

type Index

+ func (i *Index) RecalculateCaches()

+ type InternalClient interface

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

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

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

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

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

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

+ EnsureFrame func(ctx context.Context, indexName string, frameName string, options FrameOptions) error

+ EnsureIndex func(ctx context.Context, name string, options IndexOptions) error

+ ExecuteQuery func(ctx context.Context, index string, queryRequest *internal.QueryRequest) (*internal.QueryResponse, error)

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

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

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

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

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

+ ImportValue func(ctx context.Context, index, frame, field string, slice uint64, ...) error

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

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

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

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

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

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

+ type InternalHTTPClient struct

+ HTTPClient *http.Client

+ func NewInternalHTTPClient(host string, options *ClientOptions) (*InternalHTTPClient, error)

+ func NewInternalHTTPClientFromURI(defaultURI *URI, options *ClientOptions) *InternalHTTPClient

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

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

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

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

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

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

+ func (c *InternalHTTPClient) EnsureFrame(ctx context.Context, indexName string, frameName string, options FrameOptions) error

+ func (c *InternalHTTPClient) EnsureIndex(ctx context.Context, name string, options IndexOptions) error

+ func (c *InternalHTTPClient) ExecuteQuery(ctx context.Context, index string, queryRequest *internal.QueryRequest) (*internal.QueryResponse, error)

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

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

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

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

+ func (c *InternalHTTPClient) Host() *URI

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

+ func (c *InternalHTTPClient) ImportValue(ctx context.Context, index, frame, field string, slice uint64, ...) error

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

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

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

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

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

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

type MultiStatsClient

+ func (a MultiStatsClient) Close() error

+ func (a MultiStatsClient) Open()

type Node

+ Scheme string

+ func (n *Node) URI() (*URI, error)

type Server

+ DiagnosticInterval time.Duration

+ TLS *tls.Config

+ URI *URI

type StatsClient

+ Close func() error

+ Open func()

+ type TLSConfig struct

+ CertificateKeyPath string

+ CertificatePath string

+ SkipVerify bool

+ type URI struct

+ func DefaultURI() *URI

+ func NewURIFromAddress(address string) (*URI, error)

+ func NewURIFromHostPort(host string, port uint16) (*URI, error)

+ func (u *URI) Host() string

+ func (u *URI) HostPort() string

+ func (u *URI) Normalize() string

+ func (u *URI) Path(path string) string

+ func (u *URI) Port() uint16

+ func (u *URI) Scheme() string

+ func (u *URI) Set(value string) error

+ func (u *URI) SetHost(host string) error

+ func (u *URI) SetPort(port uint16)

+ func (u *URI) SetScheme(scheme string) error

+ func (u URI) Equals(other *URI) bool

+ func (u URI) String() string

+ func (u URI) Type() string

type View

+ func (v *View) RecalculateCaches()

v0.7.2

Nov 15, 2017

v0.7.1

Oct 9, 2017

Changes in this version

type Fragment

+ func (f *Fragment) FieldNotNull(bitDepth uint) (*Bitmap, error)

v0.7.0

Oct 3, 2017

Changes in this version

+ const MessageTypeDeleteView

+ var ErrFieldExists = errors.New("field already exists")

+ var ErrInvalidBetweenValue = errors.New("invalid value for between operation")

+ func MarshalImportValuePayload(index, frame, field string, slice uint64, vals []FieldValue) ([]byte, error)

type Bitmap

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

type BitmapSegment

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

type Client

+ func (c *Client) EnsureFrame(ctx context.Context, indexName string, frameName string, options FrameOptions) error

+ func (c *Client) EnsureIndex(ctx context.Context, name string, options IndexOptions) error

+ func (c *Client) ImportValue(ctx context.Context, index, frame, field string, slice uint64, ...) error

type ExecOptions

+ ExcludeAttrs bool

+ ExcludeBits bool

type Field

+ func (f *Field) BaseValue(op pql.Token, value int64) (baseValue uint64, outOfRange bool)

+ func (f *Field) BaseValueBetween(min, max int64) (baseValueMin, baseValueMax uint64, outOfRange bool)

+ type FieldValue struct

+ ColumnID uint64

+ Value uint64

+ type FieldValues []FieldValue

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

+ func (p FieldValues) GroupBySlice() map[uint64][]FieldValue

+ func (p FieldValues) Len() int

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

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

+ func (p FieldValues) Values() []uint64

type Fragment

+ func (f *Fragment) FieldRangeBetween(bitDepth uint, predicateMin, predicateMax uint64) (*Bitmap, error)

+ func (f *Fragment) FieldSum(filter *Bitmap, bitDepth uint) (sum, count uint64, err error)

+ func (f *Fragment) ImportValue(columnIDs, values []uint64, bitDepth uint) error

type Frame

+ func (f *Frame) CreateField(field *Field) error

+ func (f *Frame) DeleteField(name string) error

+ func (f *Frame) DeleteView(name string) error

+ func (f *Frame) FieldRangeBetween(name string, predicateMin, predicateMax int64) (*Bitmap, error)

+ func (f *Frame) FieldSum(filter *Bitmap, name string) (sum, count int64, err error)

+ func (f *Frame) GetFields() (*FrameSchema, error)

+ func (f *Frame) ImportValue(fieldName string, columnIDs, values []uint64) error

type FrameSchema

+ func (s *FrameSchema) AddField(field *Field) error

+ func (s *FrameSchema) Clone() *FrameSchema

+ func (s *FrameSchema) DeleteField(name string) error

+ func (s *FrameSchema) HasField(name string) bool

type Index

+ func (i *Index) Options() IndexOptions

type QueryRequest

+ ExcludeAttrs bool

+ ExcludeBits bool

+ type SumCount struct

+ Count int64

+ Sum int64

+ func (sc *SumCount) Add(other SumCount) SumCount

type TimeQuantum

+ func (q *TimeQuantum) Set(value string) error

+ func (q TimeQuantum) String() string

+ func (q TimeQuantum) Type() string

type View

+ func (v *View) FieldRangeBetween(bitDepth uint, predicateMin, predicateMax uint64) (*Bitmap, error)

+ func (v *View) FieldSum(filter *Bitmap, bitDepth uint) (sum, count uint64, err error)

v0.6.0

Aug 11, 2017

Changes in this version

+ const DefaultGossipPort

+ const RangeOpEQ

+ const RangeOpGT

+ const RangeOpGTE

+ const RangeOpLT

+ const RangeOpLTE

+ var ErrInvalidRangeOperation = errors.New("invalid range operation")

+ func AddressWithDefaults(addr string) (string, error)

+ func HostToIP(host string) string

+ func NormalizeAddress(addr string) (string, error)

type Config

+ GossipPort string

+ GossipSeed string

type Fragment

+ func (f *Fragment) FieldRange(op string, bitDepth uint, predicate uint64) (*Bitmap, error)

type Frame

+ func (f *Frame) FieldRange(name, op string, predicate int64) (*Bitmap, error)

type View

+ func (v *View) FieldRange(op string, bitDepth uint, predicate uint64) (*Bitmap, error)

v0.5.0

Aug 2, 2017

Changes in this version

+ const CacheTypeNone

+ const ClusterGossip

+ const ClusterHTTP

+ const ClusterNone

+ const ClusterStatic

+ const DefaultRangeEnabled

+ const FieldTypeInt

+ const FileLimit

+ const InputDefinitionDir

+ const InputMapping

+ const InputSetTimestamp

+ const InputSingleRowBool

+ const InputValueToRow

+ const MessageTypeCreateInputDefinition

+ const MessageTypeDeleteInputDefinition

+ const ViewFieldPrefix

+ var ClusterTypes = []string

+ var ErrConfigBroadcastPort = errors.New("internal-port not found in internal-hosts")

+ var ErrConfigClusterTypeInvalid = errors.New("invalid cluster type")

+ var ErrConfigClusterTypeMissing = errors.New("missing cluster type")

+ var ErrConfigHostsMismatch = errors.New("hosts and internal-hosts length mismatch")

+ var ErrConfigHostsMissing = errors.New("missing bind address in cluster hosts")

+ var ErrConfigReplicaNInvalid = errors.New("replica number must be <= hosts")

+ var ErrFieldNameRequired = errors.New("field name required")

+ var ErrFieldNotFound = errors.New("field not found")

+ var ErrFieldValueTooHigh = errors.New("field value too high")

+ var ErrFieldValueTooLow = errors.New("field value too low")

+ var ErrFrameFieldsNotAllowed = errors.New("frame fields not allowed")

+ var ErrInputDefinitionActionRequired = errors.New("field definitions require an action")

+ var ErrInputDefinitionAttrsRequired = errors.New("frames and fields are required")

+ var ErrInputDefinitionColumnLabel = errors.New("PrimaryKey field name does not match columnLabel")

+ var ErrInputDefinitionDupePrimaryKey = errors.New("input-definition can only contain one PrimaryKey")

+ var ErrInputDefinitionExists = errors.New("input-definition already exists")

+ var ErrInputDefinitionHasPrimaryKey = errors.New("input-definition must contain one PrimaryKey")

+ var ErrInputDefinitionNameRequired = errors.New("input-definition name required")

+ var ErrInputDefinitionNotFound = errors.New("input-definition not found")

+ var ErrInputDefinitionValueMap = errors.New("valueMap required for map")

+ var ErrInvalidFieldRange = errors.New("invalid field range")

+ var ErrInvalidFieldType = errors.New("invalid field type")

+ var ErrInvalidFieldValueType = errors.New("invalid field value type")

+ var ErrInverseRangeNotAllowed = errors.New("inverse range not allowed")

+ var ErrRangeCacheNotAllowed = errors.New("range cache not allowed")

+ func ContainsSubstring(a string, list []string) bool

+ func CountOpenFiles() int

+ func GetTimeStamp(data map[string]interface{}, timeField string) (int64, error)

+ func IsValidFieldType(v string) bool

+ func StringInSlice(a string, list []string) bool

+ func ValidateField(f *Field) error

+ type Action struct

+ Frame string

+ RowID *uint64

+ ValueDestination string

+ ValueMap map[string]uint64

+ func (a *Action) Encode() *internal.InputDefinitionAction

+ func (a *Action) Validate() error

+ type AttrCache struct

+ func NewAttrCache() *AttrCache

+ func (c *AttrCache) Get(id uint64) map[string]interface{}

+ func (c *AttrCache) Set(id uint64, attrs map[string]interface{})

type Bit

+ func HandleAction(a Action, value interface{}, colID uint64, timestamp int64) (*Bit, error)

type Config

+ Bind string

+ InternalPort string

+ func (c *Config) Validate() error

+ type Field struct

+ Max int64

+ Min int64

+ Name string

+ Type string

+ func (f *Field) BitDepth() uint

type Fragment

+ func (f *Fragment) FieldValue(columnID uint64, bitDepth uint) (value uint64, exists bool, err error)

+ func (f *Fragment) SetFieldValue(columnID uint64, bitDepth uint, value uint64) (changed bool, err error)

type Frame

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

+ func (f *Frame) FieldValue(columnID uint64, name string) (value int64, exists bool, err error)

+ func (f *Frame) RangeEnabled() bool

+ func (f *Frame) Schema() *FrameSchema

+ func (f *Frame) SetFieldValue(columnID uint64, name string, value int64) (changed bool, err error)

type FrameOptions

+ Fields []*Field

+ RangeEnabled bool

+ type FrameSchema struct

+ Fields []*Field

type Handler

+ func (h *Handler) InputJSONDataParser(req map[string]interface{}, index *Index, name string) (map[string][]*Bit, error)

type Index

+ func (i *Index) CreateInputDefinition(pb *internal.InputDefinition) (*InputDefinition, error)

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

+ func (i *Index) InputBits(frame string, bits []*Bit) error

+ func (i *Index) InputDefinition(name string) (*InputDefinition, error)

+ func (i *Index) InputDefinitionPath() string

+ type InputDefinition struct

+ func NewInputDefinition(path, index, name string) (*InputDefinition, error)

+ func (i *InputDefinition) AddFrame(frame InputFrame) error

+ func (i *InputDefinition) Fields() []InputDefinitionField

+ func (i *InputDefinition) Frames() []InputFrame

+ func (i *InputDefinition) LoadDefinition(pb *internal.InputDefinition) error

+ func (i *InputDefinition) Open() error

+ type InputDefinitionField struct

+ Actions []Action

+ Name string

+ PrimaryKey bool

+ func (o *InputDefinitionField) Encode() *internal.InputDefinitionField

+ type InputDefinitionInfo struct

+ Fields []InputDefinitionField

+ Frames []InputFrame

+ func (i *InputDefinitionInfo) Encode() *internal.InputDefinition

+ func (i *InputDefinitionInfo) Validate(columnLabel string) error

+ type InputFrame struct

+ Name string

+ Options FrameOptions

+ func (i *InputFrame) Encode() *internal.Frame

+ func (i *InputFrame) Validate() error

+ type NopCache struct

+ func NewNopCache() *NopCache

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

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

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

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

+ func (c *NopCache) Invalidate()

+ func (c *NopCache) Len() int

+ func (c *NopCache) Recalculate()

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

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

type Server

+ func (s *Server) Logger() *log.Logger

type View

+ func (v *View) FieldValue(columnID uint64, bitDepth uint) (value uint64, exists bool, err error)

+ func (v *View) SetFieldValue(columnID uint64, bitDepth uint, value uint64) (changed bool, err error)

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

Other modules containing this package

github.com/pilosa/pilosa/v2

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