marshal

Documentation

Index

• Constants
• Variables
• type FileHeader
• type Reader
  • func NewReader(r io.Reader) *Reader
  • func (r *Reader) ReadFileHeader() (h *FileHeader, err error)
  • func (r *Reader) ReadRows(ncol int) (rows <-chan RowData, err <-chan error)
  • func (r *Reader) ReadTableHeader() (h *TableHeader, err error)
  • func (r *Reader) SkipRows(ncol int) error
• type RowData
• type TableHeader
• type Writer
  • func NewWriter(w io.Writer) *Writer
  • func (d *Writer) WriteFileHeader(h *FileHeader) error
  • func (d *Writer) WriteRowData(r RowData) error
  • func (d *Writer) WriteTableHeader(h *TableHeader) error

Constants

const (
	MarkerTable byte = 231 + iota
	MarkerRow
)

Variables

var ErrInvalidMarker = errors.New("invalid marker")

Types

type FileHeader

type FileHeader struct {
	ServerVersion string
	DatabaseName  string
	DumpStart     time.Time
}

type Reader

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

func NewReader

func NewReader(r io.Reader) *Reader

func (*Reader) ReadFileHeader

func (r *Reader) ReadFileHeader() (h *FileHeader, err error)

func (*Reader) ReadRows

func (r *Reader) ReadRows(ncol int) (rows <-chan RowData, err <-chan error)

func (*Reader) ReadTableHeader

func (r *Reader) ReadTableHeader() (h *TableHeader, err error)

func (*Reader) SkipRows

func (r *Reader) SkipRows(ncol int) error

type RowData

type RowData = []*string

type TableHeader

type TableHeader struct {
	Name      string
	Columns   []string
	CreateSQL string
}

type Writer

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

func NewWriter

func NewWriter(w io.Writer) *Writer

func (*Writer) WriteFileHeader

func (d *Writer) WriteFileHeader(h *FileHeader) error

func (*Writer) WriteRowData

func (d *Writer) WriteRowData(r RowData) error

func (*Writer) WriteTableHeader

func (d *Writer) WriteTableHeader(h *TableHeader) error