repositories

Documentation

Index

• type VehicleRepository
  • func NewVehicleRepository(pool *pgxpool.Pool, session *gocql.Session) *VehicleRepository
  • func (r *VehicleRepository) AddVehicleBasics(tx pgx.Tx, data models.VehicleBasicsPg) error
  • func (r *VehicleRepository) AddVehicleData(vehicleBasics models.VehicleBasicsPg, vehicleDetails models.VehicleDetailsPg, ...) error
  • func (r *VehicleRepository) AddVehicleDetails(tx pgx.Tx, data models.VehicleDetailsPg) error
  • func (r *VehicleRepository) AddVehicleUserLink(tx pgx.Tx, link models.VehicleUserLinkPg, userID string) error
  • func (r *VehicleRepository) GetVehicleBasic(vehicleID string, partitionSeed string) (models.VehicleBasics, error)
  • func (r *VehicleRepository) GetVehicleDetail(vehicleID string, partitionSeed string) (models.VehicleDetails, error)
  • func (r *VehicleRepository) GetVehicleFuels(vehicleID string, lastRefuelAt time.Time, limit int, bucket int) ([]models.Fuel, error)
  • func (r *VehicleRepository) GetVehicleLaptimes(vehicleID string, partitionSeed string) ([]models.Laptime, error)
  • func (r *VehicleRepository) GetVehicleUsers(vehicleID string) ([]responses.UserInfosResponse, error)

Types

type VehicleRepository

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

func NewVehicleRepository

func NewVehicleRepository(pool *pgxpool.Pool, session *gocql.Session) *VehicleRepository

func (*VehicleRepository) AddVehicleBasics

func (r *VehicleRepository) AddVehicleBasics(tx pgx.Tx, data models.VehicleBasicsPg) error

func (*VehicleRepository) AddVehicleData

func (r *VehicleRepository) AddVehicleData(vehicleBasics models.VehicleBasicsPg, vehicleDetails models.VehicleDetailsPg, vehicleUserLink models.VehicleUserLinkPg, userID string) error

func (*VehicleRepository) AddVehicleDetails

func (r *VehicleRepository) AddVehicleDetails(tx pgx.Tx, data models.VehicleDetailsPg) error

func (*VehicleRepository) AddVehicleUserLink

func (r *VehicleRepository) AddVehicleUserLink(tx pgx.Tx, link models.VehicleUserLinkPg, userID string) error

func (*VehicleRepository) GetVehicleBasic

func (r *VehicleRepository) GetVehicleBasic(vehicleID string, partitionSeed string) (models.VehicleBasics, error)

GET

func (*VehicleRepository) GetVehicleDetail

func (r *VehicleRepository) GetVehicleDetail(vehicleID string, partitionSeed string) (models.VehicleDetails, error)

func (*VehicleRepository) GetVehicleFuels

func (r *VehicleRepository) GetVehicleFuels(vehicleID string, lastRefuelAt time.Time, limit int, bucket int) ([]models.Fuel, error)

func (*VehicleRepository) GetVehicleLaptimes

func (r *VehicleRepository) GetVehicleLaptimes(vehicleID string, partitionSeed string) ([]models.Laptime, error)

func (*VehicleRepository) GetVehicleUsers

func (r *VehicleRepository) GetVehicleUsers(vehicleID string) ([]responses.UserInfosResponse, error)