Versions in this module Expand all Collapse all v1 v1.1.0 Aug 27, 2023 v1.0.0 Mar 5, 2023 Changes in this version + type CsvFile interface + Header func() []string + Index func() map[string]int + Next func() (CsvRecord, error) + type CsvFileService interface + CsvFileReader func(fd *os.File, valueProcessors ...CsvValueProcessor) (CsvReader, error) + JoinCsvFiles func(outputFilePath string, parts []string) error + NewCsvFile func(filePath string, valueProcessors ...CsvValueProcessor) (CsvWriter, error) + NewCsvSchema func(header []string) CsvSchema + NewCsvStream func(fw io.Writer, withGzip bool, valueProcessors ...CsvValueProcessor) CsvWriter + OpenCsvFile func(filePath string, valueProcessors ...CsvValueProcessor) (CsvReader, error) + OpenCsvStream func(fr io.Reader, withGzip bool, valueProcessors ...CsvValueProcessor) (CsvStream, error) + SplitCsvFile func(inputFilePath string, limit int, partFn func(int) string) ([]string, error) + type CsvReader interface + Close func() error + Read func() ([]string, error) + ReadHeader func() (CsvFile, error) + type CsvRecord interface + Field func(name string, def string) string + Fields func() map[string]string + Record func() []string + type CsvSchema interface + Record func(record []string) CsvRecord + type CsvStream interface + Close func() error + Read func() ([]string, error) + type CsvValueProcessor func(string) string + type CsvWriter interface + Close func() error + Write func(values ...string) error + type FileService interface + BufferSize func() int + MarshalOptions func() protojson.MarshalOptions + SetBufferSize func(rwBufSize int) + SetMarshalOptions func(protojson.MarshalOptions) + SetUnmarshalOptions func(protojson.UnmarshalOptions) + UnmarshalOptions func() protojson.UnmarshalOptions + type JsonFileService interface + JoinJsonFiles func(outputFilePath string, parts []string) error + JsonFile func(fd *os.File) (JsonReader, error) + JsonStream func(fr io.Reader, withGzip bool) (JsonReader, error) + NewJsonFile func(filePath string) (JsonWriter, error) + NewJsonStream func(fd io.Writer, withGzip bool) JsonWriter + OpenJsonFile func(filePath string) (JsonReader, error) + SplitJsonFile func(inputFilePath string, limit int, partitionFn func(int) string) ([]string, error) + type JsonReader interface + Close func() error + Read func(holder interface{}) error + ReadRaw func() (json.RawMessage, error) + type JsonWriter interface + Close func() error + Write func(object interface{}) error + WriteRaw func(message json.RawMessage) error + type ProtoFileService interface + JoinProtoFiles func(outputFilePath string, row proto.Message, parts []string) error + NewProtoBuf func(gzipEnabled bool) (ProtoWriter, error) + NewProtoFile func(filePath string) (ProtoWriter, error) + NewProtoStream func(fd io.Writer, withGzip bool) ProtoWriter + OpenProtoFile func(filePath string) (ProtoReader, error) + ProtoFile func(fd *os.File) (ProtoReader, error) + ProtoStream func(r io.Reader, withGzip bool) (ProtoReader, error) + SplitProtoFile func(inputFilePath string, holder proto.Message, limit int, partFn func(int) string) ([]string, error) + type ProtoReader interface + Close func() error + ReadTo func(message proto.Message) error + type ProtoWriter interface + Close func() error + Write func(message proto.Message) ([]byte, error)
Go to main page