converter

Documentation

Index

• type DataHolder
• type Option
  • func WithErrWriter(errWriter io.Writer) Option
  • func WithFailOnConvertErrors() Option
  • func WithThreads(threads int) Option
  • func WithThreadsBuffer(threadBuffer int) Option
• type Processor
  • func NewProcessor(strategy Strategy, opts ...Option) *Processor
  • func (p *Processor) Process(ctx context.Context) error
• type Strategy

Types

type DataHolder

type DataHolder = interface{}

type Option

type Option func(*conf)

func WithErrWriter

func WithErrWriter(errWriter io.Writer) Option

func WithFailOnConvertErrors

func WithFailOnConvertErrors() Option

func WithThreads

func WithThreads(threads int) Option

func WithThreadsBuffer

func WithThreadsBuffer(threadBuffer int) Option

type Processor

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

func NewProcessor

func NewProcessor(strategy Strategy, opts ...Option) *Processor

func (*Processor) Process

func (p *Processor) Process(ctx context.Context) error

type Strategy

type Strategy interface {
	Read() (DataHolder, error)
	Decode(DataHolder) error

	Encode(DataHolder) error
	Write(DataHolder) error
}