encoding

Documentation

Index

• Constants
• func DecodeTime(s string) (t time.Time, err error)
• func EncodeTime(t time.Time) []byte
• func ReadPktLine(p *Parser) (s string, err error)
• func WritePktLine(w io.Writer, buf Bufferer, s string) error
• type Bufferer
• type DecodeFunc
  • func DecodeBytes(b []byte) DecodeFunc
  • func DecodeStr(s *string) DecodeFunc
  • func DecodeTimeFunc(t *time.Time) DecodeFunc
• type EncodeFunc
  • func EncodeBytes(b []byte) EncodeFunc
  • func EncodeStr(s string) EncodeFunc
  • func EncodeTimeFunc(t time.Time) EncodeFunc
• type PackfileReader
  • func NewPackfileReader(r io.ReadCloser) (*PackfileReader, error)
  • func (r *PackfileReader) Close() error
  • func (r *PackfileReader) ReadObject() (objType int, b []byte, err error)
• type PackfileWriter
  • func NewPackfileWriter(w io.Writer) (*PackfileWriter, error)
  • func (w *PackfileWriter) WriteObject(objType int, b []byte) (int, error)
• type Parser
  • func NewParser(r io.Reader) *Parser
  • func (r *Parser) NextBytes(n int) ([]byte, error)
  • func (r *Parser) ParseError(format string, a ...interface{}) error
  • func (r *Parser) ReadBytes(b []byte) (int, error)

Constants

const (
	ObjectCommit int = iota + 1
	ObjectTable
	ObjectBlock
)

Functions

func DecodeTime

func DecodeTime(s string) (t time.Time, err error)

func EncodeTime

func EncodeTime(t time.Time) []byte

func ReadPktLine

func ReadPktLine(p *Parser) (s string, err error)

func WritePktLine

func WritePktLine(w io.Writer, buf Bufferer, s string) error

Types

type Bufferer

type Bufferer interface {
	Buffer(n int) []byte
}

type DecodeFunc

type DecodeFunc func(p *Parser) (int, error)

func DecodeBytes

func DecodeBytes(b []byte) DecodeFunc

func DecodeStr

func DecodeStr(s *string) DecodeFunc

func DecodeTimeFunc

func DecodeTimeFunc(t *time.Time) DecodeFunc

type EncodeFunc

type EncodeFunc func(w Bufferer) []byte

func EncodeBytes

func EncodeBytes(b []byte) EncodeFunc

func EncodeStr

func EncodeStr(s string) EncodeFunc

func EncodeTimeFunc

func EncodeTimeFunc(t time.Time) EncodeFunc

type PackfileReader

type PackfileReader struct {
	Version int
	// contains filtered or unexported fields
}

func NewPackfileReader

func NewPackfileReader(r io.ReadCloser) (*PackfileReader, error)

func (*PackfileReader) Close

func (r *PackfileReader) Close() error

func (*PackfileReader) ReadObject

func (r *PackfileReader) ReadObject() (objType int, b []byte, err error)

type PackfileWriter

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

func NewPackfileWriter

func NewPackfileWriter(w io.Writer) (*PackfileWriter, error)

func (*PackfileWriter) WriteObject

func (w *PackfileWriter) WriteObject(objType int, b []byte) (int, error)

type Parser

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

Parser keep track of read position and read into a buffer

func NewParser

func NewParser(r io.Reader) *Parser

func (*Parser) NextBytes

func (r *Parser) NextBytes(n int) ([]byte, error)

func (*Parser) ParseError

func (r *Parser) ParseError(format string, a ...interface{}) error

func (*Parser) ReadBytes

func (r *Parser) ReadBytes(b []byte) (int, error)