ziter

Documentation

Index

• Variables
• func ChunkifyIterator[T any](iterator Iterator[T], size int, handler ChunkHandler[T]) (err error)
• func InterfaceToSlice(input interface{}) (slice []interface{}, err error)
• func NewSliceIterator[T any](slice []T) *sliceIterator[T]
• func SliceChunks[T any](items []T, size int, handler ChunkHandler[T]) (err error)
• type ChunkHandler
• type Iterator
  • func TransformIterator[F any, T any](iterator Iterator[F], t TransformFunc[F, T]) Iterator[T]
• type TransformFunc
• type Transformer
• type TransformerIterator
  • func (t *TransformerIterator[F, T]) Next() (item T, done bool, err error)

Variables

var (
	ErrValueNotSlice = errors.New("value is not a slice")
)

Functions

func ChunkifyIterator

func ChunkifyIterator[T any](iterator Iterator[T], size int, handler ChunkHandler[T]) (err error)

func InterfaceToSlice

func InterfaceToSlice(input interface{}) (slice []interface{}, err error)

Convert interface{} into []interface{} if the input is a slice, otherwise, return an error.

func NewSliceIterator

func NewSliceIterator[T any](slice []T) *sliceIterator[T]

func SliceChunks

func SliceChunks[T any](items []T, size int, handler ChunkHandler[T]) (err error)

Break a slice into multiple slices of the provided size

Types

type ChunkHandler

type ChunkHandler[T any] func(chunk []T) error

type Iterator

type Iterator[T any] interface {
	Next() (item T, done bool, err error)
}

func TransformIterator

func TransformIterator[F any, T any](iterator Iterator[F], t TransformFunc[F, T]) Iterator[T]

type TransformFunc

type TransformFunc[F any, T any] func(item F) (res T, skip bool, err error)

type Transformer

type Transformer[F any, T any] interface {
	Transform(item F) (res T, skip bool, err error)
}

type TransformerIterator

type TransformerIterator[F any, T any] struct {
	// contains filtered or unexported fields
}

func (*TransformerIterator[F, T]) Next

func (t *TransformerIterator[F, T]) Next() (item T, done bool, err error)