storage

package

Go to main page

Versions in this module

v1

v1.1.0

Jan 13, 2025

Changes in this version

+ var ErrBucketNotExists = errors.New("bucket don't exists")

+ var ErrInvalidLatitude = errors.New("latitude must be between 90,-90")

+ var ErrInvalidLongitude = errors.New("longitude must be between 180,-180")

+ var ErrUnknownVehicleType = errors.New("unknown vehicle type")

+ var ErrUserNotFound = errors.New("user not found")

+ var ErrVehicleNotFound = errors.New("vehicle not found")

+ var ErrWateringPlanNotFound = errors.New("watering plan not found")

type AuthRepository

+ GetAccessTokenFromClientCredentials func(ctx context.Context, clientID, clientSecret string) (*entities.ClientToken, error)

type FlowerbedRepository

+ GetRegionByFlowerbedID func(ctx context.Context, id int32) (*entities.Region, error)

+ UnlinkSensorID func(ctx context.Context, sensorID string) error

type Repository

+ GpxBucket S3Repository

+ Routing RoutingRepository

+ WateringPlan WateringPlanRepository

+ type RoutingRepository interface

+ GenerateRawGpxRoute func(ctx context.Context, vehicle *entities.Vehicle, ...) (io.ReadCloser, error)

+ GenerateRoute func(ctx context.Context, vehicle *entities.Vehicle, ...) (*entities.GeoJSON, error)

+ GenerateRouteInformation func(ctx context.Context, vehicle *entities.Vehicle, ...) (*entities.RouteMetadata, error)

+ type S3Repository interface

+ BucketExists func(ctx context.Context) (bool, error)

+ GetObject func(ctx context.Context, objName string) (io.ReadSeekCloser, error)

+ PutObject func(ctx context.Context, objName, contentType string, contentLength int64, ...) error

type SensorRepository

+ Create func(ctx context.Context, fn ...entities.EntityFunc[entities.Sensor]) (*entities.Sensor, error)

+ Delete func(ctx context.Context, id string) error

+ GetAll func(ctx context.Context) ([]*entities.Sensor, error)

+ GetByID func(ctx context.Context, id string) (*entities.Sensor, error)

+ GetLatestSensorDataBySensorID func(ctx context.Context, id string) (*entities.SensorData, error)

+ Update func(ctx context.Context, id string, fn ...entities.EntityFunc[entities.Sensor]) (*entities.Sensor, error)

type TreeClusterRepository

+ Create func(ctx context.Context, fn func(tc *entities.TreeCluster) (bool, error)) (*entities.TreeCluster, error)

+ Delete func(ctx context.Context, id int32) error

+ GetAll func(ctx context.Context) ([]*entities.TreeCluster, error)

+ GetAllLatestSensorDataByClusterID func(ctx context.Context, tcID int32) ([]*entities.SensorData, error)

+ GetByID func(ctx context.Context, id int32) (*entities.TreeCluster, error)

+ GetByIDs func(ctx context.Context, ids []int32) ([]*entities.TreeCluster, error)

+ GetCenterPoint func(ctx context.Context, id int32) (float64, float64, error)

+ Update func(ctx context.Context, id int32, fn func(tc *entities.TreeCluster) (bool, error)) error

type TreeRepository

+ FindNearestTree func(ctx context.Context, latitude, longitude float64) (*entities.Tree, error)

+ GetBySensorID func(ctx context.Context, id string) (*entities.Tree, error)

+ GetBySensorIDs func(ctx context.Context, ids ...string) ([]*entities.Tree, error)

+ UnlinkSensorID func(ctx context.Context, sensorID string) error

type UserRepository

+ GetAll func(ctx context.Context) ([]*entities.User, error)

+ GetByIDs func(ctx context.Context, ids []string) ([]*entities.User, error)

type VehicleRepository

+ Create func(ctx context.Context, fn func(tc *entities.Vehicle) (bool, error)) (*entities.Vehicle, error)

+ Delete func(ctx context.Context, id int32) error

+ GetAll func(ctx context.Context) ([]*entities.Vehicle, error)

+ GetAllByType func(ctx context.Context, vehicleType entities.VehicleType) ([]*entities.Vehicle, error)

+ GetByID func(ctx context.Context, id int32) (*entities.Vehicle, error)

+ Update func(ctx context.Context, id int32, fn func(tc *entities.Vehicle) (bool, error)) error

+ type WateringPlanRepository interface

+ Create func(ctx context.Context, fn func(tc *entities.WateringPlan) (bool, error)) (*entities.WateringPlan, error)

+ Delete func(ctx context.Context, id int32) error

+ GetAll func(ctx context.Context) ([]*entities.WateringPlan, error)

+ GetByID func(ctx context.Context, id int32) (*entities.WateringPlan, error)

+ GetEvaluationValues func(ctx context.Context, id int32) ([]*entities.EvaluationValue, error)

+ GetLinkedTreeClustersByID func(ctx context.Context, id int32) ([]*entities.TreeCluster, error)

+ GetLinkedUsersByID func(ctx context.Context, id int32) ([]*uuid.UUID, error)

+ GetLinkedVehicleByIDAndType func(ctx context.Context, id int32, vehicleType entities.VehicleType) (*entities.Vehicle, error)

+ Update func(ctx context.Context, id int32, ...) error

v1.0.1-pre

Dec 1, 2024

v1.0.0

Oct 21, 2024

Changes in this version

+ var ErrCannotGetAppURL = errors.New("cannot get app url")

+ var ErrConnectionClosed = errors.New("connection is closed")

+ var ErrEntityNotFound = errors.New("entity not found")

+ var ErrFlowerbedNotFound = errors.New("flowerbed not found")

+ var ErrHostnameNotFound = errors.New("cant get hostname")

+ var ErrIDAlreadyExists = errors.New("entity id already exists")

+ var ErrIDNotFound = errors.New("entity id not found")

+ var ErrIFacesAddressNotFound = errors.New("cant get interfaces address")

+ var ErrIFacesNotFound = errors.New("cant get interfaces")

+ var ErrIPNotFound = errors.New("local ip not found")

+ var ErrImageNotFound = errors.New("image not found")

+ var ErrRegionNotFound = errors.New("region not found")

+ var ErrSensorNotFound = errors.New("sensor not found")

+ var ErrToManyRows = errors.New("receive more rows then expected")

+ var ErrTreeClusterNotFound = errors.New("treecluster not found")

+ var ErrTreeNotFound = errors.New("tree not found")

+ var ErrTxClosed = errors.New("transaction closed")

+ var ErrTxCommitRollback = errors.New("transaction cannot commit or rollback")

+ var ErrUnknowError = errors.New("unknown error")

+ type AuthRepository interface

+ GetAccessTokenFromClientCode func(ctx context.Context, code, redirectURL string) (*entities.ClientToken, error)

+ RefreshToken func(ctx context.Context, refreshToken string) (*entities.ClientToken, error)

+ RetrospectToken func(ctx context.Context, token string) (*entities.IntroSpectTokenResult, error)

+ type BasicCrudRepository interface

+ Create func(ctx context.Context, fn ...entities.EntityFunc[T]) (*T, error)

+ Delete func(ctx context.Context, id int32) error

+ GetAll func(ctx context.Context) ([]*T, error)

+ GetByID func(ctx context.Context, id int32) (*T, error)

+ Update func(ctx context.Context, id int32, fn ...entities.EntityFunc[T]) (*T, error)

+ type FlowerbedRepository interface

+ Archive func(ctx context.Context, id int32) error

+ CreateAndLinkImages func(ctx context.Context, fFn ...entities.EntityFunc[entities.Flowerbed]) (*entities.Flowerbed, error)

+ DeleteAndUnlinkImages func(ctx context.Context, id int32) error

+ GetAllImagesByID func(ctx context.Context, id int32) ([]*entities.Image, error)

+ GetSensorByFlowerbedID func(ctx context.Context, id int32) (*entities.Sensor, error)

+ UnlinkAllImages func(ctx context.Context, id int32) error

+ UnlinkImage func(ctx context.Context, flowerbedID, imageID int32) error

+ UpdateWithImages func(ctx context.Context, id int32, fFn ...entities.EntityFunc[entities.Flowerbed]) (*entities.Flowerbed, error)

+ type ImageRepository interface

+ type InfoRepository interface

+ GetAppInfo func(context.Context) (*entities.App, error)

+ type RegionRepository interface

+ GetByName func(ctx context.Context, name string) (*entities.Region, error)

+ GetByPoint func(ctx context.Context, latitude, longitude float64) (*entities.Region, error)

+ type Repository struct

+ Auth AuthRepository

+ Flowerbed FlowerbedRepository

+ Image ImageRepository

+ Info InfoRepository

+ Region RegionRepository

+ Role RoleRepository

+ Sensor SensorRepository

+ Tree TreeRepository

+ TreeCluster TreeClusterRepository

+ User UserRepository

+ Vehicle VehicleRepository

+ type RoleRepository interface

+ GetByName func(ctx context.Context, name string) (*entities.Role, error)

+ type SensorRepository interface

+ GetSensorByStatus func(ctx context.Context, status *entities.SensorStatus) ([]*entities.Sensor, error)

+ GetSensorDataByID func(ctx context.Context, id int32) ([]*entities.SensorData, error)

+ GetStatusByID func(ctx context.Context, id int32) (*entities.SensorStatus, error)

+ InsertSensorData func(ctx context.Context, data []*entities.SensorData) ([]*entities.SensorData, error)

+ type TreeClusterRepository interface

+ Archive func(ctx context.Context, id int32) error

+ GetByAddress func(ctx context.Context, address string) (*entities.TreeCluster, error)

+ GetSensorByTreeClusterID func(ctx context.Context, id int32) (*entities.Sensor, error)

+ LinkTreesToCluster func(ctx context.Context, treeClusterID int32, treeIDs []int32) error

+ type TreeRepository interface

+ CreateAndLinkImages func(ctx context.Context, tcFn ...entities.EntityFunc[entities.Tree]) (*entities.Tree, error)

+ DeleteAndUnlinkImages func(ctx context.Context, id int32) error

+ GetAllImagesByID func(ctx context.Context, id int32) ([]*entities.Image, error)

+ GetByCoordinates func(ctx context.Context, latitude, longitude float64) (*entities.Tree, error)

+ GetByTreeClusterID func(ctx context.Context, id int32) ([]*entities.Tree, error)

+ GetCenterPoint func(ctx context.Context, id []int32) (float64, float64, error)

+ GetSensorByTreeID func(ctx context.Context, id int32) (*entities.Sensor, error)

+ GetTreesByIDs func(ctx context.Context, ids []int32) ([]*entities.Tree, error)

+ UnlinkAllImages func(ctx context.Context, id int32) error

+ UnlinkImage func(ctx context.Context, flowerbedID, imageID int32) error

+ UnlinkTreeClusterID func(ctx context.Context, treeClusterID int32) error

+ UpdateWithImages func(ctx context.Context, id int32, fFn ...entities.EntityFunc[entities.Tree]) (*entities.Tree, error)

+ type UserRepository interface

+ Create func(ctx context.Context, user *entities.User, password string, roles *[]string) (*entities.User, error)

+ GetByAccessToken func(ctx context.Context, token string) (*entities.User, error)

+ RemoveSession func(ctx context.Context, token string) error

+ type VehicleRepository interface

+ GetByPlate func(ctx context.Context, plate string) (*entities.Vehicle, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL