commands

package
v0.2.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 23, 2022 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateDeviceDefinitionCommand 

type CreateDeviceDefinitionCommand struct {
	Source string `json:"source"`
	Make   string `json:"make"`
	Model  string `json:"model"`
	Year   int    `json:"year"`
	// DeviceTypeID comes from the device_types.id table, determines what kind of device this is, typically a vehicle
	DeviceTypeID string `json:"device_type_id"`
	// DeviceAttributes sets definition metadata eg. vehicle info. Allowed key/values are defined in device_types.properties
	DeviceAttributes []*coremodels.UpdateDeviceTypeAttribute `json:"deviceAttributes"`
}

func (*CreateDeviceDefinitionCommand) Key 

func (*CreateDeviceDefinitionCommand) Key() string

type CreateDeviceDefinitionCommandHandler 

type CreateDeviceDefinitionCommandHandler struct {
	Repository repositories.DeviceDefinitionRepository
	DBS        func() *db.ReaderWriter
}

func NewCreateDeviceDefinitionCommandHandler 

func NewCreateDeviceDefinitionCommandHandler(repository repositories.DeviceDefinitionRepository, dbs func() *db.ReaderWriter) CreateDeviceDefinitionCommandHandler

func (CreateDeviceDefinitionCommandHandler) Handle 

func (ch CreateDeviceDefinitionCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type CreateDeviceDefinitionCommandResult 

type CreateDeviceDefinitionCommandResult struct {
	ID string `json:"id"`
}

type CreateDeviceIntegrationCommand 

type CreateDeviceIntegrationCommand struct {
	DeviceDefinitionID string `json:"device_definition_id"`
	IntegrationID      string `json:"integration_id"`
	Region             string `json:"region"`
}

func (*CreateDeviceIntegrationCommand) Key 

func (*CreateDeviceIntegrationCommand) Key() string

type CreateDeviceIntegrationCommandHandler 

type CreateDeviceIntegrationCommandHandler struct {
	Repository repositories.DeviceIntegrationRepository
}

func NewCreateDeviceIntegrationCommandHandler 

func NewCreateDeviceIntegrationCommandHandler(repository repositories.DeviceIntegrationRepository) CreateDeviceIntegrationCommandHandler

func (CreateDeviceIntegrationCommandHandler) Handle 

func (ch CreateDeviceIntegrationCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type CreateDeviceIntegrationCommandResult 

type CreateDeviceIntegrationCommandResult struct {
	ID string `json:"id"`
}

type CreateDeviceMakeCommand added in v0.1.26 

type CreateDeviceMakeCommand struct {
	Name    string `json:"name"`
	LogoURL string `json:"logo_url"`
}

func (*CreateDeviceMakeCommand) Key added in v0.1.26 

func (*CreateDeviceMakeCommand) Key() string

type CreateDeviceMakeCommandHandler added in v0.1.26 

type CreateDeviceMakeCommandHandler struct {
	Repository repositories.DeviceMakeRepository
}

func NewCreateDeviceMakeCommandHandler added in v0.1.26 

func NewCreateDeviceMakeCommandHandler(repository repositories.DeviceMakeRepository) CreateDeviceMakeCommandHandler

func (CreateDeviceMakeCommandHandler) Handle added in v0.1.26 

func (ch CreateDeviceMakeCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type CreateDeviceMakeCommandResult added in v0.1.26 

type CreateDeviceMakeCommandResult struct {
	ID string `json:"id"`
}

type CreateDeviceStyleCommand added in v0.1.11 

type CreateDeviceStyleCommand struct {
	DeviceDefinitionID string `json:"device_definition_id"`
	Name               string `json:"name"`
	ExternalStyleID    string `json:"external_style_id"`
	Source             string `json:"source"`
	SubModel           string `json:"sub_model"`
}

func (*CreateDeviceStyleCommand) Key added in v0.1.11 

func (*CreateDeviceStyleCommand) Key() string

type CreateDeviceStyleCommandHandler added in v0.1.11 

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

func NewCreateDeviceStyleCommandHandler added in v0.1.11 

func NewCreateDeviceStyleCommandHandler(repository repositories.DeviceStyleRepository, cache services.DeviceDefinitionCacheService) CreateDeviceStyleCommandHandler

func (CreateDeviceStyleCommandHandler) Handle added in v0.1.11 

func (ch CreateDeviceStyleCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type CreateDeviceStyleCommandResult added in v0.1.11 

type CreateDeviceStyleCommandResult struct {
	ID string `json:"id"`
}

type CreateIntegrationCommand added in v0.1.28 

type CreateIntegrationCommand struct {
	Vendor string `json:"vendor"`
	Type   string `json:"type"`
	Style  string `json:"style"`
}

func (*CreateIntegrationCommand) Key added in v0.1.28 

func (*CreateIntegrationCommand) Key() string

type CreateIntegrationCommandHandler added in v0.1.28 

type CreateIntegrationCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewCreateIntegrationCommandHandler added in v0.1.28 

func NewCreateIntegrationCommandHandler(dbs func() *db.ReaderWriter) CreateIntegrationCommandHandler

func (CreateIntegrationCommandHandler) Handle added in v0.1.28 

func (ch CreateIntegrationCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type CreateIntegrationCommandResult added in v0.1.28 

type CreateIntegrationCommandResult struct {
	ID string `json:"id"`
}

type SyncIPFSDataCommand 

type SyncIPFSDataCommand struct {
}

func (*SyncIPFSDataCommand) Key 

func (*SyncIPFSDataCommand) Key() string

type SyncIPFSDataCommandHandler 

type SyncIPFSDataCommandHandler struct {
	DBS          func() *db.ReaderWriter
	IPFSEndpoint string
}

func NewSyncIPFSDataCommandHandler 

func NewSyncIPFSDataCommandHandler(dbs func() *db.ReaderWriter, IPFSEndpoint string) SyncIPFSDataCommandHandler

func (SyncIPFSDataCommandHandler) Handle 

func (ch SyncIPFSDataCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type SyncIPFSDataCommandResult 

type SyncIPFSDataCommandResult struct {
}

type SyncSearchDataCommand 

type SyncSearchDataCommand struct {
}

func (*SyncSearchDataCommand) Key 

func (*SyncSearchDataCommand) Key() string

type SyncSearchDataCommandHandler 

type SyncSearchDataCommandHandler struct {
	DBS func() *db.ReaderWriter
	// contains filtered or unexported fields
}

func NewSyncSearchDataCommandHandler 

func NewSyncSearchDataCommandHandler(dbs func() *db.ReaderWriter, esSvc elastic.SearchService, logger zerolog.Logger) SyncSearchDataCommandHandler

func (SyncSearchDataCommandHandler) Handle 

func (ch SyncSearchDataCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type SyncSearchDataCommandResult 

type SyncSearchDataCommandResult struct {
	Status bool
}

type SyncSmartCartCompatibilityCommand 

type SyncSmartCartCompatibilityCommand struct {
}

func (*SyncSmartCartCompatibilityCommand) Key 

func (*SyncSmartCartCompatibilityCommand) Key() string

type SyncSmartCartCompatibilityCommandHandler 

type SyncSmartCartCompatibilityCommandHandler struct {
	DBS func() *db.ReaderWriter

	Repository repositories.DeviceDefinitionRepository
	// contains filtered or unexported fields
}

func NewSyncSmartCartCompatibilityCommandHandler 

func NewSyncSmartCartCompatibilityCommandHandler(dbs func() *db.ReaderWriter, scSvc gateways.SmartCarService, repository repositories.DeviceDefinitionRepository) SyncSmartCartCompatibilityCommandHandler

func (SyncSmartCartCompatibilityCommandHandler) Handle 

func (ch SyncSmartCartCompatibilityCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type SyncSmartCartCompatibilityCommandResult 

type SyncSmartCartCompatibilityCommandResult struct {
	Status bool
}

type SyncSmartCartForwardCompatibilityCommand 

type SyncSmartCartForwardCompatibilityCommand struct {
}

func (*SyncSmartCartForwardCompatibilityCommand) Key 

func (*SyncSmartCartForwardCompatibilityCommand) Key() string

type SyncSmartCartForwardCompatibilityCommandHandler 

type SyncSmartCartForwardCompatibilityCommandHandler struct {
	DBS func() *db.ReaderWriter

	Repository repositories.DeviceDefinitionRepository
	// contains filtered or unexported fields
}

func NewSyncSmartCartForwardCompatibilityCommandHandler 

func NewSyncSmartCartForwardCompatibilityCommandHandler(dbs func() *db.ReaderWriter, scSvc gateways.SmartCarService, repository repositories.DeviceDefinitionRepository) SyncSmartCartForwardCompatibilityCommandHandler

func (SyncSmartCartForwardCompatibilityCommandHandler) Handle 

func (ch SyncSmartCartForwardCompatibilityCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type SyncSmartCartForwardCompatibilityCommandResult 

type SyncSmartCartForwardCompatibilityCommandResult struct {
	Status bool
}

type SyncTeslaIntegrationCommand added in v0.1.17 

type SyncTeslaIntegrationCommand struct {
}

func (*SyncTeslaIntegrationCommand) Key added in v0.1.17 

func (*SyncTeslaIntegrationCommand) Key() string

type SyncTeslaIntegrationCommandResult added in v0.1.17 

type SyncTeslaIntegrationCommandResult struct {
	Status bool
}

type SyncTestlaIntegrationCommandHandler added in v0.1.17 

type SyncTestlaIntegrationCommandHandler struct {
	DBS func() *db.ReaderWriter
	// contains filtered or unexported fields
}

func NewSyncTestlaIntegrationCommandHandler added in v0.1.17 

func NewSyncTestlaIntegrationCommandHandler(dbs func() *db.ReaderWriter, log *zerolog.Logger) SyncTestlaIntegrationCommandHandler

func (SyncTestlaIntegrationCommandHandler) Handle added in v0.1.17 

func (ch SyncTestlaIntegrationCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type UpdateDeviceDefinitionCommand 

type UpdateDeviceDefinitionCommand struct {
	DeviceDefinitionID string `json:"deviceDefinitionId"`
	Source             string `json:"source"`
	ExternalID         string `json:"external_id"`
	ImageURL           string `json:"image_url"`
	VehicleInfo        *UpdateDeviceVehicleInfo
	Verified           bool                       `json:"verified"`
	Model              string                     `json:"model"`
	Year               int16                      `json:"year"`
	DeviceMakeID       string                     `json:"device_make_id"`
	DeviceStyles       []UpdateDeviceStyles       `json:"deviceStyles"`
	DeviceIntegrations []UpdateDeviceIntegrations `json:"deviceIntegrations"`
	// DeviceTypeID comes from the device_types.id table, determines what kind of device this is, typically a vehicle
	DeviceTypeID string `json:"device_type_id"`
	// DeviceAttributes sets definition metadata eg. vehicle info. Allowed key/values are defined in device_types.properties
	DeviceAttributes []*coremodels.UpdateDeviceTypeAttribute `json:"deviceAttributes"`
}

func (*UpdateDeviceDefinitionCommand) Key 

func (*UpdateDeviceDefinitionCommand) Key() string

type UpdateDeviceDefinitionCommandHandler 

type UpdateDeviceDefinitionCommandHandler struct {
	Repository repositories.DeviceDefinitionRepository
	DBS        func() *db.ReaderWriter
	DDCache    services.DeviceDefinitionCacheService
}

func NewUpdateDeviceDefinitionCommandHandler 

func NewUpdateDeviceDefinitionCommandHandler(repository repositories.DeviceDefinitionRepository, dbs func() *db.ReaderWriter, cache services.DeviceDefinitionCacheService) UpdateDeviceDefinitionCommandHandler

func (UpdateDeviceDefinitionCommandHandler) Handle 

func (ch UpdateDeviceDefinitionCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type UpdateDeviceDefinitionCommandResult 

type UpdateDeviceDefinitionCommandResult struct {
	ID string `json:"id"`
}

type UpdateDeviceDefinitionImageCommand added in v0.1.6 

type UpdateDeviceDefinitionImageCommand struct {
	DeviceDefinitionID string `json:"deviceDefinitionId"`
	ImageURL           string `json:"image_url"`
}

func (*UpdateDeviceDefinitionImageCommand) Key added in v0.1.6 

func (*UpdateDeviceDefinitionImageCommand) Key() string

type UpdateDeviceDefinitionImageCommandHandler added in v0.1.6 

type UpdateDeviceDefinitionImageCommandHandler struct {
	DBS     func() *db.ReaderWriter
	DDCache services.DeviceDefinitionCacheService
}

func NewUpdateDeviceDefinitionImageCommandHandler added in v0.1.6 

func NewUpdateDeviceDefinitionImageCommandHandler(dbs func() *db.ReaderWriter, cache services.DeviceDefinitionCacheService) UpdateDeviceDefinitionImageCommandHandler

func (UpdateDeviceDefinitionImageCommandHandler) Handle added in v0.1.6 

func (ch UpdateDeviceDefinitionImageCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type UpdateDeviceDefinitionImageCommandResult added in v0.1.6 

type UpdateDeviceDefinitionImageCommandResult struct {
	ID string `json:"id"`
}

type UpdateDeviceIntegrations added in v0.1.11 

type UpdateDeviceIntegrations struct {
	IntegrationID string    `json:"integration_id"`
	Capabilities  null.JSON `json:"capabilities,omitempty"`
	CreatedAt     time.Time `json:"created_at,omitempty"`
	UpdatedAt     time.Time `json:"updated_at,omitempty"`
	Region        string    `json:"region"`
}

type UpdateDeviceMakeCommand added in v0.1.38 

type UpdateDeviceMakeCommand struct {
	ID              string          `json:"id"`
	Name            string          `json:"name"`
	LogoURL         null.String     `json:"logo_url"`
	OemPlatformName null.String     `json:"oem_platform_name"`
	TokenID         *big.Int        `json:"tokenId,omitempty"`
	ExternalIds     json.RawMessage `json:"external_ids"`
}

func (*UpdateDeviceMakeCommand) Key added in v0.1.38 

func (*UpdateDeviceMakeCommand) Key() string

type UpdateDeviceMakeCommandHandler added in v0.1.38 

type UpdateDeviceMakeCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewUpdateDeviceMakeCommandHandler added in v0.1.38 

func NewUpdateDeviceMakeCommandHandler(dbs func() *db.ReaderWriter) UpdateDeviceMakeCommandHandler

func (UpdateDeviceMakeCommandHandler) Handle added in v0.1.38 

func (ch UpdateDeviceMakeCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type UpdateDeviceMakeCommandResult added in v0.1.38 

type UpdateDeviceMakeCommandResult struct {
	ID string `json:"id"`
}

type UpdateDeviceStyleCommand added in v0.1.38 

type UpdateDeviceStyleCommand struct {
	ID                 string `json:"id"`
	DeviceDefinitionID string `json:"device_definition_id"`
	Name               string `json:"name"`
	ExternalStyleID    string `json:"external_style_id"`
	Source             string `json:"source"`
	SubModel           string `json:"sub_model"`
}

func (*UpdateDeviceStyleCommand) Key added in v0.1.38 

func (*UpdateDeviceStyleCommand) Key() string

type UpdateDeviceStyleCommandHandler added in v0.1.38 

type UpdateDeviceStyleCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewUpdateDeviceStyleCommandHandler added in v0.1.38 

func NewUpdateDeviceStyleCommandHandler(dbs func() *db.ReaderWriter) UpdateDeviceStyleCommandHandler

func (UpdateDeviceStyleCommandHandler) Handle added in v0.1.38 

func (ch UpdateDeviceStyleCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)

type UpdateDeviceStyleCommandResult added in v0.1.38 

type UpdateDeviceStyleCommandResult struct {
	ID string `json:"id"`
}

type UpdateDeviceStyles added in v0.1.11 

type UpdateDeviceStyles struct {
	ID              string    `json:"id"`
	Name            string    `json:"name"`
	ExternalStyleID string    `json:"external_style_id"`
	Source          string    `json:"source"`
	CreatedAt       time.Time `json:"created_at,omitempty"`
	UpdatedAt       time.Time `json:"updated_at,omitempty"`
	SubModel        string    `json:"sub_model"`
}

type UpdateDeviceVehicleInfo 

type UpdateDeviceVehicleInfo struct {
	FuelType            string `json:"fuel_type,omitempty"`
	DrivenWheels        string `json:"driven_wheels,omitempty"`
	NumberOfDoors       string `json:"number_of_doors,omitempty"`
	BaseMSRP            int    `json:"base_msrp,omitempty"`
	EPAClass            string `json:"epa_class,omitempty"`
	VehicleType         string `json:"vehicle_type,omitempty"` // VehicleType PASSENGER CAR, from NHTSA
	MPGHighway          string `json:"mpg_highway,omitempty"`
	MPGCity             string `json:"mpg_city,omitempty"`
	FuelTankCapacityGal string `json:"fuel_tank_capacity_gal,omitempty"`
	MPG                 string `json:"mpg,omitempty"`
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.