pilosa

package module

Go to main page

Versions in this module

v1

v1.3.0

Apr 19, 2019

Changes in this version

+ const DefaultShardWidth

+ const QueryResultTypeGroupCounts

+ const QueryResultTypeRowIDs

+ const QueryResultTypeRowIdentifiers

+ var ErrInvalidAddress = NewError("Invalid address")

+ var ErrSingleServerAddressRequired = NewError("OptClientManualServerAddress requires a single URI or address")

type BoolResult

+ func (BoolResult) GroupCounts() []GroupCount

+ func (BoolResult) RowIdentifiers() RowIdentifiersResult

type Client

+ func (c *Client) ExperimentalReplayImport(r io.Reader) error

+ func (c *Client) Info() (Info, error)

type ClientOption

+ func ExperimentalOptClientLogImports(loc io.Writer) ClientOption

+ func OptClientManualServerAddress(enabled bool) ClientOption

+ func OptClientTracer(tracer opentracing.Tracer) ClientOption

type Field

+ func (f *Field) Opts() FieldOptions

+ func (f *Field) RowRange(rowIDOrKey interface{}, start time.Time, end time.Time) *PQLRowQuery

+ func (f *Field) Rows() *PQLRowsQuery

+ func (f *Field) RowsColumn(columnIDOrKey interface{}) *PQLRowsQuery

+ func (f *Field) RowsLimit(limit int64) *PQLRowsQuery

+ func (f *Field) RowsLimitColumn(limit int64, columnIDOrKey interface{}) *PQLRowsQuery

+ func (f *Field) RowsPrevious(rowIDOrKey interface{}) *PQLRowsQuery

+ func (f *Field) RowsPreviousColumn(rowIDOrKey interface{}, columnIDOrKey interface{}) *PQLRowsQuery

+ func (f *Field) RowsPreviousLimit(rowIDOrKey interface{}, limit int64) *PQLRowsQuery

+ func (f *Field) RowsPreviousLimitColumn(rowIDOrKey interface{}, limit int64, columnIDOrKey interface{}) *PQLRowsQuery

+ type FieldRow struct

+ FieldName string

+ RowID uint64

+ RowKey string

+ type GroupCount struct

+ Count int64

+ Groups []FieldRow

+ type GroupCountResult []GroupCount

+ func (GroupCountResult) Changed() bool

+ func (GroupCountResult) Count() int64

+ func (GroupCountResult) CountItems() []CountResultItem

+ func (GroupCountResult) Row() RowResult

+ func (GroupCountResult) RowIdentifiers() RowIdentifiersResult

+ func (GroupCountResult) Type() uint32

+ func (GroupCountResult) Value() int64

+ func (r GroupCountResult) GroupCounts() []GroupCount

type ImportOption

+ func OptImportRoaring(enable bool) ImportOption

+ func OptImportSort(sorting bool) ImportOption

type Index

+ func (idx *Index) GroupBy(rowsQueries ...*PQLRowsQuery) *PQLBaseQuery

+ func (idx *Index) GroupByFilter(filterQuery *PQLRowQuery, rowsQueries ...*PQLRowsQuery) *PQLBaseQuery

+ func (idx *Index) GroupByLimit(limit int64, rowsQueries ...*PQLRowsQuery) *PQLBaseQuery

+ func (idx *Index) GroupByLimitFilter(limit int64, filterQuery *PQLRowQuery, rowsQueries ...*PQLRowsQuery) *PQLBaseQuery

+ func (idx *Index) HasField(fieldName string) bool

+ func (idx *Index) Opts() IndexOptions

+ type Info struct

+ CPULogicalCores int

+ CPUMHz uint64

+ CPUPhysicalCores int

+ CPUType string

+ Memory uint64

+ ShardWidth uint64

type IntResult

+ func (IntResult) GroupCounts() []GroupCount

+ func (IntResult) RowIdentifiers() RowIdentifiersResult

type NilResult

+ func (NilResult) GroupCounts() []GroupCount

+ func (NilResult) RowIdentifiers() RowIdentifiersResult

+ type NoopSpan struct

+ func (s NoopSpan) BaggageItem(restrictedKey string) string

+ func (s NoopSpan) Context() opentracing.SpanContext

+ func (s NoopSpan) Finish()

+ func (s NoopSpan) FinishWithOptions(opts opentracing.FinishOptions)

+ func (s NoopSpan) Log(data opentracing.LogData)

+ func (s NoopSpan) LogEvent(event string)

+ func (s NoopSpan) LogEventWithPayload(event string, payload interface{})

+ func (s NoopSpan) LogFields(fields ...log.Field)

+ func (s NoopSpan) LogKV(alternatingKeyValues ...interface{})

+ func (s NoopSpan) SetBaggageItem(restrictedKey, value string) opentracing.Span

+ func (s NoopSpan) SetOperationName(operationName string) opentracing.Span

+ func (s NoopSpan) SetTag(key string, value interface{}) opentracing.Span

+ func (s NoopSpan) Tracer() opentracing.Tracer

+ type NoopTracer struct

+ func (t NoopTracer) Extract(format interface{}, carrier interface{}) (opentracing.SpanContext, error)

+ func (t NoopTracer) Inject(sm opentracing.SpanContext, format interface{}, carrier interface{}) error

+ func (t NoopTracer) StartSpan(operationName string, opts ...opentracing.StartSpanOption) opentracing.Span

type PQLBaseQuery

+ func (q *PQLBaseQuery) Serialize() SerializedQuery

type PQLBatchQuery

+ func (q *PQLBatchQuery) Serialize() SerializedQuery

type PQLQuery

+ Serialize func() SerializedQuery

type PQLRowQuery

+ func (q *PQLRowQuery) Serialize() SerializedQuery

+ type PQLRowsQuery struct

+ func NewPQLRowsQuery(pql string, index *Index, err error) *PQLRowsQuery

+ func (q *PQLRowsQuery) Index() *Index

+ func (q *PQLRowsQuery) Serialize() SerializedQuery

+ func (q PQLRowsQuery) Error() error

type QueryResponse

+ func (qr *QueryResponse) ColumnAttrs() []ColumnItem

type QueryResult

+ GroupCounts func() []GroupCount

+ RowIdentifiers func() RowIdentifiersResult

+ type RowIdentifiersResult struct

+ IDs []uint64

+ Keys []string

+ func (RowIdentifiersResult) Changed() bool

+ func (RowIdentifiersResult) Count() int64

+ func (RowIdentifiersResult) CountItems() []CountResultItem

+ func (RowIdentifiersResult) GroupCounts() []GroupCount

+ func (RowIdentifiersResult) Row() RowResult

+ func (RowIdentifiersResult) Type() uint32

+ func (RowIdentifiersResult) Value() int64

+ func (r RowIdentifiersResult) RowIdentifiers() RowIdentifiersResult

type RowResult

+ func (RowResult) GroupCounts() []GroupCount

+ func (RowResult) RowIdentifiers() RowIdentifiersResult

type Schema

+ func (s *Schema) HasIndex(indexName string) bool

type SchemaIndex

+ ShardWidth uint64

+ type SerializedQuery interface

+ HasWriteKeys func() bool

+ String func() string

type TopNResult

+ func (TopNResult) GroupCounts() []GroupCount

+ func (TopNResult) RowIdentifiers() RowIdentifiersResult

type ValCountResult

+ func (ValCountResult) GroupCounts() []GroupCount

+ func (ValCountResult) RowIdentifiers() RowIdentifiersResult

v1.2.0

Dec 24, 2018

Changes in this version

type Field

+ func (f *Field) ClearRow(rowIDOrKey interface{}) *PQLBaseQuery

+ func (f *Field) Store(row *PQLRowQuery, rowIDOrKey interface{}) *PQLBaseQuery

type FieldOption

+ func OptFieldTypeBool() FieldOption

+ func OptFieldTypeMutex(cacheType CacheType, cacheSize int) FieldOption

type FieldOptions

+ func (fo *FieldOptions) Keys() bool

+ func (fo *FieldOptions) NoStandardView() bool

type FieldType

+ const FieldTypeBool

+ const FieldTypeMutex

type ImportOption

+ func OptImportClear(clear bool) ImportOption

type Index

+ func (idx *Index) Options(row *PQLRowQuery, opts ...OptionsOption) *PQLBaseQuery

type IndexOptions

+ func (io IndexOptions) Keys() bool

+ func (io IndexOptions) TrackExistence() bool

+ type OptionsOption func(options *OptionsOptions)

+ func OptOptionsColumnAttrs(enable bool) OptionsOption

+ func OptOptionsExcludeColumns(enable bool) OptionsOption

+ func OptOptionsExcludeRowAttrs(enable bool) OptionsOption

+ func OptOptionsShards(shards ...uint64) OptionsOption

+ type OptionsOptions struct

type SchemaOptions

+ NoStandardView bool

+ TrackExistence bool

type Status

+ LocalID string

+ State string

v1.1.0

Sep 25, 2018

Changes in this version

+ const PQLVersion

type Column

+ ColumnKey string

+ RowKey string

type Index

+ func (idx *Index) Not(row *PQLRowQuery) *PQLRowQuery

type IndexOption

+ func OptIndexTrackExistence(trackExistence bool) IndexOption

+ type SchemaField struct

+ Name string

+ Options SchemaOptions

+ type SchemaIndex struct

+ Fields []SchemaField

+ Name string

+ Options SchemaOptions

+ Shards []uint64

+ type SchemaOptions struct

+ CacheSize uint

+ CacheType string

+ FieldType FieldType

+ Keys bool

+ Max int64

+ Min int64

+ TimeQuantum string

type StatusNode

+ ID string

+ IsCoordinator bool

+ URI StatusURI

+ type StatusURI struct

+ Host string

+ Port uint16

+ Scheme string

v0

v0.10.0

Sep 6, 2018

Changes in this version

+ const CacheSizeDefault

+ const PqlVersion

+ const QueryResultTypeRow

+ var ErrFieldExists = NewError("Field exists")

+ var ErrInvalidFieldName = NewError("Invalid field name")

+ var ErrInvalidFieldOption = NewError("Invalid field option")

+ var ErrNoShard = NewError("Index has no shards")

type BoolResult

+ func (BoolResult) Row() RowResult

type CSVIterator

+ func NewCSVColumnIterator(reader io.Reader) *CSVIterator

+ func NewCSVColumnIteratorWithTimestampFormat(reader io.Reader, timestampFormat string) *CSVIterator

type CSVRecordUnmarshaller

+ func ColumnCSVUnmarshaller() CSVRecordUnmarshaller

+ func ColumnCSVUnmarshallerWithTimestamp(timestampFormat string) CSVRecordUnmarshaller

type CacheType

+ const CacheTypeNone

type Client

+ func (c *Client) CreateField(field *Field) error

+ func (c *Client) EnsureField(field *Field) error

+ func (c *Client) ExportField(field *Field) (RecordIterator, error)

+ func (c *Client) ImportField(field *Field, iterator RecordIterator, options ...ImportOption) error

+ type Column struct

+ ColumnID uint64

+ RowID uint64

+ Timestamp int64

+ func (b Column) Less(other Record) bool

+ func (b Column) Shard(shardWidth uint64) uint64

+ type Field struct

+ func (f *Field) Clear(rowIDOrKey, colIDOrKey interface{}) *PQLBaseQuery

+ func (f *Field) FilterAttrTopN(n uint64, row *PQLRowQuery, attrName string, attrValues ...interface{}) *PQLRowQuery

+ func (f *Field) Name() string

+ func (f *Field) Options() *FieldOptions

+ func (f *Field) Range(rowIDOrKey interface{}, start time.Time, end time.Time) *PQLRowQuery

+ func (f *Field) Row(rowIDOrKey interface{}) *PQLRowQuery

+ func (f *Field) RowTopN(n uint64, row *PQLRowQuery) *PQLRowQuery

+ func (f *Field) Set(rowIDOrKey, colIDOrKey interface{}) *PQLBaseQuery

+ func (f *Field) SetRowAttrs(rowIDOrKey interface{}, attrs map[string]interface{}) *PQLBaseQuery

+ func (f *Field) SetTimestamp(rowIDOrKey, colIDOrKey interface{}, timestamp time.Time) *PQLBaseQuery

+ func (f *Field) String() string

+ func (f *Field) TopN(n uint64) *PQLRowQuery

+ func (field *Field) Between(a int, b int) *PQLRowQuery

+ func (field *Field) Equals(n int) *PQLRowQuery

+ func (field *Field) GT(n int) *PQLRowQuery

+ func (field *Field) GTE(n int) *PQLRowQuery

+ func (field *Field) LT(n int) *PQLRowQuery

+ func (field *Field) LTE(n int) *PQLRowQuery

+ func (field *Field) Max(row *PQLRowQuery) *PQLBaseQuery

+ func (field *Field) Min(row *PQLRowQuery) *PQLBaseQuery

+ func (field *Field) NotEquals(n int) *PQLRowQuery

+ func (field *Field) NotNull() *PQLRowQuery

+ func (field *Field) SetIntValue(colIDOrKey interface{}, value int) *PQLBaseQuery

+ func (field *Field) Sum(row *PQLRowQuery) *PQLBaseQuery

+ type FieldInfo struct

+ Name string

+ type FieldOption func(options *FieldOptions)

+ func OptFieldKeys(keys bool) FieldOption

+ func OptFieldTypeInt(min int64, max int64) FieldOption

+ func OptFieldTypeSet(cacheType CacheType, cacheSize int) FieldOption

+ func OptFieldTypeTime(quantum TimeQuantum) FieldOption

+ type FieldOptions struct

+ func (fo *FieldOptions) CacheSize() int

+ func (fo *FieldOptions) CacheType() CacheType

+ func (fo *FieldOptions) Max() int64

+ func (fo *FieldOptions) Min() int64

+ func (fo *FieldOptions) TimeQuantum() TimeQuantum

+ func (fo *FieldOptions) Type() FieldType

+ func (fo FieldOptions) String() string

+ type FieldType string

+ const FieldTypeDefault

+ const FieldTypeInt

+ const FieldTypeSet

+ const FieldTypeTime

type FieldValue

+ func (v FieldValue) Shard(shardWidth uint64) uint64

type ImportStatusUpdate

+ Shard uint64

type Index

+ func (idx *Index) Field(name string, options ...FieldOption) *Field

+ func (idx *Index) Fields() map[string]*Field

+ type IndexOption func(options *IndexOptions)

+ func OptIndexKeys(keys bool) IndexOption

type IntResult

+ func (IntResult) Row() RowResult

type NilResult

+ func (NilResult) Row() RowResult

+ type PQLRowQuery struct

+ func NewPQLRowQuery(pql string, index *Index, err error) *PQLRowQuery

+ func (q *PQLRowQuery) Index() *Index

+ func (q PQLRowQuery) Error() error

type QueryOption

+ func OptQueryExcludeColumns(enable bool) QueryOption

+ func OptQueryShards(shards ...uint64) QueryOption

type QueryOptions

+ ColumnAttrs bool

+ ExcludeColumns bool

+ ExcludeRowAttrs bool

+ Shards []uint64

type QueryResult

+ Row func() RowResult

type Record

+ Shard func(shardWidth uint64) uint64

+ type RowResult struct

+ Attributes map[string]interface{}

+ Columns []uint64

+ Keys []string

+ func (RowResult) Changed() bool

+ func (RowResult) Count() int64

+ func (RowResult) CountItems() []CountResultItem

+ func (RowResult) Type() uint32

+ func (RowResult) Value() int64

+ func (b RowResult) MarshalJSON() ([]byte, error)

+ func (b RowResult) Row() RowResult

type StatusField

+ Options StatusOptions

type StatusIndex

+ Fields []StatusField

+ Shards []uint64

type StatusOptions

+ FieldType FieldType

+ Keys bool

+ Max int64

+ Min int64

type TopNResult

+ func (TopNResult) Row() RowResult

type ValCountResult

+ func (ValCountResult) Row() RowResult

v0.9.0

May 10, 2018

Changes in this version

+ const QueryResultTypeBitmap

+ const QueryResultTypeBool

+ const QueryResultTypeNil

+ const QueryResultTypePairs

+ const QueryResultTypeUint64

+ const QueryResultTypeValCount

+ const Version

+ var ErrInvalidKey = NewError("Invalid key")

+ var ErrNoFragmentNodes = NewError("No fragment nodes")

+ var ErrNoSlice = NewError("Index has no slices")

+ var ErrUnknownType = NewError("Unknown type")

+ func ValidKey(key string) bool

type Bit

+ func (b Bit) Int64Field(index int) int64

+ func (b Bit) Less(other Record) bool

+ func (b Bit) StringField(index int) string

+ func (b Bit) Uint64Field(index int) uint64

type BitmapResult

+ Keys []string

+ func (BitmapResult) Changed() bool

+ func (BitmapResult) Count() int64

+ func (BitmapResult) CountItems() []CountResultItem

+ func (BitmapResult) Type() uint32

+ func (BitmapResult) Value() int64

+ func (b BitmapResult) Bitmap() BitmapResult

+ func (b BitmapResult) MarshalJSON() ([]byte, error)

+ type BoolResult bool

+ func (BoolResult) Bitmap() BitmapResult

+ func (BoolResult) Count() int64

+ func (BoolResult) CountItems() []CountResultItem

+ func (BoolResult) Type() uint32

+ func (BoolResult) Value() int64

+ func (b BoolResult) Changed() bool

+ type CSVIterator struct

+ func NewCSVIterator(reader io.Reader, unmarshaller CSVRecordUnmarshaller) *CSVIterator

+ func (c *CSVIterator) NextRecord() (Record, error)

+ type CSVRecordUnmarshaller func(text string) (Record, error)

+ func BitCSVUnmarshaller() CSVRecordUnmarshaller

+ func BitCSVUnmarshallerWithTimestamp(timestampFormat string) CSVRecordUnmarshaller

type Client

+ func (c *Client) Status() (Status, error)

type ClientOption

+ func LegacyMode(enable bool) ClientOption

+ func OptClientConnectTimeout(timeout time.Duration) ClientOption

+ func OptClientPoolSizePerRoute(size int) ClientOption

+ func OptClientSocketTimeout(timeout time.Duration) ClientOption

+ func OptClientTLSConfig(config *tls.Config) ClientOption

+ func OptClientTotalPoolSize(size int) ClientOption

+ func SkipVersionCheck() ClientOption

type ColumnItem

+ Key string

type CountResultItem

+ Key string

type FieldValue

+ ColumnKey string

+ func (f FieldValue) Int64Field(index int) int64

+ func (f FieldValue) StringField(index int) string

+ func (f FieldValue) Uint64Field(index int) uint64

+ func (v FieldValue) Less(other Record) bool

type Frame

+ func (f *Frame) BitmapK(rowKey string) *PQLBitmapQuery

+ func (f *Frame) ClearBitK(rowKey string, columnKey string) *PQLBaseQuery

+ func (f *Frame) InverseBitmapK(columnKey string) *PQLBaseQuery

+ func (f *Frame) InverseRangeK(columnKey string, start time.Time, end time.Time) *PQLBitmapQuery

+ func (f *Frame) RangeK(rowKey string, start time.Time, end time.Time) *PQLBitmapQuery

+ func (f *Frame) SetBitK(rowKey string, columnKey string) *PQLBaseQuery

+ func (f *Frame) SetBitTimestampK(rowKey string, columnKey string, timestamp time.Time) *PQLBaseQuery

+ func (f *Frame) SetRowAttrsK(rowKey string, attrs map[string]interface{}) *PQLBaseQuery

type FrameOption

+ func OptFrameCacheSize(size uint) FrameOption

+ func OptFrameIntField(name string, min int, max int) FrameOption

+ type ImportOption func(options *ImportOptions) error

+ func OptImportBatchSize(batchSize int) ImportOption

+ func OptImportStatusChannel(statusChan chan<- ImportStatusUpdate) ImportOption

+ func OptImportStrategy(strategy ImportWorkerStrategy) ImportOption

+ func OptImportThreadCount(count int) ImportOption

+ func OptImportTimeout(timeout time.Duration) ImportOption

+ type ImportOptions struct

+ type ImportStatusUpdate struct

+ ImportedCount int

+ Slice uint64

+ ThreadID int

+ Time time.Duration

+ type ImportWorkerStrategy int

+ const BatchImport

+ const DefaultImport

+ const TimeoutImport

+ type IntResult int64

+ func (IntResult) Bitmap() BitmapResult

+ func (IntResult) Changed() bool

+ func (IntResult) CountItems() []CountResultItem

+ func (IntResult) Type() uint32

+ func (IntResult) Value() int64

+ func (i IntResult) Count() int64

+ type NilResult struct

+ func (NilResult) Bitmap() BitmapResult

+ func (NilResult) Changed() bool

+ func (NilResult) Count() int64

+ func (NilResult) CountItems() []CountResultItem

+ func (NilResult) Type() uint32

+ func (NilResult) Value() int64

type QueryOption

+ func OptQueryColumnAttrs(enable bool) QueryOption

+ func OptQueryExcludeAttrs(enable bool) QueryOption

+ func OptQueryExcludeBits(enable bool) QueryOption

+ func OptQuerySlices(slices ...uint64) QueryOption

+ func Slices(slices ...uint64) QueryOption

type QueryOptions

+ Slices []uint64

type QueryResult

+ Changed func() bool

+ Type func() uint32

+ Value func() int64

type RangeField

+ func (field *RangeField) Equals(n int) *PQLBitmapQuery

+ func (field *RangeField) Max(bitmap *PQLBitmapQuery) *PQLBaseQuery

+ func (field *RangeField) Min(bitmap *PQLBitmapQuery) *PQLBaseQuery

+ func (field *RangeField) NotEquals(n int) *PQLBitmapQuery

+ func (field *RangeField) NotNull() *PQLBitmapQuery

+ func (field *RangeField) SetIntValueK(columnKey string, value int) *PQLBaseQuery

+ type Record interface

+ Int64Field func(index int) int64

+ Less func(other Record) bool

+ StringField func(index int) string

+ Uint64Field func(index int) uint64

+ func FieldValueCSVUnmarshaller(text string) (Record, error)

+ type RecordIterator interface

+ NextRecord func() (Record, error)

+ type SchemaInfo struct

+ Indexes []StatusIndex

type StatusFrame

+ Options StatusOptions

type StatusIndex

+ Options StatusOptions

type StatusNode

+ Port int

+ type StatusOptions struct

+ CacheSize uint

+ CacheType string

+ Fields []StatusField

+ InverseEnabled bool

+ RangeEnabled bool

+ TimeQuantum string

+ type TopNResult []CountResultItem

+ func (TopNResult) Bitmap() BitmapResult

+ func (TopNResult) Changed() bool

+ func (TopNResult) Count() int64

+ func (TopNResult) Type() uint32

+ func (TopNResult) Value() int64

+ func (t TopNResult) CountItems() []CountResultItem

+ type ValCountResult struct

+ Cnt int64

+ Val int64

+ func (ValCountResult) Bitmap() BitmapResult

+ func (ValCountResult) Changed() bool

+ func (ValCountResult) CountItems() []CountResultItem

+ func (ValCountResult) Type() uint32

+ func (c ValCountResult) Count() int64

+ func (c ValCountResult) Value() int64

v0.8.2

Nov 16, 2017

v0.8.0

Nov 16, 2017

Changes in this version

+ var ErrAddrURIClusterExpected = NewError("Addresses, URIs or a cluster is expected")

+ var ErrEmptyCluster = NewError("No usable addresses in the cluster")

+ var ErrFrameExists = NewError("Frame exists")

+ var ErrIndexExists = NewError("Index exists")

+ var ErrInvalidFrameName = NewError("Invalid frame name")

+ var ErrInvalidFrameOption = NewError("Invalid frame option")

+ var ErrInvalidIndexName = NewError("Invalid index name")

+ var ErrInvalidIndexOption = NewError("Invalid index option")

+ var ErrInvalidLabel = NewError("Invalid label")

+ var ErrInvalidQueryOption = NewError("Invalid query option")

+ var ErrTriedMaxHosts = NewError("Tried max hosts, still failing")

type Client

+ func NewClient(addrUriOrCluster interface{}, options ...ClientOption) (*Client, error)

+ func (c *Client) HttpRequest(method string, path string, data []byte, headers map[string]string) (*http.Response, []byte, error)

+ type ClientOption func(options *ClientOptions) error

+ func ConnectTimeout(timeout time.Duration) ClientOption

+ func PoolSizePerRoute(size int) ClientOption

+ func SocketTimeout(timeout time.Duration) ClientOption

+ func TLSConfig(config *tls.Config) ClientOption

+ func TotalPoolSize(size int) ClientOption

type ClientOptions

+ TLSConfig *tls.Config

type CountResultItem

+ func (c *CountResultItem) String() string

type Frame

+ func (f *Frame) Fields() map[string]*RangeField

+ func (f *Frame) String() string

+ type FrameOption func(options *FrameOptions) error

+ func CacheSize(size uint) FrameOption

+ func IntField(name string, min int, max int) FrameOption

+ func InverseEnabled(enabled bool) FrameOption

+ func RangeEnabled(enabled bool) FrameOption

type Index

+ func (idx *Index) String() string

+ type QueryOption func(options *QueryOptions) error

+ func ColumnAttrs(enable bool) QueryOption

+ func ExcludeAttrs(enable bool) QueryOption

+ func ExcludeBits(enable bool) QueryOption

type Schema

+ func (s *Schema) String() string

+ type StatusField struct

+ Max int64

+ Min int64

+ Name string

+ Type string

type StatusMeta

+ Fields []StatusField

+ RangeEnabled bool

type StatusNode

+ Scheme string

type URI

+ func URIFromAddress(host string) *URI

+ func (u *URI) Error() error

+ func (u *URI) HostPort() string

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

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

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

+ func (u *URI) Valid() bool

v0.7.0

Oct 4, 2017

Changes in this version

type CSVBitIterator

+ func NewCSVBitIteratorWithTimestampFormat(reader io.Reader, timestampFormat string) *CSVBitIterator

+ type CSVValueIterator struct

+ func NewCSVValueIterator(reader io.Reader) *CSVValueIterator

+ func (c *CSVValueIterator) NextValue() (FieldValue, error)

type Client

+ func (c *Client) CreateIntField(frame *Frame, name string, min int, max int) error

+ func (c *Client) DeleteField(frame *Frame, name string) error

+ func (c *Client) ImportValueFrame(frame *Frame, field string, valueIterator ValueIterator, batchSize uint) error

+ type FieldValue struct

+ ColumnID uint64

+ Value uint64

type Frame

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

+ func (f *Frame) SetIntFieldValue(columnID uint64, field string, value int) *PQLBaseQuery

+ func (f *Frame) Sum(bitmap *PQLBitmapQuery, field string) *PQLBaseQuery

type FrameOptions

+ RangeEnabled bool

+ func (options *FrameOptions) AddIntField(name string, min int, max int) error

type Index

+ func (d *Index) Xor(bitmaps ...*PQLBitmapQuery) *PQLBitmapQuery

type QueryOptions

+ ExcludeAttrs bool

+ ExcludeBits bool

type QueryResult

+ Sum int64

+ type RangeField struct

+ func (field *RangeField) Between(a int, b int) *PQLBitmapQuery

+ func (field *RangeField) GT(n int) *PQLBitmapQuery

+ func (field *RangeField) GTE(n int) *PQLBitmapQuery

+ func (field *RangeField) LT(n int) *PQLBitmapQuery

+ func (field *RangeField) LTE(n int) *PQLBitmapQuery

+ func (field *RangeField) SetIntValue(columnID uint64, value int) *PQLBaseQuery

+ func (field *RangeField) Sum(bitmap *PQLBitmapQuery) *PQLBaseQuery

+ type ValueIterator interface

+ NextValue func() (FieldValue, error)

v0.5.0

Aug 3, 2017

Changes in this version

+ var ErrorTriedMaxHosts = NewError("Tried max hosts, still failing")

+ type Bit struct

+ ColumnID uint64

+ RowID uint64

+ Timestamp int64

+ type BitIterator interface

+ NextBit func() (Bit, error)

+ type CSVBitIterator struct

+ func NewCSVBitIterator(reader io.Reader) *CSVBitIterator

+ func (c *CSVBitIterator) NextBit() (Bit, error)

type Client

+ func NewClientFromAddresses(addresses []string, options *ClientOptions) (*Client, error)

+ func (c *Client) ExportFrame(frame *Frame, view string) (BitIterator, error)

+ func (c *Client) ImportFrame(frame *Frame, bitIterator BitIterator, batchSize uint) error

+ func (c *Client) SyncSchema(schema *Schema) error

+ func (c *Client) Views(frame *Frame) ([]string, error)

type Frame

+ func (f *Frame) Name() string

type Index

+ func (d *Index) Frames() map[string]*Frame

type QueryResponse

+ ColumnList []*ColumnItem

+ ResultList []*QueryResult

type Schema

+ func NewSchema() *Schema

+ func (s *Schema) Index(name string, options *IndexOptions) (*Index, error)

+ type Status struct

+ Nodes []StatusNode

+ type StatusFrame struct

+ Meta StatusMeta

+ Name string

+ type StatusIndex struct

+ Frames []StatusFrame

+ Meta StatusMeta

+ Name string

+ Slices []uint64

+ type StatusMeta struct

+ CacheSize uint

+ CacheType string

+ ColumnLabel string

+ InverseEnabled bool

+ RowLabel string

+ TimeQuantum string

+ type StatusNode struct

+ Host string

+ Indexes []StatusIndex

v0.4.0

Jun 9, 2017

Changes in this version

type Frame

+ func (f *Frame) InverseBitmapTopN(n uint64, bitmap *PQLBitmapQuery) *PQLBitmapQuery

+ func (f *Frame) InverseFilterFieldTopN(n uint64, bitmap *PQLBitmapQuery, field string, values ...interface{}) *PQLBitmapQuery

+ func (f *Frame) InverseRange(columnID uint64, start time.Time, end time.Time) *PQLBitmapQuery

+ func (f *Frame) InverseTopN(n uint64) *PQLBitmapQuery

v0.3.1

May 1, 2017

Changes in this version

+ var ErrorEmptyCluster = NewError("No usable addresses in the cluster")

+ var ErrorFrameExists = NewError("Frame exists")

+ var ErrorIndexExists = NewError("Index exists")

+ var ErrorInvalidFrameName = NewError("Invalid frame name")

+ var ErrorInvalidIndexName = NewError("Invalid index name")

+ var ErrorInvalidLabel = NewError("Invalid label")

+ var ErrorInverseBitmapsNotEnabled = NewError("Inverse bitmaps support was not enabled for this frame")

+ func ValidFrameName(name string) bool

+ func ValidIndexName(name string) bool

+ func ValidLabel(label string) bool

+ type BitmapResult struct

+ Attributes map[string]interface{}

+ Bits []uint64

+ type CacheType string

+ const CacheTypeDefault

+ const CacheTypeLRU

+ const CacheTypeRanked

+ type Client struct

+ func DefaultClient() *Client

+ func NewClientWithCluster(cluster *Cluster, options *ClientOptions) *Client

+ func NewClientWithURI(uri *URI) *Client

+ func (c *Client) CreateFrame(frame *Frame) error

+ func (c *Client) CreateIndex(index *Index) error

+ func (c *Client) DeleteFrame(frame *Frame) error

+ func (c *Client) DeleteIndex(index *Index) error

+ func (c *Client) EnsureFrame(frame *Frame) error

+ func (c *Client) EnsureIndex(index *Index) error

+ func (c *Client) Query(query PQLQuery, options *QueryOptions) (*QueryResponse, error)

+ func (c *Client) Schema() (*Schema, error)

+ type ClientOptions struct

+ ConnectTimeout time.Duration

+ PoolSizePerRoute int

+ SocketTimeout time.Duration

+ TotalPoolSize int

+ type Cluster struct

+ func DefaultCluster() *Cluster

+ func NewClusterWithHost(hosts ...*URI) *Cluster

+ func (c *Cluster) AddHost(address *URI)

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

+ func (c *Cluster) Hosts() []URI

+ func (c *Cluster) RemoveHost(address *URI)

+ type ColumnItem struct

+ Attributes map[string]interface{}

+ ID uint64

+ type CountResultItem struct

+ Count uint64

+ ID uint64

+ type Error struct

+ Message string

+ func NewError(message string) *Error

+ func (e Error) Error() string

+ type Frame struct

+ func (f *Frame) Bitmap(rowID uint64) *PQLBitmapQuery

+ func (f *Frame) BitmapTopN(n uint64, bitmap *PQLBitmapQuery) *PQLBitmapQuery

+ func (f *Frame) ClearBit(rowID uint64, columnID uint64) *PQLBaseQuery

+ func (f *Frame) FilterFieldTopN(n uint64, bitmap *PQLBitmapQuery, field string, values ...interface{}) *PQLBitmapQuery

+ func (f *Frame) InverseBitmap(columnID uint64) *PQLBaseQuery

+ func (f *Frame) Range(rowID uint64, start time.Time, end time.Time) *PQLBitmapQuery

+ func (f *Frame) SetBit(rowID uint64, columnID uint64) *PQLBaseQuery

+ func (f *Frame) SetBitTimestamp(rowID uint64, columnID uint64, timestamp time.Time) *PQLBaseQuery

+ func (f *Frame) SetRowAttrs(rowID uint64, attrs map[string]interface{}) *PQLBaseQuery

+ func (f *Frame) TopN(n uint64) *PQLBitmapQuery

+ type FrameInfo struct

+ Name string

+ type FrameOptions struct

+ CacheSize uint

+ CacheType CacheType

+ InverseEnabled bool

+ RowLabel string

+ TimeQuantum TimeQuantum

+ func (options FrameOptions) String() string

+ type Index struct

+ func NewIndex(name string, options *IndexOptions) (*Index, error)

+ func (d *Index) BatchQuery(queries ...PQLQuery) *PQLBatchQuery

+ func (d *Index) Count(bitmap *PQLBitmapQuery) *PQLBaseQuery

+ func (d *Index) Difference(bitmap1 *PQLBitmapQuery, bitmap2 *PQLBitmapQuery, bitmaps ...*PQLBitmapQuery) *PQLBitmapQuery

+ func (d *Index) Frame(name string, options *FrameOptions) (*Frame, error)

+ func (d *Index) Intersect(bitmap1 *PQLBitmapQuery, bitmap2 *PQLBitmapQuery, bitmaps ...*PQLBitmapQuery) *PQLBitmapQuery

+ func (d *Index) Name() string

+ func (d *Index) RawQuery(query string) *PQLBaseQuery

+ func (d *Index) SetColumnAttrs(columnID uint64, attrs map[string]interface{}) *PQLBaseQuery

+ func (d *Index) Union(bitmap1 *PQLBitmapQuery, bitmap2 *PQLBitmapQuery, bitmaps ...*PQLBitmapQuery) *PQLBitmapQuery

+ type IndexInfo struct

+ Frames []*FrameInfo

+ Name string

+ type IndexOptions struct

+ ColumnLabel string

+ TimeQuantum TimeQuantum

+ func (options IndexOptions) String() string

+ type PQLBaseQuery struct

+ func NewPQLBaseQuery(pql string, index *Index, err error) *PQLBaseQuery

+ func (q *PQLBaseQuery) Index() *Index

+ func (q PQLBaseQuery) Error() error

+ type PQLBatchQuery struct

+ func (q *PQLBatchQuery) Add(query PQLQuery)

+ func (q *PQLBatchQuery) Error() error

+ func (q *PQLBatchQuery) Index() *Index

+ type PQLBitmapQuery struct

+ func NewPQLBitmapQuery(pql string, index *Index, err error) *PQLBitmapQuery

+ func (q *PQLBitmapQuery) Index() *Index

+ func (q PQLBitmapQuery) Error() error

+ type PQLQuery interface

+ Error func() error

+ Index func() *Index

+ type QueryOptions struct

+ Columns bool

+ type QueryResponse struct

+ ErrorMessage string

+ Success bool

+ func (qr *QueryResponse) Column() *ColumnItem

+ func (qr *QueryResponse) Columns() []*ColumnItem

+ func (qr *QueryResponse) Result() *QueryResult

+ func (qr *QueryResponse) Results() []*QueryResult

+ type QueryResult struct

+ Bitmap *BitmapResult

+ Count uint64

+ CountItems []*CountResultItem

+ type Schema struct

+ Indexes []*IndexInfo

+ type TimeQuantum string

+ const TimeQuantumDay

+ const TimeQuantumDayHour

+ const TimeQuantumHour

+ const TimeQuantumMonth

+ const TimeQuantumMonthDay

+ const TimeQuantumMonthDayHour

+ const TimeQuantumNone

+ const TimeQuantumYear

+ const TimeQuantumYearMonth

+ const TimeQuantumYearMonthDay

+ const TimeQuantumYearMonthDayHour

+ 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) Normalize() string

+ func (u *URI) Port() uint16

+ func (u *URI) Scheme() string

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

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