Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CsvFileService ¶
type CsvFileService interface { NewCsvStream(fw io.Writer, withGzip bool, valueProcessors ...CsvValueProcessor) CsvWriter NewCsvFile(filePath string, valueProcessors ...CsvValueProcessor) (CsvWriter, error) OpenCsvStream(fr io.Reader, withGzip bool, valueProcessors ...CsvValueProcessor) (CsvStream, error) OpenCsvFile(filePath string, valueProcessors ...CsvValueProcessor) (CsvReader, error) CsvFileReader(fd *os.File, valueProcessors ...CsvValueProcessor) (CsvReader, error) NewCsvSchema(header []string) CsvSchema SplitCsvFile(inputFilePath string, limit int, partFn func(int) string) ([]string, error) JoinCsvFiles(outputFilePath string, parts []string) error }
type CsvValueProcessor ¶
type FileService ¶
type FileService interface { JsonFileService ProtoFileService CsvFileService BlockSize() int SetBlockSize(rwBlockSize int) MarshalOptions() protojson.MarshalOptions SetMarshalOptions(protojson.MarshalOptions) UnmarshalOptions() protojson.UnmarshalOptions SetUnmarshalOptions(protojson.UnmarshalOptions) }
type JsonFileService ¶
type JsonFileService interface { NewJsonStream(fd io.Writer, withGzip bool) JsonWriter NewJsonFile(filePath string) (JsonWriter, error) JsonStream(fr io.Reader, withGzip bool) (JsonReader, error) OpenJsonFile(filePath string) (JsonReader, error) JsonFile(fd *os.File) (JsonReader, error) SplitJsonFile(inputFilePath string, limit int, partFn func(int) string) ([]string, error) JoinJsonFiles(outputFilePath string, parts []string) error }
type JsonReader ¶
type JsonReader interface { ReadRaw() (json.RawMessage, error) Read(holder interface{}) error Close() error }
type JsonWriter ¶
type JsonWriter interface { WriteRaw(message json.RawMessage) error Write(object interface{}) error Close() error }
type ProtoFileService ¶
type ProtoFileService interface { ProtoStream(r io.Reader, withGzip bool) (ProtoReader, error) OpenProtoFile(filePath string) (ProtoReader, error) ProtoFile(fd *os.File) (ProtoReader, error) NewProtoStream(fd io.Writer, withGzip bool) ProtoWriter NewProtoBuf(gzipEnabled bool) (ProtoWriter, error) NewProtoFile(filePath string) (ProtoWriter, error) SplitProtoFile(inputFilePath string, holder proto.Message, limit int, partFn func(int) string) ([]string, error) JoinProtoFiles(outputFilePath string, row proto.Message, parts []string) error }
Click to show internal directories.
Click to hide internal directories.