storage

Sep 8, 2019

Changes in this version

type Config

+ TableStorageConfig ts.Config

Nov 4, 2019

Changes in this version

+ const StorageEngineChunks

+ const StorageEngineTSDB

type Config

+ Engine string

+ func (cfg *Config) Validate() error

Oct 23, 2019

Changes in this version

type Config

+ BTSConfig baidu.BTSConfig

Sep 6, 2019

Changes in this version

type Config

+ TableConfig ts.Config

Sep 4, 2019

Changes in this version

+ var ErrIntOverflowCachingIndexClient = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthCachingIndexClient = fmt.Errorf("proto: negative length found during unmarshaling")

+ var Fixtures = []testutils.Fixture

+ func NewBucketClient(storageConfig Config) (chunk.BucketClient, error)

+ func NewIndexClient(name string, cfg Config, schemaCfg chunk.SchemaConfig) (chunk.IndexClient, error)

+ func NewObjectClient(name string, cfg Config, schemaCfg chunk.SchemaConfig) (chunk.ObjectClient, error)

+ func NewStore(cfg Config, storeCfg chunk.StoreConfig, schemaCfg chunk.SchemaConfig, ...) (chunk.Store, error)

+ func NewTableClient(name string, cfg Config) (chunk.TableClient, error)

+ type Bytes []byte

+ func (bs *Bytes) Compare(other Bytes) int

+ func (bs *Bytes) Equal(other Bytes) bool

+ func (bs *Bytes) Marshal() ([]byte, error)

+ func (bs *Bytes) MarshalTo(data []byte) (n int, err error)

+ func (bs *Bytes) Size() int

+ func (bs *Bytes) Unmarshal(data []byte) error

+ type Config struct

+ AWSStorageConfig aws.StorageConfig

+ BOSConfig bos.Config

+ BoltDBConfig local.BoltDBConfig

+ CassandraStorageConfig cassandra.Config

+ FSConfig local.FSConfig

+ GCPStorageConfig gcp.Config

+ GCSConfig gcp.GCSConfig

+ IndexCacheValidity time.Duration

+ IndexQueriesCacheConfig cache.Config

+ func (cfg *Config) RegisterFlags(f *flag.FlagSet)

+ type Entry struct

+ Column Bytes

+ Value Bytes

+ func (*Entry) Descriptor() ([]byte, []int)

+ func (*Entry) ProtoMessage()

+ func (m *Entry) Marshal() (dAtA []byte, err error)

+ func (m *Entry) MarshalTo(dAtA []byte) (int, error)

+ func (m *Entry) Reset()

+ func (m *Entry) Size() (n int)

+ func (m *Entry) Unmarshal(dAtA []byte) error

+ func (m *Entry) XXX_DiscardUnknown()

+ func (m *Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Entry) XXX_Merge(src proto.Message)

+ func (m *Entry) XXX_Size() int

+ func (m *Entry) XXX_Unmarshal(b []byte) error

+ func (this *Entry) Equal(that interface{}) bool

+ func (this *Entry) GoString() string

+ func (this *Entry) String() string

+ type ReadBatch struct

+ Cardinality int32

+ Entries []Entry

+ Expiry int64

+ Key string

+ func (*ReadBatch) Descriptor() ([]byte, []int)

+ func (*ReadBatch) ProtoMessage()

+ func (b ReadBatch) Iterator() chunk.ReadBatchIterator

+ func (m *ReadBatch) GetCardinality() int32

+ func (m *ReadBatch) GetEntries() []Entry

+ func (m *ReadBatch) GetExpiry() int64

+ func (m *ReadBatch) GetKey() string

+ func (m *ReadBatch) Marshal() (dAtA []byte, err error)

+ func (m *ReadBatch) MarshalTo(dAtA []byte) (int, error)

+ func (m *ReadBatch) Reset()

+ func (m *ReadBatch) Size() (n int)

+ func (m *ReadBatch) Unmarshal(dAtA []byte) error

+ func (m *ReadBatch) XXX_DiscardUnknown()

+ func (m *ReadBatch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *ReadBatch) XXX_Merge(src proto.Message)

+ func (m *ReadBatch) XXX_Size() int

+ func (m *ReadBatch) XXX_Unmarshal(b []byte) error

+ func (this *ReadBatch) Equal(that interface{}) bool

+ func (this *ReadBatch) GoString() string

+ func (this *ReadBatch) String() string

+ type StoreLimits interface

+ CardinalityLimit func(userID string) int

+ MaxChunksPerQuery func(userID string) int

+ MaxQueryLength func(userID string) time.Duration