batch

Documentation

Overview

Licensed under the GNU General Public License, version 3 or higher.

Index

• type Batch
• type BatchProcessor
  • func NewBatchProcessor(callback Callback, maxTasks int) *BatchProcessor
  • func (this *BatchProcessor) AddBatch(batch Batch)
  • func (this *BatchProcessor) Finish()
  • func (this *BatchProcessor) Terminate()
• type Callback

Types

type Batch

type Batch interface {
	Item(index int) interface{}
	Len() int
}

A batch is a list of arbitrary items.

type BatchProcessor

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

A batch processor feeds items into a goroutine for processing.

func NewBatchProcessor

func NewBatchProcessor(callback Callback, maxTasks int) *BatchProcessor

Create a new batch processor.

func (*BatchProcessor) AddBatch

func (this *BatchProcessor) AddBatch(batch Batch)

Adds a batch to the batch processor.

func (*BatchProcessor) Finish

func (this *BatchProcessor) Finish()

Signals that no more batches are incoming, and then waits for batch processing to complete.

func (*BatchProcessor) Terminate

func (this *BatchProcessor) Terminate()

Forcefully terminates batch processing. This only shuts down the worker routine. Individual processing tasks will continue.

type Callback

type Callback func(item interface{})

Callback function to process items.