Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

files

package module

Go to main page

Versions in this module

v1

v1.2.0

Jul 15, 2022

v1.1.0

Jun 19, 2022

Changes in this version

+ var FileRWBlockSize = 1024 * 64

+ var Marshaler = &runtime.JSONPb

+ func CsvFileReader(fd *os.File, valueProcessors ...CsvValueProcessor) (*csvFileReader, error)

type CsvFile

+ Header func() []string

+ Index func() map[string]int

+ Next func() (CsvRecord, 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

+ func OpenCsvStream(fr io.Reader, gzipEnabled bool, valueProcessors ...CsvValueProcessor) (CsvStream, error)

+ Close func() error

+ Read func() ([]string, error)

+ type CsvValueProcessor func(string) string

+ type CsvWriter interface

+ Close func() error

+ Write func(values ...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 ProtoReader interface

+ Close func() error

+ ReadTo func(message proto.Message) error

+ type ProtoWriter interface

+ Close func() error

+ Write func(message proto.Message) ([]byte, error)

v1.0.0

Dec 22, 2021

Changes in this version

+ var PandasEmptyValues = map[string]bool

+ func CsvFile(fd *os.File, valueProcessors ...files_api.CsvValueProcessor) (*csvFileReader, error)

+ func CsvStream(fr io.Reader, gzipEnabled bool, valueProcessors ...files_api.CsvValueProcessor) (files_api.CsvStream, error)

+ func JoinCsvFiles(outputFilePath string, parts []string) error

+ func JoinJsonFiles(outputFilePath string, parts []string) error

+ func JoinProtoFiles(outputFilePath string, row proto.Message, parts []string) error

+ func JsonFile(fd *os.File) (files_api.JsonReader, error)

+ func JsonStream(fr io.Reader, gzipEnabled bool) (files_api.JsonReader, error)

+ func JsonWrite(w io.Writer, object interface{}) error

+ func NewCsvFile(filePath string, valueProcessors ...files_api.CsvValueProcessor) (files_api.CsvWriter, error)

+ func NewCsvSchema(header []string) files_api.CsvSchema

+ func NewCsvStream(fw io.Writer, gzipEnabled bool, valueProcessors ...files_api.CsvValueProcessor) files_api.CsvWriter

+ func NewJsonFile(filePath string) (files_api.JsonWriter, error)

+ func NewJsonStream(fd io.Writer, gzipEnabled bool) files_api.JsonWriter

+ func NewProtoBuf(gzipEnabled bool) (files_api.ProtoWriter, error)

+ func NewProtoFile(filePath string) (files_api.ProtoWriter, error)

+ func NewProtoStream(fd io.Writer, gzipEnabled bool) files_api.ProtoWriter

+ func OpenCsvFile(filePath string, valueProcessors ...files_api.CsvValueProcessor) (files_api.CsvReader, error)

+ func OpenJsonFile(filePath string) (files_api.JsonReader, error)

+ func OpenProtoFile(filePath string) (files_api.ProtoReader, error)

+ func PandasFriendly(v string) string

+ func ProtoFile(fd *os.File) (files_api.ProtoReader, error)

+ func ProtoStream(r io.Reader, gzipEnabled bool) (files_api.ProtoReader, error)

+ func ProtobufWrite(w io.Writer, message proto.Message) ([]byte, error)

+ func RemoveHash(v string) string

+ func SplitCsvFile(inputFilePath string, limit int, partFn func(int) string) ([]string, error)

+ func SplitJsonFile(inputFilePath string, limit int, partFn func(int) string) ([]string, error)

+ func SplitProtoFile(inputFilePath string, holder proto.Message, limit int, partFn func(int) string) ([]string, error)