wal

Apr 28, 2022

Changes in this version

type Config

+ IngestionSlack time.Duration

type LocalBlock

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

+ type RangeFunc func(obj []byte, dataEncoding string) (uint32, uint32, error)

Nov 5, 2021

Changes in this version

+ func ParseFilename(filename string) (uuid.UUID, string, string, backend.Encoding, string, error)

+ func ReplayWALAndGetRecords(file *os.File, v encoding.VersionedEncoding, enc backend.Encoding, ...) ([]common.Record, error, error)

type AppendBlock

+ func (a *AppendBlock) Append(id common.ID, b []byte) error

+ func (a *AppendBlock) Iterator(combiner common.ObjectCombiner) (encoding.Iterator, error)

type Config

+ SearchEncoding backend.Encoding

type WAL

+ func (w *WAL) ClearFolder(dir string) error

+ func (w *WAL) GetFilepath() string

+ func (w *WAL) NewFile(blockid uuid.UUID, tenantid string, dir string) (*os.File, string, backend.Encoding, error)

Jun 7, 2021

Changes in this version

type WAL

+ func (w *WAL) RescanBlocks(log log.Logger) ([]*AppendBlock, error)

Apr 21, 2021

Changes in this version

type AppendBlock

+ func (h *AppendBlock) BlockID() uuid.UUID

+ func (h *AppendBlock) GetIterator(combiner common.ObjectCombiner) (encoding.Iterator, error)

+ func (h *AppendBlock) Meta() *backend.BlockMeta

type Config

+ BlocksFilepath string

+ Encoding backend.Encoding

+ type LocalBlock struct

+ func NewLocalBlock(ctx context.Context, existingBlock *encoding.BackendBlock, l *local.Backend) (*LocalBlock, error)

+ func (c *LocalBlock) Find(ctx context.Context, id common.ID) ([]byte, error)

+ func (c *LocalBlock) FlushedTime() time.Time

+ func (c *LocalBlock) SetFlushed(ctx context.Context) error

+ func (c *LocalBlock) Write(ctx context.Context, w backend.Writer) error

type ReplayBlock

+ func NewReplayBlock(filename string, path string) (*ReplayBlock, error)

+ func (r *ReplayBlock) BlockID() string

type WAL

+ func (w *WAL) LocalBackend() *local.Backend

Feb 18, 2021

Changes in this version

type AppendBlock

+ func (h *AppendBlock) DataLength() uint64

Dec 2, 2020

Changes in this version

type CompactorBlock

+ func (c *CompactorBlock) CurrentBufferedObjects() int

Nov 10, 2020

Changes in this version

type CompactorBlock

+ func (c *CompactorBlock) CurrentBufferLength() int

type CompleteBlock

+ func NewCompleteBlock() *CompleteBlock

Oct 23, 2020

Changes in this version

+ type AppendBlock struct

+ func (h *AppendBlock) Clear() error

+ func (h *AppendBlock) Complete(w *WAL, combiner encoding.ObjectCombiner) (*CompleteBlock, error)

+ func (h *AppendBlock) Find(id encoding.ID, combiner encoding.ObjectCombiner) ([]byte, error)

+ func (h *AppendBlock) Length() int

+ func (h *AppendBlock) Write(id encoding.ID, b []byte) error

+ type CompactorBlock struct

+ func (c *CompactorBlock) BlockMeta() *encoding.BlockMeta

+ func (c *CompactorBlock) BloomFilter() *bloom.BloomFilter

+ func (c *CompactorBlock) Clear() error

+ func (c *CompactorBlock) Complete()

+ func (c *CompactorBlock) CurrentBuffer() []byte

+ func (c *CompactorBlock) Flushed() error

+ func (c *CompactorBlock) Length() int

+ func (c *CompactorBlock) ObjectFilePath() string

+ func (c *CompactorBlock) Records() []*encoding.Record

+ func (c *CompactorBlock) ResetBuffer()

+ func (c *CompactorBlock) Write(id encoding.ID, object []byte) error

+ type CompleteBlock struct

+ func (c *CompleteBlock) BlockMeta() *encoding.BlockMeta

+ func (c *CompleteBlock) BloomFilter() *bloom.BloomFilter

+ func (c *CompleteBlock) Clear() error

+ func (c *CompleteBlock) Find(id encoding.ID, combiner encoding.ObjectCombiner) ([]byte, error)

+ func (c *CompleteBlock) Flushed() error

+ func (c *CompleteBlock) FlushedTime() time.Time

+ func (c *CompleteBlock) Iterator() (encoding.Iterator, error)

+ func (c *CompleteBlock) ObjectFilePath() string

+ func (c *CompleteBlock) Records() []*encoding.Record

+ type Config struct

+ BloomFP float64

+ CompletedFilepath string

+ Filepath string

+ IndexDownsample int

+ type ReplayBlock struct

+ func (r *ReplayBlock) Clear() error

+ func (r *ReplayBlock) Iterator() (encoding.Iterator, error)

+ func (r *ReplayBlock) TenantID() string

+ type WAL struct

+ func New(c *Config) (*WAL, error)

+ func (w *WAL) AllBlocks() ([]*ReplayBlock, error)

+ func (w *WAL) NewBlock(id uuid.UUID, tenantID string) (*AppendBlock, error)

+ func (w *WAL) NewCompactorBlock(id uuid.UUID, tenantID string, metas []*encoding.BlockMeta, ...) (*CompactorBlock, error)

+ type WriteableBlock interface

+ BlockMeta func() *encoding.BlockMeta

+ BloomFilter func() *bloom.BloomFilter

+ Flushed func() error

+ ObjectFilePath func() string

+ Records func() []*encoding.Record