csv

Documentation

Index

• func NewBackend(logger logger.Logger, v3ioContext v3io.Context, config *frames.BackendConfig, ...) (frames.DataBackend, error)
• type Backend
  • func (b *Backend) Create(request *frames.CreateRequest) error
  • func (b *Backend) Delete(request *frames.DeleteRequest) error
  • func (b *Backend) Exec(request *frames.ExecRequest) (frames.Frame, error)
  • func (b *Backend) Read(request *frames.ReadRequest) (frames.FrameIterator, error)
  • func (b *Backend) Write(request *frames.WriteRequest) (frames.FrameAppender, error)
• type FrameIterator
  • func (it *FrameIterator) At() frames.Frame
  • func (it *FrameIterator) Err() error
  • func (it *FrameIterator) Next() bool

Functions

func NewBackend

func NewBackend(logger logger.Logger, v3ioContext v3io.Context, config *frames.BackendConfig, framesConfig *frames.Config) (frames.DataBackend, error)

NewBackend returns a new CSV backend

Types

type Backend

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

Backend is CSV backend

func (*Backend) Create

func (b *Backend) Create(request *frames.CreateRequest) error

Create creates a CSV file

func (*Backend) Delete

func (b *Backend) Delete(request *frames.DeleteRequest) error

Delete will delete a table

func (*Backend) Exec

func (b *Backend) Exec(request *frames.ExecRequest) (frames.Frame, error)

Exec executes a command

func (*Backend) Read

func (b *Backend) Read(request *frames.ReadRequest) (frames.FrameIterator, error)

Read handles reading

func (*Backend) Write

func (b *Backend) Write(request *frames.WriteRequest) (frames.FrameAppender, error)

Write handles writing

type FrameIterator

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

FrameIterator iterates over CSV

func (*FrameIterator) At

func (it *FrameIterator) At() frames.Frame

At return the current Frame

func (*FrameIterator) Err

func (it *FrameIterator) Err() error

Err returns the last error

func (*FrameIterator) Next

func (it *FrameIterator) Next() bool

Next reads the next frame, return true of succeeded