logstorage

Oct 2, 2023

Changes in this version

+ const MaxFieldNameSize

type Storage

+ func (s *Storage) IsReadOnly() bool

type StorageConfig

+ MinFreeDiskSpaceBytes int64

type StorageStats

+ IsReadOnly bool

Aug 12, 2023

Changes in this version

type IndexdbStats

+ IndexdbBlocksCount uint64

+ IndexdbItemsCount uint64

+ IndexdbPartsCount uint64

+ IndexdbSizeBytes uint64

Jul 27, 2023

Changes in this version

+ func PutLogRows(lr *LogRows)

+ func PutStreamTags(st *StreamTags)

+ type BlockColumn struct

+ Name string

+ Values []string

+ type DatadbStats struct

+ CompressedFileSize uint64

+ CompressedInmemorySize uint64

+ FileActiveMerges uint64

+ FileBlocks uint64

+ FileMergesTotal uint64

+ FileParts uint64

+ FileRowsCount uint64

+ InmemoryActiveMerges uint64

+ InmemoryBlocks uint64

+ InmemoryMergesTotal uint64

+ InmemoryParts uint64

+ InmemoryRowsCount uint64

+ UncompressedFileSize uint64

+ UncompressedInmemorySize uint64

+ func (s *DatadbStats) RowsCount() uint64

+ type Field struct

+ Name string

+ Value string

+ func (f *Field) Reset()

+ func (f *Field) String() string

+ type IndexdbStats struct

+ StreamsCreatedTotal uint64

+ type LogRows struct

+ func GetLogRows(streamFields, ignoreFields []string) *LogRows

+ func (lr *LogRows) GetRowString(idx int) string

+ func (lr *LogRows) Len() int

+ func (lr *LogRows) Less(i, j int) bool

+ func (lr *LogRows) MustAdd(tenantID TenantID, timestamp int64, fields []Field)

+ func (lr *LogRows) NeedFlush() bool

+ func (lr *LogRows) Reset()

+ func (lr *LogRows) ResetKeepSettings()

+ func (lr *LogRows) Swap(i, j int)

+ type PartitionStats struct

+ type Query struct

+ func ParseQuery(s string) (*Query, error)

+ func (q *Query) String() string

+ type RowFormatter []Field

+ func (rf *RowFormatter) String() string

+ type Storage struct

+ func MustOpenStorage(path string, cfg *StorageConfig) *Storage

+ func (s *Storage) MustAddRows(lr *LogRows)

+ func (s *Storage) MustClose()

+ func (s *Storage) RunQuery(tenantIDs []TenantID, q *Query, stopCh <-chan struct{}, ...)

+ func (s *Storage) UpdateStats(ss *StorageStats)

+ type StorageConfig struct

+ FlushInterval time.Duration

+ FutureRetention time.Duration

+ LogIngestedRows bool

+ LogNewStreams bool

+ Retention time.Duration

+ type StorageStats struct

+ PartitionsCount uint64

+ RowsDroppedTooBigTimestamp uint64

+ RowsDroppedTooSmallTimestamp uint64

+ func (s *StorageStats) Reset()

+ type StreamFilter struct

+ func (sf *StreamFilter) String() string

+ type StreamTags struct

+ func GetStreamTags() *StreamTags

+ func (st *StreamTags) Add(name, value string)

+ func (st *StreamTags) Len() int

+ func (st *StreamTags) Less(i, j int) bool

+ func (st *StreamTags) MarshalCanonical(dst []byte) []byte

+ func (st *StreamTags) Reset()

+ func (st *StreamTags) String() string

+ func (st *StreamTags) Swap(i, j int)

+ func (st *StreamTags) UnmarshalCanonical(src []byte) ([]byte, error)

+ type TenantID struct

+ AccountID uint32

+ ProjectID uint32

+ func GetTenantIDFromRequest(r *http.Request) (TenantID, error)

+ func GetTenantIDFromString(s string) (TenantID, error)

+ func (tid *TenantID) Reset()

+ func (tid *TenantID) String() string

+ type TimeFormatter int64

+ func (tf *TimeFormatter) String() string