synccompactor

package

v0.7.23 Latest Latest Go to latest Published: Feb 19, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/conductorone/baton-sdk

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type CompactableSync
type Compactor
- func NewCompactor(ctx context.Context, outputDir string, compactableSyncs []*CompactableSync, ...) (*Compactor, func() error, error)
- func (c *Compactor) Compact(ctx context.Context) (*CompactableSync, error)
type CompactorType
type Option

Constants ¶

This section is empty.

Variables ¶

View Source

var ErrNotEnoughFilesToCompact = errors.New("must provide two or more files to compact")

Functions ¶

This section is empty.

Types ¶

type CompactableSync ¶

type CompactableSync struct {
	FilePath string
	SyncID   string
}

type Compactor ¶

type Compactor struct {
	// contains filtered or unexported fields
}

func NewCompactor ¶

func NewCompactor(ctx context.Context, outputDir string, compactableSyncs []*CompactableSync, opts ...Option) (*Compactor, func() error, error)

func (*Compactor) Compact ¶

func (c *Compactor) Compact(ctx context.Context) (*CompactableSync, error)

type CompactorType ¶ added in v0.3.36

type CompactorType string

const (
	CompactorTypeAttached CompactorType = "attached"
)

type Option ¶ added in v0.3.5

type Option func(*Compactor)

func WithC1ZOptions ¶ added in v0.7.22

func WithC1ZOptions(opts ...dotc1z.C1ZOption) Option

WithC1ZOptions sets the C1Z options to use for the compactor. This allows tweaking C1Z opts such as encoder/decoder parallelism.

func WithCompactorType deprecated added in v0.3.36

func WithCompactorType(compactorType CompactorType) Option

Deprecated: There is now only one compactor type, so this option is no longer needed.

func WithRunDuration ¶ added in v0.5.13

func WithRunDuration(runDuration time.Duration) Option

func WithSyncLimit ¶ added in v0.7.0

func WithSyncLimit(limit int) Option

WithSyncLimit sets the number of syncs to keep after compaction cleanup.

func WithTmpDir ¶ added in v0.3.5

func WithTmpDir(tempDir string) Option

WithTmpDir sets the working directory where files will be created and edited during compaction. If not provided, the temporary directory will be used.

Source Files ¶

View all Source files

compactor.go

Directories ¶

Path	Synopsis
attached

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL