factory

Documentation

Overview

Package factory provides functions to create shards and track their creation progress

• Copyright (c) 2024-2025, NVIDIA CORPORATION. All rights reserved.

Package factory provides functions to create shards and track their creation progress

• Copyright (c) 2024, NVIDIA CORPORATION. All rights reserved.

Index

• type ShardFactory
  • func NewShardFactory(baseParams api.BaseParams, fromBck, toBck cmn.Bck, ext, shardTmpl string, ...) (sf *ShardFactory, err error)
  • func (sf *ShardFactory) Create(recs *shard.Records, size int64, errCh chan error)
  • func (sf *ShardFactory) NewBar(numShards int64)
  • func (sf *ShardFactory) Wait()

Types

type ShardFactory

type ShardFactory struct {

	// Dsort
	OutShardNames []string

	CLItemplate *template.Template
	// contains filtered or unexported fields
}

shardFactory creates shards and keeps track of the progress of their creation

func NewShardFactory

func NewShardFactory(baseParams api.BaseParams, fromBck, toBck cmn.Bck, ext, shardTmpl string, dryRun config.DryRunFlag) (sf *ShardFactory, err error)

func (*ShardFactory) Create

func (sf *ShardFactory) Create(recs *shard.Records, size int64, errCh chan error)

func (*ShardFactory) NewBar

func (sf *ShardFactory) NewBar(numShards int64)

func (*ShardFactory) Wait

func (sf *ShardFactory) Wait()