tlcsv

Oct 16, 2024

Changes in this version

+ func NewShapeFromShapes(shapes []gtfs.Shape) gtfs.Shape

+ func ValidateShapes(shapes []gtfs.Shape) []error

type TmpZipAdapter

+ func NewStoreAdapter(storage string, key string, fragment string) (*TmpZipAdapter, error)

Jul 28, 2023

Changes in this version

type Reader

+ func (reader *Reader) FareMedia() (out chan tl.FareMedia)

Jan 11, 2023

Changes in this version

+ type TmpZipAdapter struct

+ func NewTmpZipAdapterFromReader(reader io.Reader, fragment string) (*TmpZipAdapter, error)

+ func (adapter *TmpZipAdapter) Close() error

+ func (adapter *TmpZipAdapter) Open() error

Aug 29, 2022

Changes in this version

+ func ReadEntities(reader *Reader, efn string) chan T

type Adapter

+ String func() string

type DirAdapter

+ func (adapter *DirAdapter) String() string

type OverlayAdapter

+ func (adapter OverlayAdapter) String() string

type Reader

+ func (reader *Reader) Areas() (out chan tl.Area)

+ func (reader *Reader) FareContainers() (out chan tl.FareContainer)

+ func (reader *Reader) FareLegRules() (out chan tl.FareLegRule)

+ func (reader *Reader) FareProducts() (out chan tl.FareProduct)

+ func (reader *Reader) FareTransferRules() (out chan tl.FareTransferRule)

+ func (reader *Reader) RiderCategories() (out chan tl.RiderCategory)

+ func (reader *Reader) StopAreas() (out chan tl.StopArea)

type URLAdapter

+ func (adapter *URLAdapter) String() string

type Writer

+ func (writer *Writer) WriteExtraColumns(val bool)

type ZipAdapter

+ func (adapter *ZipAdapter) String() string

Apr 21, 2022

Changes in this version

type Adapter

+ func NewAdapter(address string) (Adapter, error)

type Reader

+ func NewReaderFromAdapter(a Adapter) (*Reader, error)

+ func (reader *Reader) String() string

type URLAdapter

+ func NewURLAdapter(address string, opts ...request.RequestOption) *URLAdapter

type Writer

+ func (writer *Writer) String() string

Feb 23, 2022

Changes in this version

type Reader

+ func (reader *Reader) Attributions() (out chan tl.Attribution)

+ func (reader *Reader) Translations() (out chan tl.Translation)

Aug 20, 2021

Changes in this version

type DirAdapter

+ func (adapter *DirAdapter) AddFile(filename string, reader io.Reader) error

type OverlayAdapter

+ func (adapter OverlayAdapter) CreateZip(outfile string) error

+ func (adapter OverlayAdapter) Files() ([]string, error)

Apr 13, 2021

Changes in this version

+ var MapperCache = tags.NewCache(reflectx.NewMapperFunc("csv", tags.ToSnakeCase))

type URLAdapter

+ func (adapter *URLAdapter) SetAuth(auth tl.FeedAuthorization, secret download.Secret)

Sep 5, 2020

Changes in this version

+ func GetString(ent tl.Entity, key string) (string, error)

+ func ReadRows(in io.Reader, cb func(Row)) error

+ func SetString(ent tl.Entity, key string, value string) error

+ type Adapter interface

+ Close func() error

+ DirSHA1 func() (string, error)

+ Exists func() bool

+ Open func() error

+ OpenFile func(string, func(io.Reader)) error

+ Path func() string

+ ReadRows func(string, func(Row)) error

+ SHA1 func() (string, error)

+ type DirAdapter struct

+ func NewDirAdapter(path string) *DirAdapter

+ func (adapter *DirAdapter) Close() error

+ func (adapter *DirAdapter) DirSHA1() (string, error)

+ func (adapter *DirAdapter) Exists() bool

+ func (adapter *DirAdapter) FileInfos() ([]os.FileInfo, error)

+ func (adapter *DirAdapter) Open() error

+ func (adapter *DirAdapter) OpenFile(filename string, cb func(io.Reader)) error

+ func (adapter *DirAdapter) Path() string

+ func (adapter *DirAdapter) ReadRows(filename string, cb func(Row)) error

+ func (adapter *DirAdapter) SHA1() (string, error)

+ func (adapter *DirAdapter) WriteRows(filename string, rows [][]string) error

+ type OverlayAdapter struct

+ func NewOverlayAdapter(paths ...string) OverlayAdapter

+ func (adapter OverlayAdapter) Close() error

+ func (adapter OverlayAdapter) DirSHA1() (string, error)

+ func (adapter OverlayAdapter) Exists() bool

+ func (adapter OverlayAdapter) Open() error

+ func (adapter OverlayAdapter) OpenFile(filename string, cb func(io.Reader)) error

+ func (adapter OverlayAdapter) Path() string

+ func (adapter OverlayAdapter) ReadRows(filename string, cb func(Row)) error

+ func (adapter OverlayAdapter) SHA1() (string, error)

+ type Reader struct

+ func NewReader(path string) (*Reader, error)

+ func (reader *Reader) Agencies() (out chan tl.Agency)

+ func (reader *Reader) CalendarDates() (out chan tl.CalendarDate)

+ func (reader *Reader) Calendars() (out chan tl.Calendar)

+ func (reader *Reader) ContainsFile(filename string) bool

+ func (reader *Reader) FareAttributes() (out chan tl.FareAttribute)

+ func (reader *Reader) FareRules() (out chan tl.FareRule)

+ func (reader *Reader) FeedInfos() (out chan tl.FeedInfo)

+ func (reader *Reader) Frequencies() (out chan tl.Frequency)

+ func (reader *Reader) Levels() (out chan tl.Level)

+ func (reader *Reader) Pathways() (out chan tl.Pathway)

+ func (reader *Reader) ReadEntities(c interface{}) error

+ func (reader *Reader) Routes() (out chan tl.Route)

+ func (reader *Reader) Shapes() chan tl.Shape

+ func (reader *Reader) StopTimes() (out chan tl.StopTime)

+ func (reader *Reader) StopTimesByTripID(tripIDs ...string) chan []tl.StopTime

+ func (reader *Reader) Stops() (out chan tl.Stop)

+ func (reader *Reader) Transfers() (out chan tl.Transfer)

+ func (reader *Reader) Trips() (out chan tl.Trip)

+ func (reader *Reader) ValidateStructure() []error

+ type Row struct

+ Err error

+ Header []string

+ Hindex map[string]int

+ Line int

+ Row []string

+ func (row *Row) Get(k string) (string, bool)

+ type S3Adapter struct

+ func (adapter *S3Adapter) Close() error

+ func (adapter *S3Adapter) Open() error

+ type URLAdapter struct

+ func (adapter *URLAdapter) Close() error

+ func (adapter *URLAdapter) Open() error

+ type Writer struct

+ func NewWriter(path string) (*Writer, error)

+ func (writer *Writer) AddEntities(ents []tl.Entity) error

+ func (writer *Writer) AddEntity(ent tl.Entity) (string, error)

+ func (writer *Writer) Create() error

+ func (writer *Writer) Delete() error

+ func (writer *Writer) NewReader() (tl.Reader, error)

+ type WriterAdapter interface

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

+ type ZipAdapter struct

+ func NewZipAdapter(path string) *ZipAdapter

+ func (adapter ZipAdapter) Close() error

+ func (adapter ZipAdapter) DirSHA1() (string, error)

+ func (adapter ZipAdapter) Exists() bool

+ func (adapter ZipAdapter) FileInfos() ([]os.FileInfo, error)

+ func (adapter ZipAdapter) Open() error

+ func (adapter ZipAdapter) OpenFile(filename string, cb func(io.Reader)) error

+ func (adapter ZipAdapter) Path() string

+ func (adapter ZipAdapter) ReadRows(filename string, cb func(Row)) error

+ func (adapter ZipAdapter) SHA1() (string, error)

+ type ZipWriterAdapter struct

+ func NewZipWriterAdapter(path string) *ZipWriterAdapter

+ func (adapter *ZipWriterAdapter) Close() error