shorttermrentals

Documentation

Index

• Constants
• type JobMetadata
• type Permit
  • func (p *Permit) AfterParse()
• type PermitTime
  • func (m *PermitTime) UnmarshalJSON(data []byte) error
• type Repo
  • func NewRepo(conn *pgxpool.Pool) *Repo
  • func (r *Repo) StorePermits(permits []*Permit) error
• type STRScraper
  • func NewScraper() *STRScraper
  • func (s *STRScraper) Configure(pool *pgxpool.Pool) (err error)
  • func (s *STRScraper) EnqueueJobs() (jobs []infra.Job, err error)
  • func (s *STRScraper) HandleResponse(j infra.Job, resp *http.Response, httpErr error) (*infra.Job, error)
  • func (s *STRScraper) MakeRequest(j infra.Job) (*http.Request, error)

Constants

const (
	ScraperName              = "SHORT-TERM-RENTALS"
	MergedVacationRentalsURL = "https://data.nola.gov/resource/en36-xvxg.json"
	LimitPerPage             = 1000
)

Types

type JobMetadata

type JobMetadata struct {
	Limit  int
	Offset int
}

type Permit

type Permit struct {
	Address            string   `json:"address"`
	LicenseNumber      string   `json:"license_number"`
	LicenseType        string   `json:"license_type"`
	ResidentialSubtype string   `json:"residential_subtype"`
	CurrentStatus      string   `json:"current_status"`
	Expired            string   `json:"expired"`
	Link               string   `json:"link"`
	ReferenceCode      string   `json:"reference_code"`
	X                  *float64 `json:",string"`
	Y                  *float64 `json:",string"`
	LngLatPoint        postgis.PointS
	ContactName        string `json:"contact_name"`
	ContactPhone       string `json:"contact_phone"`
	ContactEmail       string `json:"contact_email"`
	LicenseHolderName  string `json:"license_holder_name"`

	ApplicationDate      PermitTime `json:"application_date"`
	ExpirationDate       PermitTime `json:"expiration_date"`
	IssueDate            PermitTime `json:"issue_date"`
	OperatorPermitNumber string     `json:"operator_permit_number"`

	BedroomLimit        *int64 `json:"bedroom_limit,string"`
	GuestOccupancyLimit *int64 `json:"guest_occupancy_limit,string"`

	Location struct {
		Latitude  *float64 `json:",string"`
		Longitude *float64 `json:",string"`
	} `json:"location"`
}

func (*Permit) AfterParse

func (p *Permit) AfterParse()

type PermitTime

type PermitTime struct {
	time.Time
}

func (*PermitTime) UnmarshalJSON

func (m *PermitTime) UnmarshalJSON(data []byte) error

type Repo

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

func NewRepo

func NewRepo(conn *pgxpool.Pool) *Repo

func (*Repo) StorePermits

func (r *Repo) StorePermits(permits []*Permit) error

type STRScraper

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

func NewScraper

func NewScraper() *STRScraper

func (*STRScraper) Configure

func (s *STRScraper) Configure(pool *pgxpool.Pool) (err error)

func (*STRScraper) EnqueueJobs

func (s *STRScraper) EnqueueJobs() (jobs []infra.Job, err error)

func (*STRScraper) HandleResponse

func (s *STRScraper) HandleResponse(j infra.Job, resp *http.Response, httpErr error) (*infra.Job, error)

func (*STRScraper) MakeRequest

func (s *STRScraper) MakeRequest(j infra.Job) (*http.Request, error)