reader

Documentation

Index

• Constants
• type PackageReader
  • func NewPackageReader(obj interface{}, buffSize int) *PackageReader
  • func (reader *PackageReader) Read() ([]byte, error)
  • func (reader *PackageReader) ReadJSON(obj interface{}) error
• type RawReader
  • func NewRawReader(conn interface{}, buffSize int) *RawReader
  • func (r *RawReader) Read() ([]byte, error)
  • func (r *RawReader) ReadJSON(obj interface{}) error
• type Reader
  • func NewReader(readerType string, conn interface{}, buffSize int) Reader

Constants

const (
	// ReaderTypeRaw reader type raw
	ReaderTypeRaw = "raw"
	// ReaderTypePackage reader type package
	ReaderTypePackage = "package"
)

Types

type PackageReader

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

PackageReader package reader

func NewPackageReader

func NewPackageReader(obj interface{}, buffSize int) *PackageReader

NewPackageReader new package reader

func (*PackageReader) Read

func (reader *PackageReader) Read() ([]byte, error)

Read read

func (*PackageReader) ReadJSON

func (reader *PackageReader) ReadJSON(obj interface{}) error

ReadJSON read json

type RawReader

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

RawReader raw reader

func NewRawReader

func NewRawReader(conn interface{}, buffSize int) *RawReader

NewRawReader new raw reader

func (*RawReader) Read

func (r *RawReader) Read() ([]byte, error)

Read read

func (*RawReader) ReadJSON

func (r *RawReader) ReadJSON(obj interface{}) error

ReadJSON read json

type Reader

type Reader interface {
	Read() ([]byte, error)
	ReadJSON(obj interface{}) error
}

Reader reader

func NewReader

func NewReader(readerType string, conn interface{}, buffSize int) Reader

NewReader new reader