postgres

Documentation

Index

• type Configuration
• type Database
  • func New(conf Configuration) (*Database, error)
  • func (db *Database) FetchBikeLanes(ctx context.Context) ([]byte, error)
  • func (db *Database) FetchFreeFloatingBikes(ctx context.Context, timestamp string) ([]byte, error)
  • func (db *Database) FetchStationsStatuses(ctx context.Context, timestamp string) ([]byte, error)
  • func (db *Database) GetAdministrativeDistricts(ctx context.Context, timestamp string) ([]byte, error)
  • func (db *Database) GetBoroughs(ctx context.Context, timestamp string) ([]byte, error)
  • func (db *Database) GetMinMaxTimestamps(ctx context.Context) (time.Time, time.Time, error)
  • func (db *Database) GetStationDistribution(ctx context.Context, IDs []int) ([]domain.DistributionData, error)
  • func (db *Database) GetStationTimeSeries(ctx context.Context, IDs []int) ([]domain.Timeseries, error)
  • func (db *Database) GetStations(ctx context.Context, IDs []int) ([]domain.StationInformation, error)
  • func (db *Database) HasAdministrativeDistricts(ctx context.Context) (bool, error)
  • func (db *Database) HasBoroughs(ctx context.Context) (bool, error)
  • func (db *Database) InsertAdministrativeDistricts(ctx context.Context, districts domain.DistrictsGeoJSON) error
  • func (db *Database) InsertBikeLanes(ctx context.Context, lanes domain.BikeLanesGeoJSON) error
  • func (db *Database) InsertBoroughs(ctx context.Context, districts domain.BoroughsGeoJSON) error
  • func (db *Database) InsertFreeFloatingBikes(ctx context.Context, bikes []domain.FreeFloatingBike) error
  • func (db *Database) InsertStations(ctx context.Context, stationsInformation []domain.StationInformation) error
  • func (db *Database) InsertStatuses(ctx context.Context, statuses []domain.StationStatus) error

Types

type Configuration

type Configuration struct {
	Username string
	Password string
	Address  string
	Name     string
}

type Database

type Database struct {
	// contains filtered or unexported fields
}

func New

func New(conf Configuration) (*Database, error)

func (*Database) FetchBikeLanes

func (db *Database) FetchBikeLanes(ctx context.Context) ([]byte, error)

func (*Database) FetchFreeFloatingBikes

func (db *Database) FetchFreeFloatingBikes(ctx context.Context, timestamp string) ([]byte, error)

func (*Database) FetchStationsStatuses

func (db *Database) FetchStationsStatuses(ctx context.Context, timestamp string) ([]byte, error)

func (*Database) GetAdministrativeDistricts

func (db *Database) GetAdministrativeDistricts(ctx context.Context, timestamp string) ([]byte, error)

func (*Database) GetBoroughs

func (db *Database) GetBoroughs(ctx context.Context, timestamp string) ([]byte, error)

func (*Database) GetMinMaxTimestamps

func (db *Database) GetMinMaxTimestamps(ctx context.Context) (time.Time, time.Time, error)

func (*Database) GetStationDistribution

func (db *Database) GetStationDistribution(ctx context.Context, IDs []int) ([]domain.DistributionData, error)

func (*Database) GetStationTimeSeries

func (db *Database) GetStationTimeSeries(ctx context.Context, IDs []int) ([]domain.Timeseries, error)

func (*Database) GetStations

func (db *Database) GetStations(ctx context.Context, IDs []int) ([]domain.StationInformation, error)

func (*Database) HasAdministrativeDistricts

func (db *Database) HasAdministrativeDistricts(ctx context.Context) (bool, error)

func (*Database) HasBoroughs

func (db *Database) HasBoroughs(ctx context.Context) (bool, error)

func (*Database) InsertAdministrativeDistricts

func (db *Database) InsertAdministrativeDistricts(ctx context.Context, districts domain.DistrictsGeoJSON) error

func (*Database) InsertBikeLanes

func (db *Database) InsertBikeLanes(ctx context.Context, lanes domain.BikeLanesGeoJSON) error

func (*Database) InsertBoroughs

func (db *Database) InsertBoroughs(ctx context.Context, districts domain.BoroughsGeoJSON) error

func (*Database) InsertFreeFloatingBikes

func (db *Database) InsertFreeFloatingBikes(ctx context.Context, bikes []domain.FreeFloatingBike) error

func (*Database) InsertStations

func (db *Database) InsertStations(ctx context.Context, stationsInformation []domain.StationInformation) error

func (*Database) InsertStatuses

func (db *Database) InsertStatuses(ctx context.Context, statuses []domain.StationStatus) error