Documentation ¶
Overview ¶
Package pilosa implements the core of the Pilosa distributed bitmap index. It contains all the domain objects, interfaces, and logic that defines pilosa.
Index ¶
- Constants
- Variables
- func DecodeAttrs(v []byte) (map[string]interface{}, error)
- func EncodeAttrs(attr map[string]interface{}) ([]byte, error)
- func MarshalInternalMessage(m Message, s Serializer) ([]byte, error)
- func NewRankCache(maxEntries uint32) *rankCache
- func OptAPIServer(s *Server) apiOption
- type API
- func (api *API) AvailableShardsByIndex(ctx context.Context) map[string]*roaring.Bitmap
- func (api *API) ClusterMessage(ctx context.Context, reqBody io.Reader) error
- func (api *API) CreateField(ctx context.Context, indexName string, fieldName string, opts ...FieldOption) (*Field, error)
- func (api *API) CreateIndex(ctx context.Context, indexName string, options IndexOptions) (*Index, error)
- func (api *API) DeleteAvailableShard(_ context.Context, indexName, fieldName string, shardID uint64) error
- func (api *API) DeleteField(ctx context.Context, indexName string, fieldName string) error
- func (api *API) DeleteIndex(ctx context.Context, indexName string) error
- func (api *API) DeleteView(ctx context.Context, indexName string, fieldName string, viewName string) error
- func (api *API) ExportCSV(ctx context.Context, indexName string, fieldName string, shard uint64, ...) error
- 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) FragmentBlockData(ctx context.Context, body io.Reader) ([]byte, error)
- func (api *API) FragmentBlocks(ctx context.Context, indexName, fieldName, viewName string, shard uint64) ([]FragmentBlock, error)
- func (api *API) FragmentData(ctx context.Context, indexName, fieldName, viewName string, shard uint64) (io.WriterTo, error)
- func (api *API) GetTranslateData(ctx context.Context, offset int64) (io.ReadCloser, error)
- func (api *API) Hosts(ctx context.Context) []*Node
- func (api *API) Import(ctx context.Context, req *ImportRequest, opts ...ImportOption) error
- func (api *API) ImportRoaring(ctx context.Context, indexName, fieldName string, shard uint64, remote bool, ...) (err error)
- func (api *API) ImportValue(ctx context.Context, req *ImportValueRequest, opts ...ImportOption) 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) Info() serverInfo
- func (api *API) LongQueryTime() time.Duration
- func (api *API) MaxShards(ctx context.Context) map[string]uint64
- func (api *API) Node() *Node
- 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) Schema(ctx context.Context) []*IndexInfo
- func (api *API) SetCoordinator(ctx context.Context, id string) (oldNode, newNode *Node, err error)
- func (api *API) ShardNodes(ctx context.Context, indexName string, shard uint64) ([]*Node, error)
- func (api *API) State() string
- func (api *API) StatsWithTags(tags []string) stats.StatsClient
- func (api *API) TranslateKeys(body io.Reader) ([]byte, error)
- func (api *API) Version() string
- func (api *API) Views(ctx context.Context, indexName string, fieldName string) ([]*view, error)
- type AttrBlock
- type AttrStore
- type BadRequestError
- type Bit
- type BlockDataRequest
- type BlockDataResponse
- type ClusterStatus
- type CmdIO
- type ColumnAttrSet
- type ConflictError
- type CreateFieldMessage
- type CreateIndexMessage
- type CreateShardMessage
- type CreateViewMessage
- type DeleteAvailableShardMessage
- type DeleteFieldMessage
- type DeleteIndexMessage
- type DeleteViewMessage
- type Field
- func (f *Field) AddRemoteAvailableShards(b *roaring.Bitmap) error
- func (f *Field) AvailableShards() *roaring.Bitmap
- 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, opts ...ImportOption) error
- func (f *Field) Index() string
- func (f *Field) Max(filter *Row, name string) (max, count int64, err error)
- func (f *Field) Min(filter *Row, name string) (min, count int64, err error)
- func (f *Field) Name() 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) RemoveAvailableShard(v uint64) 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) Type() string
- func (f *Field) Value(columnID uint64) (value int64, exists bool, err error)
- type FieldInfo
- type FieldOption
- func OptFieldKeys() FieldOption
- func OptFieldTypeBool() FieldOption
- func OptFieldTypeDefault() FieldOption
- func OptFieldTypeInt(min, max int64) FieldOption
- func OptFieldTypeMutex(cacheType string, cacheSize uint32) FieldOption
- func OptFieldTypeSet(cacheType string, cacheSize uint32) FieldOption
- func OptFieldTypeTime(timeQuantum TimeQuantum, opt ...bool) FieldOption
- type FieldOptions
- type FieldRow
- type FieldStatus
- type FieldValue
- type FragmentBlock
- type GCNotifier
- type GroupCount
- type Handler
- type Hasher
- type 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) Field(index, name string) *Field
- func (h *Holder) HasData() (bool, error)
- func (h *Holder) Index(name string) *Index
- func (h *Holder) IndexPath(name string) string
- func (h *Holder) Indexes() []*Index
- func (h *Holder) Open() error
- func (h *Holder) Schema() []*IndexInfo
- type ImportOption
- type ImportOptions
- type ImportRequest
- type ImportResponse
- type ImportRoaringRequest
- type ImportValueRequest
- type Index
- func (i *Index) AvailableShards() *roaring.Bitmap
- func (i *Index) Close() error
- func (i *Index) ColumnAttrStore() AttrStore
- 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
- func (i *Index) Name() string
- func (i *Index) Open() error
- func (i *Index) Options() IndexOptions
- func (i *Index) Path() string
- type IndexInfo
- type IndexOptions
- type IndexStatus
- type InternalClient
- type InternalQueryClient
- type LogEntry
- type Message
- type Node
- type NodeEvent
- type NodeEventType
- type NodeStateMessage
- type NodeStatus
- type Nodes
- type NotFoundError
- type Pair
- type Pairs
- type QueryRequest
- type QueryResponse
- type RecalculateCaches
- type ResizeInstruction
- type ResizeInstructionComplete
- type ResizeSource
- type Row
- func (r *Row) Columns() []uint64
- func (r *Row) Count() uint64
- func (r *Row) Difference(other *Row) *Row
- func (r *Row) Intersect(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 RowIDs
- type RowIdentifiers
- type Schema
- type Serializer
- type Server
- type ServerOption
- func OptServerAntiEntropyInterval(interval time.Duration) ServerOption
- func OptServerAttrStoreFunc(af func(string) AttrStore) ServerOption
- func OptServerClusterDisabled(disabled bool, hosts []string) ServerOption
- func OptServerClusterHasher(h Hasher) ServerOption
- func OptServerDataDir(dir string) ServerOption
- func OptServerDiagnosticsInterval(dur time.Duration) ServerOption
- func OptServerGCNotifier(gcn GCNotifier) ServerOption
- func OptServerInternalClient(c InternalClient) ServerOption
- func OptServerIsCoordinator(is bool) ServerOption
- func OptServerLogger(l logger.Logger) ServerOption
- func OptServerLongQueryTime(dur time.Duration) ServerOption
- func OptServerMaxWritesPerRequest(n int) ServerOption
- func OptServerMetricInterval(dur time.Duration) ServerOption
- func OptServerNodeID(nodeID string) ServerOption
- func OptServerPrimaryTranslateStore(store TranslateStore) ServerOption
- func OptServerPrimaryTranslateStoreFunc(tf func(interface{}) TranslateStore) ServerOption
- func OptServerReplicaN(n int) ServerOption
- func OptServerSerializer(ser Serializer) ServerOption
- func OptServerStatsClient(sc stats.StatsClient) ServerOption
- func OptServerSystemInfo(si SystemInfo) ServerOption
- func OptServerTranslateFileMapSize(mapSize int) ServerOption
- func OptServerURI(uri *URI) ServerOption
- type SetCoordinatorMessage
- type SystemInfo
- type TimeQuantum
- type Topology
- type 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) SetPrimaryStore(id string, ts TranslateStore)
- 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, field string, id uint64) (string, error)
- func (s *TranslateFile) TranslateRowsToUint64(index, field string, values []string) ([]uint64, error)
- func (s *TranslateFile) WriteNotify() <-chan struct{}
- type TranslateFileOption
- type TranslateKeysRequest
- type TranslateKeysResponse
- type TranslateStore
- type URI
- type URIs
- type UpdateCoordinatorMessage
- type ValCount
- type ViewInfo
Constants ¶
const ( // ClusterState represents the state returned in the /status endpoint. ClusterStateStarting = "STARTING" ClusterStateDegraded = "DEGRADED" // cluster is running but we've lost some # of hosts >0 but < replicaN ClusterStateNormal = "NORMAL" ClusterStateResizing = "RESIZING" )
const ( DefaultFieldType = FieldTypeSet DefaultCacheType = CacheTypeRanked // Default ranked field cache DefaultCacheSize = 50000 )
Default field settings.
const ( FieldTypeSet = "set" FieldTypeInt = "int" FieldTypeTime = "time" FieldTypeMutex = "mutex" FieldTypeBool = "bool" )
Field types.
const ( CacheTypeLRU = "lru" CacheTypeRanked = "ranked" CacheTypeNone = "none" )
Cache types.
const ( ShardWidth = 1 << shardWidthExponent // HashBlockSize is the number of rows in a merkle hash block. HashBlockSize = 100 )
const ( LogEntryTypeInsertColumn = 1 LogEntryTypeInsertRow = 2 )
const TimeFormat = "2006-01-02T15:04"
TimeFormat is the go-style time format used to parse string dates.
Variables ¶
var ( ErrHostRequired = errors.New("host required") ErrIndexRequired = errors.New("index required") ErrIndexExists = errors.New("index already exists") ErrIndexNotFound = errors.New("index not found") // ErrFieldRequired is returned when no field is specified. ErrFieldRequired = errors.New("field required") ErrFieldExists = errors.New("field already exists") ErrFieldNotFound = errors.New("field not found") ErrBSIGroupNotFound = errors.New("bsigroup not found") ErrBSIGroupExists = errors.New("bsigroup already exists") ErrBSIGroupNameRequired = errors.New("bsigroup name required") ErrInvalidBSIGroupType = errors.New("invalid bsigroup type") ErrInvalidBSIGroupRange = errors.New("invalid bsigroup range") ErrInvalidBSIGroupValueType = errors.New("invalid bsigroup value type") ErrBSIGroupValueTooLow = errors.New("bsigroup value too low") ErrBSIGroupValueTooHigh = errors.New("bsigroup value too high") ErrInvalidRangeOperation = errors.New("invalid range operation") ErrInvalidBetweenValue = errors.New("invalid value for between operation") ErrInvalidView = errors.New("invalid view") ErrInvalidCacheType = errors.New("invalid cache type") ErrName = errors.New("invalid index or field name, must match [a-z0-9_-]") ErrLabel = errors.New("invalid row or column label, must match [A-Za-z0-9_-]") // ErrFragmentNotFound is returned when a fragment does not exist. ErrFragmentNotFound = errors.New("fragment not found") ErrQueryRequired = errors.New("query required") ErrQueryCancelled = errors.New("query cancelled") ErrQueryTimeout = errors.New("query timeout") ErrTooManyWrites = errors.New("too many write commands") // TODO(2.0) poorly named - used when a *node* doesn't own a shard. Probably // we won't need this error at all by 2.0 though. ErrClusterDoesNotOwnShard = errors.New("node does not own shard") ErrNodeIDNotExists = errors.New("node with provided ID does not exist") ErrNodeNotCoordinator = errors.New("node is not the coordinator") ErrResizeNotRunning = errors.New("no resize job currently running") ErrNotImplemented = errors.New("not implemented") ErrFieldsArgumentRequired = errors.New("fields argument required") ErrExpectedFieldListArgument = errors.New("expected field list argument") )
System errors.
var ( ErrTranslateStoreClosed = errors.New("pilosa: translate store closed") ErrTranslateStoreReaderClosed = errors.New("pilosa: translate store reader closed") ErrReplicationNotSupported = errors.New("pilosa: replication not supported") ErrTranslateStoreReadOnly = errors.New("pilosa: translate store could not find or create key, translate store read only") ErrTranslateReadTargetUndersized = errors.New("pilosa: translate read target is undersized") )
var BuildTime = "not recorded"
var Enterprise = "0"
var EnterpriseEnabled = false
var ErrInvalidTimeQuantum = errors.New("invalid time quantum")
ErrInvalidTimeQuantum is returned when parsing a time quantum.
var NopBroadcaster broadcaster = &nopBroadcaster{}
NopBroadcaster represents a Broadcaster that doesn't do anything.
var Version = "v0.0.0"
Functions ¶
func DecodeAttrs ¶
DecodeAttrs decodes a byte slice into an attribute map.
func EncodeAttrs ¶
EncodeAttrs encodes an attribute map into a byte slice.
func MarshalInternalMessage ¶
func MarshalInternalMessage(m Message, s Serializer) ([]byte, error)
MarshalInternalMessage serializes the pilosa message and adds pilosa internal type info which is used by the internal messaging stuff.
func NewRankCache ¶
func NewRankCache(maxEntries uint32) *rankCache
NewRankCache returns a new instance of RankCache.
func OptAPIServer ¶
func OptAPIServer(s *Server) apiOption
Types ¶
type API ¶
type API struct { Serializer Serializer // contains filtered or unexported fields }
API provides the top level programmatic interface to Pilosa. It is usually wrapped by a handler which provides an external interface (e.g. HTTP).
func (*API) AvailableShardsByIndex ¶
AvailableShardsByIndex returns bitmaps of shards with available by index name.
func (*API) ClusterMessage ¶
PostClusterMessage is for internal use. It decodes a protobuf message out of the body and forwards it to the BroadcastHandler.
func (*API) CreateField ¶
func (api *API) CreateField(ctx context.Context, indexName string, fieldName string, opts ...FieldOption) (*Field, error)
CreateField makes the named field in the named index with the given options. This method currently only takes a single functional option, but that may be changed in the future to support multiple options.
func (*API) CreateIndex ¶
func (api *API) CreateIndex(ctx context.Context, indexName string, options IndexOptions) (*Index, error)
CreateIndex makes a new Pilosa index.
func (*API) DeleteAvailableShard ¶
func (api *API) DeleteAvailableShard(_ context.Context, indexName, fieldName string, shardID uint64) error
DeleteAvailableShard a shard ID from the available shard set cache.
func (*API) DeleteField ¶
DeleteField removes the named field from the named index. If the index is not found, an error is returned. If the field is not found, it is ignored and no action is taken.
func (*API) DeleteIndex ¶
DeleteIndex removes the named index. If the index is not found it does nothing and returns no error.
func (*API) DeleteView ¶
func (api *API) DeleteView(ctx context.Context, indexName string, fieldName string, viewName string) error
DeleteView removes the given view.
func (*API) ExportCSV ¶
func (api *API) ExportCSV(ctx context.Context, indexName string, fieldName string, shard uint64, w io.Writer) error
ExportCSV encodes the fragment designated by the index,field,shard as CSV of the form <row>,<col>
func (*API) FieldAttrDiff ¶
func (*API) FragmentBlockData ¶
FragmentBlockData is an endpoint for internal usage. It is not guaranteed to return anything useful. Currently it returns protobuf encoded row and column ids from a "block" which is a subdivision of a fragment.
func (*API) FragmentBlocks ¶
func (api *API) FragmentBlocks(ctx context.Context, indexName, fieldName, viewName string, shard uint64) ([]FragmentBlock, error)
FragmentBlocks returns the checksums and block ids for all blocks in the specified fragment.
func (*API) FragmentData ¶
func (api *API) FragmentData(ctx context.Context, indexName, fieldName, viewName string, shard uint64) (io.WriterTo, error)
FragmentData returns all data in the specified fragment.
func (*API) GetTranslateData ¶
GetTranslateData provides a reader for key translation logs starting at offset.
func (*API) Hosts ¶
Hosts returns a list of the hosts in the cluster including their ID, URL, and which is the coordinator.
func (*API) Import ¶
func (api *API) Import(ctx context.Context, req *ImportRequest, opts ...ImportOption) error
Import bulk imports data into a particular index,field,shard.
func (*API) ImportRoaring ¶
func (api *API) ImportRoaring(ctx context.Context, indexName, fieldName string, shard uint64, remote bool, req *ImportRoaringRequest) (err error)
ImportRoaring is a low level interface for importing data to Pilosa when extremely high throughput is desired. The data must be encoded in a particular way which may be unintuitive (discussed below). The data is merged with existing data.
It takes as input a roaring bitmap which it uses as the data for the indicated index, field, and shard. The bitmap may be encoded according to the official roaring spec (https://github.com/RoaringBitmap/RoaringFormatSpec), or to the pilosa roaring spec which supports 64 bit integers (https://www.pilosa.com/docs/latest/architecture/#roaring-bitmap-storage-format).
The data should be encoded the same way that Pilosa stores fragments internally. A bit "i" being set in the input bitmap indicates that the bit is set in Pilosa row "i/ShardWidth", and in column (shard*ShardWidth)+(i%ShardWidth). That is to say that "data" represents all of the rows in this shard of this field concatenated together in one long bitmap.
func (*API) ImportValue ¶
func (api *API) ImportValue(ctx context.Context, req *ImportValueRequest, opts ...ImportOption) error
ImportValue bulk imports values into a particular field.
func (*API) IndexAttrDiff ¶
func (api *API) IndexAttrDiff(ctx context.Context, indexName string, blocks []AttrBlock) (map[uint64]map[string]interface{}, error)
IndexAttrDiff
func (*API) Info ¶
func (api *API) Info() serverInfo
Info returns information about this server instance
func (*API) LongQueryTime ¶
LongQueryTime returns the configured threshold for logging/statting long running queries.
func (*API) MaxShards ¶
MaxShards returns the maximum shard number for each index in a map. TODO (2.0): This method has been deprecated. Instead, use AvailableShardsByIndex.
func (*API) Query ¶
func (api *API) Query(ctx context.Context, req *QueryRequest) (QueryResponse, error)
Query parses a PQL query out of the request and executes it.
func (*API) RecalculateCaches ¶
RecalculateCaches forces all TopN caches to be updated. Used mainly for integration tests.
func (*API) RemoveNode ¶
RemoveNode puts the cluster into the "RESIZING" state and begins the job of removing the given node.
func (*API) ResizeAbort ¶
ResizeAbort stops the current resize job.
func (*API) Schema ¶
Schema returns information about each index in Pilosa including which fields they contain.
func (*API) SetCoordinator ¶
SetCoordinator makes a new Node the cluster coordinator.
func (*API) ShardNodes ¶
ShardNodes returns the node and all replicas which should contain a shard's data.
func (*API) State ¶
State returns the cluster state which is usually "NORMAL", but could be "STARTING", "RESIZING", or potentially others. See cluster.go for more details.
func (*API) StatsWithTags ¶
func (api *API) StatsWithTags(tags []string) stats.StatsClient
StatsWithTags returns an instance of whatever implementation of StatsClient pilosa is using with the given tags.
type AttrStore ¶
type AttrStore interface { Path() string Open() error Close() error Attrs(id uint64) (m map[string]interface{}, err error) SetAttrs(id uint64, m map[string]interface{}) error SetBulkAttrs(m map[uint64]map[string]interface{}) error Blocks() ([]AttrBlock, error) BlockData(i uint64) (map[uint64]map[string]interface{}, error) }
AttrStore represents an interface for handling row/column attributes.
type BadRequestError ¶
type BadRequestError struct {
// contains filtered or unexported fields
}
BadRequestError wraps an error value to signify that a request could not be read, decoded, or parsed such that in an HTTP scenario, http.StatusBadRequest would be returned.
func NewBadRequestError ¶
func NewBadRequestError(err error) BadRequestError
NewBadRequestError returns err wrapped in a BadRequestError.
type Bit ¶
Bit represents the intersection of a row and a column. It can be specified by integer ids or string keys.
type BlockDataRequest ¶
type BlockDataResponse ¶
type ClusterStatus ¶
type ColumnAttrSet ¶
type ColumnAttrSet struct { ID uint64 `json:"id,omitempty"` Key string `json:"key,omitempty"` Attrs map[string]interface{} `json:"attrs,omitempty"` }
ColumnAttrSet represents a set of attributes for a vertical column in an index. Can have a set of attributes attached to it.
type ConflictError ¶
type ConflictError struct {
// contains filtered or unexported fields
}
ConflictError wraps an error value to signify that a conflict with an existing resource occurred such that in an HTTP scenario, http.StatusConflict would be returned.
type CreateFieldMessage ¶
type CreateFieldMessage struct { Index string Field string Meta *FieldOptions }
type CreateIndexMessage ¶
type CreateIndexMessage struct { Index string Meta *IndexOptions }
type CreateShardMessage ¶
type CreateViewMessage ¶
type DeleteFieldMessage ¶
type DeleteIndexMessage ¶
type DeleteIndexMessage struct {
Index string
}
type DeleteViewMessage ¶
type Field ¶
type Field struct { Stats stats.StatsClient // contains filtered or unexported fields }
Field represents a container for views.
func NewField ¶
func NewField(path, index, name string, opts FieldOption) (*Field, error)
NewField returns a new instance of field.
func (*Field) AddRemoteAvailableShards ¶
AddRemoteAvailableShards merges the set of available shards into the current known set and saves the set to a file.
func (*Field) AvailableShards ¶
AvailableShards returns a bitmap of shards that contain data.
func (*Field) Import ¶
func (f *Field) Import(rowIDs, columnIDs []uint64, timestamps []*time.Time, opts ...ImportOption) error
Import bulk imports data.
func (*Field) Options ¶
func (f *Field) Options() FieldOptions
Options returns all options for this field.
func (*Field) RemoveAvailableShard ¶
RemoveAvailableShard removes a shard from the bitmap cache.
NOTE: This can be overridden on the next sync so all nodes should be updated.
func (*Field) Row ¶
Row returns a row of the standard view. It seems this method is only being used by the test package, and the fact that it's only allowed on `set` fields is odd. This may be considered for deprecation in a future version.
func (*Field) RowAttrStore ¶
RowAttrStore returns the attribute storage.
func (*Field) RowTime ¶
RowTime gets the row at the particular time with the granularity specified by the quantum.
func (*Field) SetCacheSize ¶
SetCacheSize sets the cache size for ranked fames. Persists to meta file on update. defaults to DefaultCacheSize 50000
func (*Field) Sum ¶
Sum returns the sum and count for a field. An optional filtering row can be provided.
func (*Field) TimeQuantum ¶
func (f *Field) TimeQuantum() TimeQuantum
TimeQuantum returns the time quantum for the field.
type FieldInfo ¶
type FieldInfo struct { Name string `json:"name"` Options FieldOptions `json:"options"` Views []*ViewInfo `json:"views,omitempty"` }
FieldInfo represents schema information for a field.
type FieldOption ¶
type FieldOption func(fo *FieldOptions) error
FieldOption is a functional option type for pilosa.fieldOptions.
func OptFieldKeys ¶
func OptFieldKeys() FieldOption
func OptFieldTypeBool ¶
func OptFieldTypeBool() FieldOption
func OptFieldTypeDefault ¶
func OptFieldTypeDefault() FieldOption
func OptFieldTypeInt ¶
func OptFieldTypeInt(min, max int64) FieldOption
func OptFieldTypeMutex ¶
func OptFieldTypeMutex(cacheType string, cacheSize uint32) FieldOption
func OptFieldTypeSet ¶
func OptFieldTypeSet(cacheType string, cacheSize uint32) FieldOption
func OptFieldTypeTime ¶
func OptFieldTypeTime(timeQuantum TimeQuantum, opt ...bool) FieldOption
OptFieldTypeTime sets the field type to time. Pass true to skip creation of the standard view.
type FieldOptions ¶
type FieldOptions struct { Min int64 `json:"min,omitempty"` Max int64 `json:"max,omitempty"` Keys bool `json:"keys"` NoStandardView bool `json:"noStandardView,omitempty"` CacheSize uint32 `json:"cacheSize,omitempty"` CacheType string `json:"cacheType,omitempty"` Type string `json:"type,omitempty"` TimeQuantum TimeQuantum `json:"timeQuantum,omitempty"` }
FieldOptions represents options to set when initializing a field.
func (*FieldOptions) MarshalJSON ¶
func (o *FieldOptions) MarshalJSON() ([]byte, error)
type FieldRow ¶
type FieldRow struct { Field string `json:"field"` RowID uint64 `json:"rowID"` RowKey string `json:"rowKey,omitempty"` }
FieldRow is used to distinguish rows in a group by result.
func (FieldRow) MarshalJSON ¶
type FieldStatus ¶
type FieldValue ¶
FieldValue represents the value for a column within a range-encoded field.
type FragmentBlock ¶
FragmentBlock represents info about a subsection of the rows in a block. This is used for comparing data in remote blocks for active anti-entropy.
type GCNotifier ¶
type GCNotifier interface { Close() AfterGC() <-chan struct{} }
GCNotifier represents an interface for garbage collection notificationss.
var NopGCNotifier GCNotifier = &nopGCNotifier{}
NopGCNotifier represents a GCNotifier that doesn't do anything.
type GroupCount ¶
func (GroupCount) Compare ¶
func (g GroupCount) Compare(o GroupCount) int
type Hasher ¶
type Hasher interface { // Hashes the key into a number between [0,N). Hash(key uint64, n int) int }
Hasher represents an interface to hash integers into buckets.
type Holder ¶
type Holder struct { NewPrimaryTranslateStore func(interface{}) TranslateStore NewAttrStore func(string) AttrStore // Stats Stats stats.StatsClient // Data directory path. Path string Logger logger.Logger // contains filtered or unexported fields }
Holder represents a container for indexes.
func (*Holder) CreateIndex ¶
func (h *Holder) CreateIndex(name string, opt IndexOptions) (*Index, error)
CreateIndex creates an index. An error is returned if the index already exists.
func (*Holder) CreateIndexIfNotExists ¶
func (h *Holder) CreateIndexIfNotExists(name string, opt IndexOptions) (*Index, error)
CreateIndexIfNotExists returns an index by name. The index is created if it does not already exist.
func (*Holder) DeleteIndex ¶
DeleteIndex removes an index from the holder.
func (*Holder) HasData ¶
HasData returns true if Holder contains at least one index. This is used to determine if the rebalancing of data is necessary when a node joins the cluster.
type ImportOption ¶
type ImportOption func(*ImportOptions) error
ImportOption is a functional option type for API.Import.
func OptImportOptionsClear ¶
func OptImportOptionsClear(c bool) ImportOption
func OptImportOptionsIgnoreKeyCheck ¶
func OptImportOptionsIgnoreKeyCheck(b bool) ImportOption
type ImportOptions ¶
ImportOptions holds the options for the API.Import method.
type ImportRequest ¶
type ImportResponse ¶
type ImportResponse struct {
Err string
}
type ImportRoaringRequest ¶
type ImportValueRequest ¶
type Index ¶
type Index struct { Stats stats.StatsClient // contains filtered or unexported fields }
Index represents a container for fields.
func (*Index) AvailableShards ¶
AvailableShards returns a bitmap of all shards with data in the index.
func (*Index) ColumnAttrStore ¶
ColumnAttrStore returns the storage for column attributes.
func (*Index) CreateField ¶
func (i *Index) CreateField(name string, opts ...FieldOption) (*Field, error)
CreateField creates a field.
func (*Index) CreateFieldIfNotExists ¶
func (i *Index) CreateFieldIfNotExists(name string, opts ...FieldOption) (*Field, error)
CreateFieldIfNotExists creates a field with the given options if it doesn't exist.
func (*Index) DeleteField ¶
DeleteField removes a field from the index.
func (*Index) Options ¶
func (i *Index) Options() IndexOptions
Options returns all options for this index.
type IndexInfo ¶
type IndexInfo struct { Name string `json:"name"` Options IndexOptions `json:"options"` Fields []*FieldInfo `json:"fields"` }
IndexInfo represents schema information for an index.
type IndexOptions ¶
IndexOptions represents options to set when initializing an index.
type IndexStatus ¶
type IndexStatus struct { Name string Fields []*FieldStatus }
type InternalClient ¶
type InternalClient interface { MaxShardByIndex(ctx context.Context) (map[string]uint64, error) Schema(ctx context.Context) ([]*IndexInfo, error) CreateIndex(ctx context.Context, index string, opt IndexOptions) error FragmentNodes(ctx context.Context, index string, shard uint64) ([]*Node, error) Nodes(ctx context.Context) ([]*Node, error) Query(ctx context.Context, index string, queryRequest *QueryRequest) (*QueryResponse, error) QueryNode(ctx context.Context, uri *URI, index string, queryRequest *QueryRequest) (*QueryResponse, error) Import(ctx context.Context, index, field string, shard uint64, bits []Bit, opts ...ImportOption) error ImportK(ctx context.Context, index, field string, bits []Bit, opts ...ImportOption) error EnsureIndex(ctx context.Context, name string, options IndexOptions) error EnsureField(ctx context.Context, indexName string, fieldName string) error EnsureFieldWithOptions(ctx context.Context, index, field string, opt FieldOptions) error ImportValue(ctx context.Context, index, field string, shard uint64, vals []FieldValue, opts ...ImportOption) error ImportValueK(ctx context.Context, index, field string, vals []FieldValue, opts ...ImportOption) error ExportCSV(ctx context.Context, index, field string, shard uint64, w io.Writer) error CreateField(ctx context.Context, index, field string) error CreateFieldWithOptions(ctx context.Context, index, field string, opt FieldOptions) error FragmentBlocks(ctx context.Context, uri *URI, index, field, view string, shard uint64) ([]FragmentBlock, error) BlockData(ctx context.Context, uri *URI, index, field, view string, shard uint64, block int) ([]uint64, []uint64, error) ColumnAttrDiff(ctx context.Context, uri *URI, index string, blks []AttrBlock) (map[uint64]map[string]interface{}, error) RowAttrDiff(ctx context.Context, uri *URI, index, field string, blks []AttrBlock) (map[uint64]map[string]interface{}, error) SendMessage(ctx context.Context, uri *URI, msg []byte) error RetrieveShardFromURI(ctx context.Context, index, field, view string, shard uint64, uri URI) (io.ReadCloser, error) ImportRoaring(ctx context.Context, uri *URI, index, field string, shard uint64, remote bool, req *ImportRoaringRequest) error }
InternalClient should be implemented by any struct that enables any transport between nodes TODO: Refactor Note from Travis: Typically an interface containing more than two or three methods is an indication that something hasn't been architected correctly. While I understand that putting the entire Client behind an interface might require this many methods, I don't want to let it go unquestioned.
type InternalQueryClient ¶
type InternalQueryClient interface {
QueryNode(ctx context.Context, uri *URI, index string, queryRequest *QueryRequest) (*QueryResponse, error)
}
type LogEntry ¶
type LogEntry struct { Type uint8 Index []byte Field []byte IDs []uint64 Keys [][]byte // Length of the entry, in bytes. // This is only populated after ReadFrom() or WriteTo(). Length uint64 }
type Message ¶
type Message interface{}
Message is the interface implemented by all core pilosa types which can be serialized to messages. TODO add at least a single "isMessage()" method.
type Node ¶
type Node struct { ID string `json:"id"` URI URI `json:"uri"` IsCoordinator bool `json:"isCoordinator"` State string `json:"state"` }
Node represents a node in the cluster.
type NodeEvent ¶
type NodeEvent struct { Event NodeEventType Node *Node }
NodeEvent is a single event related to node activity in the cluster.
type NodeEventType ¶
type NodeEventType int
NodeEventType are the types of node events.
const ( NodeJoin NodeEventType = iota NodeLeave NodeUpdate )
type NodeStateMessage ¶
type NodeStatus ¶
type NodeStatus struct { Node *Node Indexes []*IndexStatus Schema *Schema }
type Nodes ¶
type Nodes []*Node
Nodes represents a list of nodes.
func (Nodes) ContainsID ¶
ContainsID returns true if host matches one of the node's id.
type NotFoundError ¶
type NotFoundError struct {
// contains filtered or unexported fields
}
NotFoundError wraps an error value to signify that a resource was not found such that in an HTTP scenario, http.StatusNotFound would be returned.
type Pair ¶
type Pair struct { ID uint64 `json:"id"` Key string `json:"key,omitempty"` Count uint64 `json:"count"` }
Pair holds an id/count pair.
type Pairs ¶
type Pairs []Pair
Pairs is a sortable slice of Pair objects.
func (*Pairs) Pop ¶
func (p *Pairs) Pop() interface{}
Pop removes the minimum element from the Pair slice.
type QueryRequest ¶
type QueryRequest struct { // Index to execute query against. Index string // The query string to parse and execute. Query string // The shards to include in the query execution. // If empty, all shards are included. Shards []uint64 // Return column attributes, if true. ColumnAttrs bool // Do not return row attributes, if true. ExcludeRowAttrs bool // Do not return columns, if true. ExcludeColumns bool // If true, indicates that query is part of a larger distributed query. // If false, this request is on the originating node. Remote bool }
QueryRequest represent a request to process a query.
type QueryResponse ¶
type QueryResponse struct { // Result for each top-level query call. // Can be a Bitmap, Pairs, or uint64. Results []interface{} // Set of column attribute objects matching IDs returned in Result. ColumnAttrSets []*ColumnAttrSet // Error during parsing or execution. Err error }
QueryResponse represent a response from a processed query.
func (*QueryResponse) MarshalJSON ¶
func (resp *QueryResponse) MarshalJSON() ([]byte, error)
MarshalJSON marshals QueryResponse into a JSON-encoded byte slice
type RecalculateCaches ¶
type RecalculateCaches struct{}
type ResizeInstruction ¶
type ResizeInstruction struct { JobID int64 Node *Node Coordinator *Node Sources []*ResizeSource NodeStatus *NodeStatus ClusterStatus *ClusterStatus }
type ResizeSource ¶
type ResizeSource struct { Node *Node `protobuf:"bytes,1,opt,name=Node" json:"Node,omitempty"` Index string `protobuf:"bytes,2,opt,name=Index,proto3" json:"Index,omitempty"` Field string `protobuf:"bytes,3,opt,name=Field,proto3" json:"Field,omitempty"` View string `protobuf:"bytes,4,opt,name=View,proto3" json:"View,omitempty"` Shard uint64 `protobuf:"varint,5,opt,name=Shard,proto3" json:"Shard,omitempty"` }
type Row ¶
type Row struct { // String keys translated to/from segment columns. Keys []string // Attributes associated with the row. Attrs map[string]interface{} // contains filtered or unexported fields }
Row is a set of integers (the associated columns), and attributes which are arbitrary key/value pairs storing metadata about what the row represents.
func (*Row) Difference ¶
Difference returns the diff of r and other.
func (*Row) MarshalJSON ¶
MarshalJSON returns a JSON-encoded byte slice of r.
func (*Row) Segments ¶
func (r *Row) Segments() []rowSegment
Segments returns a list of all segments in the row.
type RowIDs ¶
type RowIDs []uint64
RowIDs is a query return type for just uint64 row ids. It should only be used internally (since RowIdentifiers is the external return type), but it is exported because the proto package needs access to it.
type RowIdentifiers ¶
RowIdentifiers is a return type for a list of row ids or row keys. The names `Rows` and `Keys` are meant to follow the same convention as the Row query which returns `Columns` and `Keys`. TODO: Rename this to something better. Anything.
type Schema ¶
type Schema struct {
Indexes []*IndexInfo
}
Schema contains information about indexes and their configuration.
type Serializer ¶
Serializer is an interface for serializing pilosa types to bytes and back.
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
Server represents a holder wrapped by a running HTTP server.
func NewServer ¶
func NewServer(opts ...ServerOption) (*Server, error)
NewServer returns a new instance of Server.
type ServerOption ¶
ServerOption is a functional option type for pilosa.Server
func OptServerAntiEntropyInterval ¶
func OptServerAntiEntropyInterval(interval time.Duration) ServerOption
func OptServerAttrStoreFunc ¶
func OptServerAttrStoreFunc(af func(string) AttrStore) ServerOption
func OptServerClusterDisabled ¶
func OptServerClusterDisabled(disabled bool, hosts []string) ServerOption
OptClusterDisabled tells the server whether to use a static cluster with the defined hosts. Mostly used for testing.
func OptServerClusterHasher ¶
func OptServerClusterHasher(h Hasher) ServerOption
func OptServerDataDir ¶
func OptServerDataDir(dir string) ServerOption
func OptServerDiagnosticsInterval ¶
func OptServerDiagnosticsInterval(dur time.Duration) ServerOption
func OptServerGCNotifier ¶
func OptServerGCNotifier(gcn GCNotifier) ServerOption
func OptServerInternalClient ¶
func OptServerInternalClient(c InternalClient) ServerOption
func OptServerIsCoordinator ¶
func OptServerIsCoordinator(is bool) ServerOption
func OptServerLogger ¶
func OptServerLogger(l logger.Logger) ServerOption
func OptServerLongQueryTime ¶
func OptServerLongQueryTime(dur time.Duration) ServerOption
func OptServerMaxWritesPerRequest ¶
func OptServerMaxWritesPerRequest(n int) ServerOption
func OptServerMetricInterval ¶
func OptServerMetricInterval(dur time.Duration) ServerOption
func OptServerNodeID ¶
func OptServerNodeID(nodeID string) ServerOption
func OptServerPrimaryTranslateStore ¶
func OptServerPrimaryTranslateStore(store TranslateStore) ServerOption
DEPRECATED
func OptServerPrimaryTranslateStoreFunc ¶
func OptServerPrimaryTranslateStoreFunc(tf func(interface{}) TranslateStore) ServerOption
func OptServerReplicaN ¶
func OptServerReplicaN(n int) ServerOption
func OptServerSerializer ¶
func OptServerSerializer(ser Serializer) ServerOption
func OptServerStatsClient ¶
func OptServerStatsClient(sc stats.StatsClient) ServerOption
func OptServerSystemInfo ¶
func OptServerSystemInfo(si SystemInfo) ServerOption
func OptServerTranslateFileMapSize ¶
func OptServerTranslateFileMapSize(mapSize int) ServerOption
func OptServerURI ¶
func OptServerURI(uri *URI) ServerOption
type SetCoordinatorMessage ¶
type SetCoordinatorMessage struct {
New *Node
}
type SystemInfo ¶
type SystemInfo interface { Uptime() (uint64, error) Platform() (string, error) Family() (string, error) OSVersion() (string, error) KernelVersion() (string, error) MemFree() (uint64, error) MemTotal() (uint64, error) MemUsed() (uint64, error) CPUArch() string }
SystemInfo collects information about the host OS.
type TimeQuantum ¶
type TimeQuantum string
TimeQuantum represents a time granularity for time-based bitmaps.
func (TimeQuantum) HasDay ¶
func (q TimeQuantum) HasDay() bool
HasDay returns true if the quantum contains a 'D' unit.
func (TimeQuantum) HasHour ¶
func (q TimeQuantum) HasHour() bool
HasHour returns true if the quantum contains a 'H' unit.
func (TimeQuantum) HasMonth ¶
func (q TimeQuantum) HasMonth() bool
HasMonth returns true if the quantum contains a 'M' unit.
func (TimeQuantum) HasYear ¶
func (q TimeQuantum) HasYear() bool
HasYear returns true if the quantum contains a 'Y' unit.
func (*TimeQuantum) Set ¶
func (q *TimeQuantum) Set(value string) error
Set sets the time quantum value.
func (TimeQuantum) String ¶
func (q TimeQuantum) String() string
func (TimeQuantum) Type ¶
func (q TimeQuantum) Type() string
Type returns the type of a time quantum value.
func (TimeQuantum) Valid ¶
func (q TimeQuantum) Valid() bool
Valid returns true if q is a valid time quantum value.
type Topology ¶
type Topology struct {
// contains filtered or unexported fields
}
Topology represents the list of hosts in the cluster.
func (*Topology) ContainsID ¶
ContainsID returns true if id matches one of the topology's IDs.
type TranslateFile ¶
type TranslateFile struct { Path string // If non-nil, data is streamed from a primary and this is a read-only store. PrimaryTranslateStore TranslateStore // contains filtered or unexported fields }
TranslateFile is an on-disk storage engine for translating string-to-uint64 values.
func NewTranslateFile ¶
func NewTranslateFile(opts ...TranslateFileOption) *TranslateFile
NewTranslateFile returns a new instance of TranslateFile.
func (*TranslateFile) Close ¶
func (s *TranslateFile) Close() (err error)
func (*TranslateFile) Closing ¶
func (s *TranslateFile) Closing() <-chan struct{}
Closing returns a channel that is closed when the store is closed.
func (*TranslateFile) Open ¶
func (s *TranslateFile) Open() (err error)
func (*TranslateFile) Reader ¶
func (s *TranslateFile) Reader(ctx context.Context, offset int64) (io.ReadCloser, error)
Reader returns a reader that streams the underlying data file.
func (*TranslateFile) SetPrimaryStore ¶
func (s *TranslateFile) SetPrimaryStore(id string, ts TranslateStore)
SetPrimaryStore sets the translate files's primary translate store. The id value is used to determine whether the primary needs to be changed from the current value (i.e. calling this multiple times with the same input values will no-op on all subsequent calls).
func (*TranslateFile) TranslateColumnToString ¶
func (s *TranslateFile) TranslateColumnToString(index string, value uint64) (string, error)
TranslateColumnToString converts a uint64 id to its associated string value. If the id is not associated with a string value then a blank string is returned.
func (*TranslateFile) TranslateColumnsToUint64 ¶
func (s *TranslateFile) TranslateColumnsToUint64(index string, values []string) ([]uint64, error)
TranslateColumnsToUint64 converts values to a uint64 id. If value does not have an associated id then one is created.
func (*TranslateFile) TranslateRowToString ¶
func (s *TranslateFile) TranslateRowToString(index, field string, id uint64) (string, error)
func (*TranslateFile) TranslateRowsToUint64 ¶
func (s *TranslateFile) TranslateRowsToUint64(index, field string, values []string) ([]uint64, error)
func (*TranslateFile) WriteNotify ¶
func (s *TranslateFile) WriteNotify() <-chan struct{}
WriteNotify returns a channel that is closed when a new entry is written.
type TranslateFileOption ¶
type TranslateFileOption func(f *TranslateFile) error
TranslateFileOption is a functional option type for pilosa.TranslateFile
func OptTranslateFileLogger ¶
func OptTranslateFileLogger(l logger.Logger) TranslateFileOption
func OptTranslateFileMapSize ¶
func OptTranslateFileMapSize(mapSize int) TranslateFileOption
type TranslateKeysRequest ¶
type TranslateKeysResponse ¶
type TranslateKeysResponse struct {
IDs []uint64
}
type TranslateStore ¶
type TranslateStore interface { TranslateColumnsToUint64(index string, values []string) ([]uint64, error) TranslateColumnToString(index string, values uint64) (string, error) TranslateRowsToUint64(index, field string, values []string) ([]uint64, error) TranslateRowToString(index, field string, values uint64) (string, error) // Returns a reader from the given offset of the raw data file. // The returned reader must be closed by the caller when done. Reader(ctx context.Context, off int64) (io.ReadCloser, error) }
TranslateStore is the storage for translation string-to-uint64 values.
type URI ¶
type URI struct { Scheme string `json:"scheme"` Host string `json:"host"` Port uint16 `json:"port"` }
URI represents a Pilosa URI. A Pilosa URI consists of three parts: 1) Scheme: Protocol of the URI. Default: http. 2) Host: Hostname or IP URI. Default: localhost. IPv6 addresses should be written in brackets, e.g., `[fd42:4201:f86b:7e09:216:3eff:fefa:ed80]`. 3) Port: Port of the URI. Default: 10101.
All parts of the URI are optional. The following are equivalent:
http://localhost:10101 http://localhost http://:10101 localhost:10101 localhost :10101
func AddressWithDefaults ¶
AddressWithDefaults converts addr into a valid address, using defaults when necessary.
func NewURIFromAddress ¶
NewURIFromAddress parses the passed address and returns a URI.
func NewURIFromHostPort ¶
NewURIFromHostPort returns a URI with specified host and port.
func (*URI) MarshalJSON ¶
MarshalJSON marshals URI into a JSON-encoded byte slice.
func (*URI) UnmarshalJSON ¶
type UpdateCoordinatorMessage ¶
type UpdateCoordinatorMessage struct {
New *Node
}
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
Package cmd contains all the pilosa subcommand definitions (1 per file).
|
Package cmd contains all the pilosa subcommand definitions (1 per file). |
pilosa
This is the entrypoint for the Pilosa binary.
|
This is the entrypoint for the Pilosa binary. |
package ctl contains all pilosa subcommands other than 'server'.
|
package ctl contains all pilosa subcommands other than 'server'. |
encoding
|
|
Package enterprise injects enterprise implementations of various Pilosa features when Pilosa is built with "ENTERPRISE=1 make install".
|
Package enterprise injects enterprise implementations of various Pilosa features when Pilosa is built with "ENTERPRISE=1 make install". |
Package lru implements an LRU cache.
|
Package lru implements an LRU cache. |
Package pql defines the Pilosa Query Language.
|
Package pql defines the Pilosa Query Language. |
Package roaring implements roaring bitmaps with support for incremental changes.
|
Package roaring implements roaring bitmaps with support for incremental changes. |