Versions in this module Expand all Collapse all v2 v2.4.3 Mar 21, 2022 Changes in this version + const StorageEngineBlocks + const StorageEngineChunks + const StorageTypeAWS + const StorageTypeAWSDynamo + const StorageTypeAzure + const StorageTypeBigTable + const StorageTypeBigTableHashed + const StorageTypeBoltDB + const StorageTypeCassandra + const StorageTypeFileSystem + const StorageTypeGCP + const StorageTypeGCPColumnKey + const StorageTypeGCS + const StorageTypeGrpc + const StorageTypeInMemory + const StorageTypeS3 + const StorageTypeSwift + 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 NewChunkClient(name string, cfg Config, schemaCfg chunk.SchemaConfig, ...) (chunk.Client, error) + func NewIndexClient(name string, cfg Config, schemaCfg chunk.SchemaConfig, limits StoreLimits, ...) (chunk.IndexClient, error) + func NewObjectClient(name string, cfg Config, clientMetrics ClientMetrics) (chunk.ObjectClient, error) + func NewStore(cfg Config, storeCfg chunk.StoreConfig, schemaCfg chunk.SchemaConfig, ...) (chunk.Store, error) + func NewTableClient(name string, cfg Config, registerer prometheus.Registerer) (chunk.TableClient, error) + func RegisterIndexStore(name string, indexClientFactory IndexClientFactoryFunc, ...) + 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 ClientMetrics struct + AzureMetrics azure.BlobStorageMetrics + func NewClientMetrics() ClientMetrics + func (c *ClientMetrics) Unregister() + type Config struct + AWSStorageConfig aws.StorageConfig + AzureStorageConfig azure.BlobStorageConfig + BoltDBConfig local.BoltDBConfig + CassandraStorageConfig cassandra.Config + DisableBroadIndexQueries bool + Engine string + FSConfig local.FSConfig + GCPStorageConfig gcp.Config + GCSConfig gcp.GCSConfig + GrpcConfig grpc.Config + Hedging hedging.Config + IndexCacheValidity time.Duration + IndexQueriesCacheConfig cache.Config + MaxParallelGetChunk int + Swift openstack.SwiftConfig + func (cfg *Config) RegisterFlags(f *flag.FlagSet) + func (cfg *Config) Validate() error + 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) MarshalToSizedBuffer(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 IndexClientFactoryFunc func(limits StoreLimits) (chunk.IndexClient, error) + 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) MarshalToSizedBuffer(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 + MaxChunksPerQueryFromStore func(userID string) int + MaxQueryLength func(userID string) time.Duration + type TableClientFactoryFunc func() (chunk.TableClient, error) Other modules containing this package github.com/pao214/loki/v3
Go to main page