common

Aug 17, 2022

Changes in this version

+ type BackendBlock interface

+ BlockMeta func() *backend.BlockMeta

type BlockConfig

+ RowGroupSizeBytes int

+ Version string

+ type CacheControl struct

+ ColumnIndex bool

+ Footer bool

+ OffsetIndex bool

type CompactionOptions

+ BytesWritten func(compactionLevel, bytes int)

+ IteratorBufferSize int

+ MaxBytesPerTrace int

+ ObjectsCombined func(compactionLevel, objects int)

+ ObjectsWritten func(compactionLevel, objects int)

+ SpansDiscarded func(spans int)

type SearchOptions

+ CacheControl CacheControl

+ ReadBufferCount int

+ ReadBufferSize int

May 5, 2022

Changes in this version

type CompactionOptions

+ Combiner model.ObjectCombiner

Apr 28, 2022

Changes in this version

+ const NameIndex

+ const NameObjects

+ func BloomName(shard int) string

+ func ValidateConfig(b *BlockConfig) error

+ type BlockConfig struct

+ BloomFP float64

+ BloomShardSizeBytes int

+ Encoding backend.Encoding

+ IndexDownsampleBytes int

+ IndexPageSizeBytes int

+ SearchEncoding backend.Encoding

+ SearchPageSizeBytes int

+ type CompactionOptions struct

+ BlockConfig BlockConfig

+ ChunkSizeBytes uint32

+ FlushSizeBytes uint32

+ OutputBlocks uint8

+ PrefetchTraceCount int

+ func DefaultCompactionOptions() CompactionOptions

+ type Compactor interface

+ Compact func(ctx context.Context, l log.Logger, r backend.Reader, ...) ([]*backend.BlockMeta, error)

type Finder

+ FindTraceByID func(ctx context.Context, id ID) (*tempopb.Trace, error)

+ type SearchOptions struct

+ ChunkSizeBytes uint32

+ MaxBytes int

+ PrefetchTraceCount int

+ StartPage int

+ TotalPages int

+ func DefaultSearchOptions() SearchOptions

+ type Searcher interface

+ Search func(ctx context.Context, req *tempopb.SearchRequest, opts SearchOptions) (*tempopb.SearchResponse, error)

Nov 5, 2021

Changes in this version

+ type DataWriterGeneric interface

+ Complete func(context.Context) error

+ CutPage func(context.Context) (int, error)

+ Write func(context.Context, ID, interface{}) (int, error)

Jun 7, 2021

Changes in this version

+ func SortRecords(records []Record)

+ func ValidateShardCount(shardCount int) int

type ShardedBloomFilter

+ func NewBloom(fp float64, shardSize, estimatedObjects uint) *ShardedBloomFilter

+ func (b *ShardedBloomFilter) GetShardCount() int

+ func (b *ShardedBloomFilter) Marshal() ([][]byte, error)

Apr 21, 2021

Changes in this version

+ var ErrUnsupported = fmt.Errorf("unsupported")

+ type DataReader interface

+ Close func()

+ NextPage func([]byte) ([]byte, error)

+ Read func(context.Context, []*Record, []byte) ([][]byte, []byte, error)

+ type DataWriter interface

+ Complete func() error

+ CutPage func() (int, error)

+ Write func(ID, []byte) (int, error)

+ type IndexWriter interface

+ Write func([]*Record) ([]byte, error)

+ type ObjectReaderWriter interface

+ MarshalObjectToWriter func(id ID, b []byte, w io.Writer) (int, error)

+ UnmarshalAndAdvanceBuffer func(buffer []byte) ([]byte, ID, []byte, error)

+ UnmarshalObjectFromReader func(r io.Reader) (ID, []byte, error)

+ type RecordReaderWriter interface

+ MarshalRecords func(records []*Record) ([]byte, error)

+ MarshalRecordsToBuffer func(records []*Record, buffer []byte) error

+ RecordCount func(b []byte) int

+ RecordLength func() int

+ UnmarshalRecord func(buff []byte) *Record

Feb 18, 2021

Changes in this version

+ func GetShardNum() int

+ func ShardKeyForTraceID(traceID []byte) int

+ type Appender interface

+ Append func(ID, []byte) error

+ Complete func() error

+ DataLength func() uint64

+ Length func() int

+ Records func() []*Record

+ type Finder interface

+ Find func(id ID) ([]byte, error)

+ type ID []byte

+ type IndexReader interface

+ At func(i int) *Record

+ Find func(id ID) (*Record, int)

+ type Iterator interface

+ Close func()

+ Next func() (ID, []byte, error)

+ type ObjectCombiner interface

+ Combine func(objA []byte, objB []byte) []byte

+ type PageReader interface

+ Close func()

+ Read func([]*Record) ([][]byte, error)

+ type Record struct

+ ID ID

+ Length uint32

+ Start uint64

+ type Records []*Record

+ func (r Records) At(i int) *Record

+ func (r Records) Find(id ID) (*Record, int)

+ type ShardedBloomFilter struct

+ func NewWithEstimates(n uint, fp float64) *ShardedBloomFilter

+ func (b *ShardedBloomFilter) Add(traceID []byte)

+ func (b *ShardedBloomFilter) Test(traceID []byte) bool

+ func (b *ShardedBloomFilter) WriteTo() ([][]byte, error)