batch

Documentation

Index

• Constants
• type Batch
  • func (o *Batch) Worker(ctx context.Context, images []v1alpha3.CopyImageSchema, ...) error
• type BatchInterface
  • func New(log clog.PluggableLoggerInterface, mirror mirror.MirrorInterface, ...) BatchInterface
• type BatchSchema

Constants

const (
	BATCH_SIZE int = 8
)

Types

type Batch

type Batch struct {
	Log      clog.PluggableLoggerInterface
	Mirror   mirror.MirrorInterface
	Manifest manifest.ManifestInterface
}

func (*Batch) Worker

func (o *Batch) Worker(ctx context.Context, images []v1alpha3.CopyImageSchema, opts mirror.CopyOptions) error

Worker - the main batch processor

type BatchInterface

type BatchInterface interface {
	Worker(ctx context.Context, images []v1alpha3.CopyImageSchema, opts mirror.CopyOptions) error
}

func New

func New(log clog.PluggableLoggerInterface,
	mirror mirror.MirrorInterface,
	manifest manifest.ManifestInterface,
) BatchInterface

type BatchSchema

type BatchSchema struct {
	Writer     io.Writer
	CopyImages []v1alpha3.RelatedImage
	Items      int
	Count      int
	BatchSize  int
	BatchIndex int
	Remainder  int
}