commands

Documentation

Index

• type CreateDeviceDefinitionCommand
  • func (*CreateDeviceDefinitionCommand) Key() string
• type CreateDeviceDefinitionCommandHandler
  • func NewCreateDeviceDefinitionCommandHandler(repository repositories.DeviceDefinitionRepository) CreateDeviceDefinitionCommandHandler
  • func (ch CreateDeviceDefinitionCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)
• type CreateDeviceDefinitionCommandResult
• type CreateDeviceIntegrationCommand
  • func (*CreateDeviceIntegrationCommand) Key() string
• type CreateDeviceIntegrationCommandHandler
  • func NewCreateDeviceIntegrationCommandHandler(repository repositories.DeviceIntegrationRepository) CreateDeviceIntegrationCommandHandler
  • func (ch CreateDeviceIntegrationCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)
• type CreateDeviceIntegrationCommandResult
• type SyncIPFSDataCommand
  • func (*SyncIPFSDataCommand) Key() string
• type SyncIPFSDataCommandHandler
  • func NewSyncIPFSDataCommandHandler(dbs func() *db.ReaderWriter, IPFSEndpoint string) SyncIPFSDataCommandHandler
  • func (ch SyncIPFSDataCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)
• type SyncIPFSDataCommandResult
• type SyncSearchDataCommand
  • func (*SyncSearchDataCommand) Key() string
• type SyncSearchDataCommandHandler
  • func NewSyncSearchDataCommandHandler(dbs func() *db.ReaderWriter, esSvc elastic.SearchService) SyncSearchDataCommandHandler
  • func (ch SyncSearchDataCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)
• type SyncSearchDataCommandResult
• type SyncSmartCartCompatibilityCommand
  • func (*SyncSmartCartCompatibilityCommand) Key() string
• type SyncSmartCartCompatibilityCommandHandler
  • func NewSyncSmartCartCompatibilityCommandHandler(dbs func() *db.ReaderWriter, scSvc gateways.SmartCarService, ...) SyncSmartCartCompatibilityCommandHandler
  • func (ch SyncSmartCartCompatibilityCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)
• type SyncSmartCartCompatibilityCommandResult
• type SyncSmartCartForwardCompatibilityCommand
  • func (*SyncSmartCartForwardCompatibilityCommand) Key() string
• type SyncSmartCartForwardCompatibilityCommandHandler
  • func NewSyncSmartCartForwardCompatibilityCommandHandler(dbs func() *db.ReaderWriter, scSvc gateways.SmartCarService, ...) SyncSmartCartForwardCompatibilityCommandHandler
  • func (ch SyncSmartCartForwardCompatibilityCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)
• type SyncSmartCartForwardCompatibilityCommandResult
• type UpdateDeviceDefinitionCommand
  • func (*UpdateDeviceDefinitionCommand) Key() string
• type UpdateDeviceDefinitionCommandHandler
  • func NewUpdateDeviceDefinitionCommandHandler(dbs func() *db.ReaderWriter, cache services.DeviceDefinitionCacheService) UpdateDeviceDefinitionCommandHandler
  • func (ch UpdateDeviceDefinitionCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)
• type UpdateDeviceDefinitionCommandResult
• type UpdateDeviceDefinitionImageCommand
  • func (*UpdateDeviceDefinitionImageCommand) Key() string
• type UpdateDeviceDefinitionImageCommandHandler
  • func NewUpdateDeviceDefinitionImageCommandHandler(dbs func() *db.ReaderWriter, cache services.DeviceDefinitionCacheService) UpdateDeviceDefinitionImageCommandHandler
  • func (ch UpdateDeviceDefinitionImageCommandHandler) Handle(ctx context.Context, query mediator.Message) (interface{}, error)
• type UpdateDeviceDefinitionImageCommandResult
• type UpdateDeviceVehicleInfo

Types

type CreateDeviceDefinitionCommand

type CreateDeviceDefinitionCommand struct {
	Source string `json:"source"`
	Make   string `json:"make"`
	Model  string `json:"model"`
	Year   int    `json:"year"`
}

func (*CreateDeviceDefinitionCommand) Key

func (*CreateDeviceDefinitionCommand) Key() string

type CreateDeviceDefinitionCommandHandler

type CreateDeviceDefinitionCommandHandler struct {
	Repository repositories.DeviceDefinitionRepository
}

func NewCreateDeviceDefinitionCommandHandler

func NewCreateDeviceDefinitionCommandHandler(repository repositories.DeviceDefinitionRepository) 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 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) 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 UpdateDeviceDefinitionCommand

type UpdateDeviceDefinitionCommand struct {
	DeviceDefinitionID string `json:"deviceDefinitionId"`
	VehicleInfo        UpdateDeviceVehicleInfo
}

func (*UpdateDeviceDefinitionCommand) Key

func (*UpdateDeviceDefinitionCommand) Key() string

type UpdateDeviceDefinitionCommandHandler

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

func NewUpdateDeviceDefinitionCommandHandler

func NewUpdateDeviceDefinitionCommandHandler(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

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

func (*UpdateDeviceDefinitionImageCommand) Key

func (*UpdateDeviceDefinitionImageCommand) Key() string

type UpdateDeviceDefinitionImageCommandHandler

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

func NewUpdateDeviceDefinitionImageCommandHandler

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

func (UpdateDeviceDefinitionImageCommandHandler) Handle

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

type UpdateDeviceDefinitionImageCommandResult

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

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"`
}