csv

Documentation

Index

• type KaminoCsvLoader
  • func NewLoader(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer) (*KaminoCsvLoader, error)
  • func (cl *KaminoCsvLoader) Close(log *logrus.Entry) error
  • func (cl *KaminoCsvLoader) Load(log *logrus.Entry) (types.Record, error)
  • func (cl *KaminoCsvLoader) Name() string
  • func (cl *KaminoCsvLoader) Next() bool
• type KaminoCsvSaver
  • func NewSaver(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer) (*KaminoCsvSaver, error)
  • func (cs *KaminoCsvSaver) Close(log *logrus.Entry) error
  • func (cs *KaminoCsvSaver) Name() string
  • func (cs *KaminoCsvSaver) Reset(log *logrus.Entry) error
  • func (cs *KaminoCsvSaver) Save(log *logrus.Entry, record types.Record) error

Types

type KaminoCsvLoader

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

KaminoCsvLoader specifc state for database Saver provider.

func NewLoader

func NewLoader(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer) (*KaminoCsvLoader, error)

NewLoader open the encoding process on provider file, read the header from the first line and return a Loader compatible object.

func (*KaminoCsvLoader) Close

func (cl *KaminoCsvLoader) Close(log *logrus.Entry) error

Close closes the datasource.

func (*KaminoCsvLoader) Load

func (cl *KaminoCsvLoader) Load(log *logrus.Entry) (types.Record, error)

Load reads the next record and return it.

func (*KaminoCsvLoader) Name

func (cl *KaminoCsvLoader) Name() string

Name give the name of the destination.

func (*KaminoCsvLoader) Next

func (cl *KaminoCsvLoader) Next() bool

Next moves to next record and return false if there is no more records.

type KaminoCsvSaver

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

KaminoCsvSaver specifc state for database Saver provider.

func NewSaver

func NewSaver(ctx context.Context, log *logrus.Entry, ds datasource.Datasourcer) (*KaminoCsvSaver, error)

NewSaver open the encoding process on provider file and return a Saver compatible object.

func (*KaminoCsvSaver) Close

func (cs *KaminoCsvSaver) Close(log *logrus.Entry) error

Close closes the destination.

func (*KaminoCsvSaver) Name

func (cs *KaminoCsvSaver) Name() string

Name give the name of the destination.

func (*KaminoCsvSaver) Reset

func (cs *KaminoCsvSaver) Reset(log *logrus.Entry) error

Reset reinitialize the destination (if possible).

func (*KaminoCsvSaver) Save

func (cs *KaminoCsvSaver) Save(log *logrus.Entry, record types.Record) error

Save writes the record to the destination.