services

Documentation

Index

• type DataQueryService
  • func NewAggregateQueryService(es *elasticsearch.TypedClient, settings *config.Settings, log *zerolog.Logger) *DataQueryService
  • func (uds *DataQueryService) FetchUserData(userDeviceID string) (UserData, error)
• type DeviceAPIService
  • func NewDeviceAPIService(devicesAPIGRPCAddr string) DeviceAPIService
• type EmailService
  • func NewEmailService(settings *config.Settings, log *zerolog.Logger) *EmailService
  • func (es *EmailService) SendEmail(user, downloadLink string) error
• type StorageService
  • func NewStorageService(settings *config.Settings, log *zerolog.Logger) *StorageService
  • func (ss *StorageService) UploadUserData(ud UserData, keyName string) (string, error)
• type UserData
• type UserDeviceFull

Types

type DataQueryService

type DataQueryService struct {
	Settings *config.Settings
	// contains filtered or unexported fields
}

func NewAggregateQueryService

func NewAggregateQueryService(es *elasticsearch.TypedClient, settings *config.Settings, log *zerolog.Logger) *DataQueryService

func (*DataQueryService) FetchUserData

func (uds *DataQueryService) FetchUserData(userDeviceID string) (UserData, error)

type DeviceAPIService

type DeviceAPIService interface {
	ListUserDevicesForUser(ctx context.Context, userID string) (*pb.ListUserDevicesForUserResponse, error)
	GetUserDevice(ctx context.Context, userDeviceID string) (*pb.UserDevice, error)
	UserDeviceBelongsToUserID(ctx context.Context, userID, userDeviceID string) (bool, error)
	GetUserDeviceByTokenID(ctx context.Context, tokenID int64) (*pb.UserDevice, error)
}

func NewDeviceAPIService

func NewDeviceAPIService(devicesAPIGRPCAddr string) DeviceAPIService

NewDeviceAPIService API wrapper to call device-data-api to get the userDevices associated with a userId over grpc

type EmailService

type EmailService struct {
	ClientConn *grpc.ClientConn
	// contains filtered or unexported fields
}

func NewEmailService

func NewEmailService(settings *config.Settings, log *zerolog.Logger) *EmailService

func (*EmailService) SendEmail

func (es *EmailService) SendEmail(user, downloadLink string) error

type StorageService

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

func NewStorageService

func NewStorageService(settings *config.Settings, log *zerolog.Logger) *StorageService

func (*StorageService) UploadUserData

func (ss *StorageService) UploadUserData(ud UserData, keyName string) (string, error)

type UserData

type UserData struct {
	User             string                   `json:"user"`
	RequestTimestamp string                   `json:"requestTimestamp"`
	Data             []map[string]interface{} `json:"data,omitempty"`
}

type UserDeviceFull

type UserDeviceFull struct {
	ID             string  `json:"id"`
	VIN            *string `json:"vin"`
	VINConfirmed   bool    `json:"vinConfirmed"`
	Name           *string `json:"name"`
	CustomImageURL *string `json:"customImageUrl"`
	CountryCode    *string `json:"countryCode"`
}

UserDeviceFull represents object user's see on frontend for listing of their devices