reader

Documentation

Index

• type CsvReader
  • func (r *CsvReader) Bind(ctx api.StreamContext, fileStream io.Reader, _ int) error
  • func (r *CsvReader) Close(ctx api.StreamContext) error
  • func (r *CsvReader) IsBytesReader() bool
  • func (r *CsvReader) Provision(ctx api.StreamContext, props map[string]any) error
  • func (r *CsvReader) Read(ctx api.StreamContext) (any, error)
• type LinesReader
  • func (r *LinesReader) Bind(ctx api.StreamContext, fileStream io.Reader, maxSize int) error
  • func (r *LinesReader) Close(ctx api.StreamContext) error
  • func (r *LinesReader) IsBytesReader() bool
  • func (r *LinesReader) Provision(ctx api.StreamContext, props map[string]any) error
  • func (r *LinesReader) Read(ctx api.StreamContext) (any, error)

Types

type CsvReader

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

func (*CsvReader) Bind

func (r *CsvReader) Bind(ctx api.StreamContext, fileStream io.Reader, _ int) error

func (*CsvReader) Close

func (r *CsvReader) Close(ctx api.StreamContext) error

func (*CsvReader) IsBytesReader

func (r *CsvReader) IsBytesReader() bool

func (*CsvReader) Provision

func (r *CsvReader) Provision(ctx api.StreamContext, props map[string]any) error

func (*CsvReader) Read

func (r *CsvReader) Read(ctx api.StreamContext) (any, error)

type LinesReader

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

func (*LinesReader) Bind

func (r *LinesReader) Bind(ctx api.StreamContext, fileStream io.Reader, maxSize int) error

func (*LinesReader) Close

func (r *LinesReader) Close(ctx api.StreamContext) error

func (*LinesReader) IsBytesReader

func (r *LinesReader) IsBytesReader() bool

func (*LinesReader) Provision

func (r *LinesReader) Provision(ctx api.StreamContext, props map[string]any) error

func (*LinesReader) Read

func (r *LinesReader) Read(ctx api.StreamContext) (any, error)