Documentation ¶
Overview ¶
Package file 实现了文件输入流和输出流的框架,可以用于所有类二维表文件输入输出 文件输入流InStreamer框架,可以通过如下方式读取文件
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterCreator ¶
RegisterCreator 通过创建器名称name注册输出流创建器creator
func RegisterOpener ¶
RegisterOpener 通过打开器名称name注册输入流打开器opener
Types ¶
type FetchHandler ¶
type FetchHandler interface { OnRecord(element.Record) error //处理记录 CreateRecord() (element.Record, error) //创建空记录 }
FetchHandler 获取记录句柄
type InStream ¶
type InStream interface { Rows(conf *config.JSON) (rows Rows, err error) //获取行读取器 Close() (err error) //关闭输入流 }
InStream 输入流
type InStreamer ¶
type InStreamer struct {
// contains filtered or unexported fields
}
InStreamer 输入流包装
func NewInStreamer ¶
func NewInStreamer(name string, filename string) (streamer *InStreamer, err error)
NewInStreamer 通过opener名称name的输入流打开器,并打开名为filename的输入流
func (*InStreamer) Read ¶
func (s *InStreamer) Read(ctx context.Context, conf *config.JSON, handler FetchHandler) (err error)
Read 使用获取记录句柄handler,传入上下文ctx和配置文件conf获取对应数据
type OutStream ¶
type OutStream interface { Writer(conf *config.JSON) (writer StreamWriter, err error) //创建写入器 Close() (err error) //关闭输出流 }
OutStream 输出流
type OutStreamer ¶
type OutStreamer struct {
// contains filtered or unexported fields
}
OutStreamer 输出流包装
func NewOutStreamer ¶
func NewOutStreamer(name string, filename string) (streamer *OutStreamer, err error)
NewOutStreamer 通过creator名称name的输出流包装,并打开名为filename的输出流
func (*OutStreamer) Writer ¶
func (s *OutStreamer) Writer(conf *config.JSON) (StreamWriter, error)
Writer 通过配置conf创建流写入器
Click to show internal directories.
Click to hide internal directories.