extsort

Jul 31, 2025

Changes in this version

+ type CompareGeneric func(a, b E) int

Jul 29, 2025

Changes in this version

+ func NewComparisonError(cause interface{}, context string) error

+ func NewDeserializationError(cause interface{}, dataSize int, context string) error

+ func NewDiskError(err error, operation, path string) error

+ func NewResourceError(err error, resource, context string) error

+ func NewSerializationError(cause interface{}, context string) error

+ type CompareLessFuncGeneric func(a, b E) bool

+ type ComparisonError struct

+ Cause interface{}

+ Context string

+ func (e *ComparisonError) Error() string

+ func (e *ComparisonError) Unwrap() error

+ type ConfigError struct

+ Field string

+ Reason string

+ Value interface{}

+ func (e *ConfigError) Error() string

+ type DeserializationError struct

+ Cause interface{}

+ Context string

+ DataSize int

+ func (e *DeserializationError) Error() string

+ func (e *DeserializationError) Unwrap() error

+ type FromBytesGeneric func([]byte) E

+ type GenericSorter struct

+ func Generic[E any](input <-chan E, fromBytes FromBytesGeneric[E], toBytes ToBytesGeneric[E], ...) (*GenericSorter[E], <-chan E, <-chan error)

+ func MockGeneric[E any](input <-chan E, fromBytes FromBytesGeneric[E], toBytes ToBytesGeneric[E], ...) (*GenericSorter[E], <-chan E, <-chan error)

+ func (s *GenericSorter[E]) Sort(ctx context.Context)

+ type OrderedSorter struct

+ func OrderedMock[T cmp.Ordered](input <-chan T, config *Config, n int) (*OrderedSorter[T], <-chan T, <-chan error)

+ func Ordered[T cmp.Ordered](input <-chan T, config *Config) (*OrderedSorter[T], <-chan T, <-chan error)

+ type SerializationError struct

+ Cause interface{}

+ Context string

+ func (e *SerializationError) Error() string

+ func (e *SerializationError) Unwrap() error

+ type ToBytesGeneric func(E) []byte

Jul 26, 2025

Changes in this version

type Config

+ NumMergeWorkers int

May 12, 2021

Changes in this version

+ func UniqStringChan(in chan string) chan string

+ type CompareLessFunc func(a, b SortType) bool

+ type Config struct

+ ChanBuffSize int

+ ChunkSize int

+ NumWorkers int

+ SortedChanBuffSize int

+ TempFilesDir string

+ func DefaultConfig() *Config

+ type FromBytes func([]byte) SortType

+ type SortType interface

+ ToBytes func() []byte

+ type SortTypeSorter struct

+ func New(i chan SortType, fromBytes FromBytes, lessFunc CompareLessFunc, config *Config) (*SortTypeSorter, chan SortType, chan error)

+ func NewMock(i chan SortType, fromBytes FromBytes, lessFunc CompareLessFunc, config *Config, ...) (*SortTypeSorter, chan SortType, chan error)

+ func (s *SortTypeSorter) Sort(ctx context.Context)

+ type Sorter interface

+ Sort func(context.Context)

+ type StringSorter struct

+ func Strings(i chan string, config *Config) (*StringSorter, chan string, chan error)

+ func StringsMock(i chan string, config *Config, n int) (*StringSorter, chan string, chan error)

+ func (s *StringSorter) Sort(ctx context.Context)