Versions in this module Expand all Collapse all v0 v0.0.68 Apr 16, 2026 Changes in this version + type BlameConfigProcessor struct + func NewBlameConfigProcessor(params *BlameConfigProcessorParams) *BlameConfigProcessor + func (p *BlameConfigProcessor) Run(ctx context.Context, e api.Entry, poolFactory pool.VirtualPoolFactory) (*sdcpb.BlameTreeElement, error) + type BlameConfigProcessorParams struct + IncludeDefaults bool + type BlameConfigTask struct + func NewBlameConfigTask(e api.Entry, c *BlameConfigProcessorParams) *BlameConfigTask + func (t *BlameConfigTask) Run(ctx context.Context, submit func(pool.Task) error) error + type Collector struct + func NewCollector[T any](cap int) *Collector[T] + func (c *Collector[T]) Append(x T) + func (c *Collector[T]) AppendAll(xs []T) + func (c *Collector[T]) Len() int + type ExplicitDeleteProcessor struct + func NewExplicitDeleteProcessor(params *ExplicitDeleteTaskParams) *ExplicitDeleteProcessor + func (edp *ExplicitDeleteProcessor) GetCreatedExplicitDeleteLeafEntries() api.LeafVariantSlice + func (edp *ExplicitDeleteProcessor) GetExplicitDeleteCreationCount() int + func (p *ExplicitDeleteProcessor) Run(ctx context.Context, e api.Entry, poolFactory pool.VirtualPoolFactory) error + type ExplicitDeleteProcessorStat interface + GetCreatedExplicitDeleteLeafEntries func() api.LeafVariantSlice + GetExplicitDeleteCreationCount func() int + type ExplicitDeleteProcessorStatCollection map[string]ExplicitDeleteProcessorStat + func (e ExplicitDeleteProcessorStatCollection) ContainsEntries() bool + func (e ExplicitDeleteProcessorStatCollection) Count() int + func (e ExplicitDeleteProcessorStatCollection) Stats() map[string]int + type ExplicitDeleteTaskParams struct + Owner string + Priority int32 + type ImportConfigProcessor struct + func NewImportConfigProcessor(importer treeimporter.ImportConfigAdapter, ...) *ImportConfigProcessor + func (p *ImportConfigProcessor) GetStats() *types.ImportStats + func (p *ImportConfigProcessor) Run(ctx context.Context, e api.Entry, poolFactory pool.VirtualPoolFactory) error + type MarkOwnerDeleteProcessor struct + func NewOwnerDeleteMarker(params *OwnerDeleteMarkerProcessorParams) *MarkOwnerDeleteProcessor + func (p *MarkOwnerDeleteProcessor) Run(e api.Entry, poolFactory pool.VirtualPoolFactory) error + type OwnerDeleteMarkerProcessorParams struct + OnlyIntended bool + Owner string + type RemoveDeletedProcessor struct + func NewRemoveDeletedProcessor(params *RemoveDeletedProcessorParams) *RemoveDeletedProcessor + func (p *RemoveDeletedProcessor) GetDeleteStatsCount() int64 + func (p *RemoveDeletedProcessor) GetZeroLengthLeafVariantEntries() []api.Entry + func (p *RemoveDeletedProcessor) Run(e api.Entry, poolFactory pool.VirtualPoolFactory) error + type RemoveDeletedProcessorParams struct + Owner string + type ResetFlagsProcessor struct + func NewResetFlagsProcessor(params *ResetFlagsProcessorParams) *ResetFlagsProcessor + func (p *ResetFlagsProcessor) Run(e api.Entry, poolFactory pool.VirtualPoolFactory) error + func (r *ResetFlagsProcessor) GetAdjustedFlagsCount() int64 + type ResetFlagsProcessorParams struct + DeleteFlag bool + NewFlag bool + UpdateFlag bool + func (r *ResetFlagsProcessorParams) SetDeleteFlag() *ResetFlagsProcessorParams + func (r *ResetFlagsProcessorParams) SetNewFlag() *ResetFlagsProcessorParams + func (r *ResetFlagsProcessorParams) SetUpdateFlag() *ResetFlagsProcessorParams
Go to main page