store

Documentation

Index

• type Column
• type Reader
• type Record
• type Row
  • func (r Row) GetColumn(name string) Column
• type StdLogger
• type Writer

Types

type Column

type Column struct {
	ColumnNumber int
	Name         string
	Value        string
}

Column is a struct to hold all csv values

type Reader

type Reader interface {
	//Read is a function to read all the records from database
	//Record is a callback function of record to be returned to caller
	Read(record Record)
}

Reader is an interface to read all the records from a database

type Record

type Record func(row Row)

Record is a function called by Reader

type Row

type Row struct {
	RowNumber int64
	Columns   []Column
	Error     error
	// contains filtered or unexported fields
}

Row is a struct to hold all csv values

func (Row) GetColumn

func (r Row) GetColumn(name string) Column

GetColumn is a function to return value for a column name

type StdLogger

type StdLogger interface {
	Print(v ...interface{})
	Printf(format string, v ...interface{})
	Println(v ...interface{})
}

StdLogger is used to log messages.

var Logger StdLogger = log.New(ioutil.Discard, "[JN-Migrate] ", log.LstdFlags)

Logger is the instance of a Logger interface that Sarama writes connection management events to. By default it is set to discard all log messages via ioutil.Discard, but you can set it to redirect wherever you want.

type Writer

type Writer interface {
	Initialize() error
	//Write is a function to write all the records in the database
	Write(record Row) (bool, error)
	Flush() error
}

Writer is an interface to write all the records in the a database