Documentation ¶
Index ¶
- func ErrorHandler(c *fiber.Ctx, err error, logger zerolog.Logger) error
- func NewDbcConfigService(logger *zerolog.Logger, dbs func() *db.ReaderWriter) grpc.DbcConfigServiceServer
- func NewDeviceSettingsConfigService(logger *zerolog.Logger, dbs func() *db.ReaderWriter) grpc.DeviceSettingsServiceServer
- func NewGrpcService(logger *zerolog.Logger, dbs func() *db.ReaderWriter, s3Client *s3.Client, ...) p_grpc.VehicleSignalDecodingServiceServer
- func NewPidConfigService(logger *zerolog.Logger, dbs func() *db.ReaderWriter) grpc.PidConfigServiceServer
- func NewTemplateConfigService(logger *zerolog.Logger, dbs func() *db.ReaderWriter) grpc.TemplateConfigServiceServer
- func NewVehicleTemplateService(logger *zerolog.Logger, dbs func() *db.ReaderWriter) grpc.VehicleTemplateServiceServer
- func Run(ctx context.Context, logger zerolog.Logger, settings *config.Settings)
- func StartGrpcServer(logger zerolog.Logger, dbs func() *db.ReaderWriter, s *config.Settings, ...)
- type CodeResp
- type DbcConfigService
- func (s *DbcConfigService) CreateDbc(ctx context.Context, in *grpc.UpdateDbcRequest) (*emptypb.Empty, error)
- func (s *DbcConfigService) GetDbcByTemplateName(ctx context.Context, in *grpc.GetDbcByTemplateNameRequest) (*grpc.GetDbcByTemplateNameResponse, error)
- func (s *DbcConfigService) GetDbcList(ctx context.Context, in *grpc.GetDbcListRequest) (*grpc.GetDbcListResponse, error)
- func (s *DbcConfigService) UpdateDbc(ctx context.Context, in *grpc.UpdateDbcRequest) (*emptypb.Empty, error)
- type DeviceSettingsConfigService
- func (s *DeviceSettingsConfigService) CreateDeviceSettings(ctx context.Context, in *grpc.UpdateDeviceSettingsRequest) (*emptypb.Empty, error)
- func (s *DeviceSettingsConfigService) GetDeviceSettingByName(ctx context.Context, in *grpc.GetDeviceSettingByNameRequest) (*grpc.GetDeviceSettingByNameResponse, error)
- func (s *DeviceSettingsConfigService) GetDeviceSettingList(ctx context.Context, _ *emptypb.Empty) (*grpc.GetDeviceSettingListResponse, error)
- func (s *DeviceSettingsConfigService) UpdateDeviceSettings(ctx context.Context, in *grpc.UpdateDeviceSettingsRequest) (*emptypb.Empty, error)
- type GRPCPanicker
- type GrpcService
- func (s *GrpcService) CreateDBCCode(ctx context.Context, in *p_grpc.CreateDBCCodeRequest) (*p_grpc.VehicleSignalBaseResponse, error)
- func (s *GrpcService) CreateJobsByEtherumAddress(ctx context.Context, in *p_grpc.CreateJobByEtherumAddressRequest) (*p_grpc.GetJobsByEtherumAddressItemResponse, error)
- func (s *GrpcService) CreateTestSignal(ctx context.Context, in *p_grpc.CreateTestSignalRequest) (*p_grpc.VehicleSignalBaseResponse, error)
- func (s *GrpcService) DeleteJobsByEtherumAddress(ctx context.Context, in *p_grpc.DeleteJobByEtherumAddressRequest) (*emptypb.Empty, error)
- func (s *GrpcService) DownloadCanBusDumpFile(ctx context.Context, in *p_grpc.DownloadCanBusDumpFileContentRequest) (*p_grpc.DownloadCanBusDumpFileContentResponse, error)
- func (s *GrpcService) GetCanBusDumpFiles(ctx context.Context, in *p_grpc.GetCanBusDumpFileRequest) (*p_grpc.GetCanBusDumpFileResponse, error)
- func (s *GrpcService) GetDBCCodes(ctx context.Context, _ *emptypb.Empty) (*p_grpc.GetDBCCodeListResponse, error)
- func (s *GrpcService) GetDBCCodesByID(ctx context.Context, in *p_grpc.GetByIdRequest) (*p_grpc.GetDBCCodeResponse, error)
- func (s *GrpcService) GetJobsByEtherumAddress(ctx context.Context, in *p_grpc.GetJobsByEtherumAddressRequest) (*p_grpc.GetJobsByEtherumAddressResponse, error)
- func (s *GrpcService) GetTestSignalByID(ctx context.Context, in *p_grpc.GetByIdRequest) (*p_grpc.GetTestSignalResponse, error)
- func (s *GrpcService) GetTestSignals(ctx context.Context, _ *emptypb.Empty) (*p_grpc.GetTestSignalListResponse, error)
- func (s *GrpcService) GetTestSignalsByDBCCodeID(ctx context.Context, in *p_grpc.GetByIdRequest) (*p_grpc.GetTestSignalListResponse, error)
- func (s *GrpcService) GetTestSignalsByDeviceDefinitionID(ctx context.Context, in *p_grpc.GetByIdRequest) (*p_grpc.GetTestSignalListResponse, error)
- func (s *GrpcService) GetTestSignalsByUserDeviceID(ctx context.Context, in *p_grpc.GetByIdRequest) (*p_grpc.GetTestSignalListResponse, error)
- func (s *GrpcService) UpdateDBCCode(ctx context.Context, in *p_grpc.UpdateDBCCodeRequest) (*p_grpc.VehicleSignalBaseResponse, error)
- func (s *GrpcService) UpdateTestSignal(ctx context.Context, in *p_grpc.UpdateTestSignalRequest) (*p_grpc.VehicleSignalBaseResponse, error)
- type PidConfigService
- func (s *PidConfigService) CreatePid(ctx context.Context, in *grpc.UpdatePidRequest) (*emptypb.Empty, error)
- func (s *PidConfigService) DeletePid(ctx context.Context, in *grpc.DeletePidRequest) (*emptypb.Empty, error)
- func (s *PidConfigService) GetPidByID(ctx context.Context, in *grpc.GetPidByIDRequest) (*grpc.GetPidByIDResponse, error)
- func (s *PidConfigService) GetPidList(ctx context.Context, in *grpc.GetPidListRequest) (*grpc.GetPidListResponse, error)
- func (s *PidConfigService) UpdatePid(ctx context.Context, in *grpc.UpdatePidRequest) (*emptypb.Empty, error)
- type TemplateConfigService
- func (s *TemplateConfigService) CreateTemplate(ctx context.Context, in *grpc.UpdateTemplateRequest) (*emptypb.Empty, error)
- func (s *TemplateConfigService) GetTemplateByName(ctx context.Context, in *grpc.GetTemplateByNameRequest) (*grpc.GetTemplateByNameResponse, error)
- func (s *TemplateConfigService) GetTemplateList(ctx context.Context, in *grpc.GetTemplateListRequest) (*grpc.GetTemplateListResponse, error)
- func (s *TemplateConfigService) UpdateTemplate(ctx context.Context, in *grpc.UpdateTemplateRequest) (*emptypb.Empty, error)
- type VechicleSignalDecodingData
- type VehicleTemplateService
- func (s *VehicleTemplateService) CreateVehicleTemplate(ctx context.Context, request *grpc.VehicleTemplate) (*emptypb.Empty, error)
- func (s *VehicleTemplateService) GetVehicleTemplate(ctx context.Context, request *grpc.GetVehicleTemplateRequest) (*grpc.VehicleTemplate, error)
- func (s *VehicleTemplateService) GetVehicleTemplates(ctx context.Context, request *grpc.GetVehicleTemplatesRequest) (*grpc.GetVehicleTemplatesResponse, error)
- func (s *VehicleTemplateService) UpdateVehicleTemplate(ctx context.Context, request *grpc.VehicleTemplate) (*emptypb.Empty, error)
- type WorkerListenerService
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ErrorHandler ¶ added in v0.2.4
ErrorHandler handles errors returned from fiber handlers / controllers
func NewDbcConfigService ¶ added in v0.4.4
func NewDbcConfigService(logger *zerolog.Logger, dbs func() *db.ReaderWriter) grpc.DbcConfigServiceServer
func NewDeviceSettingsConfigService ¶ added in v0.4.4
func NewDeviceSettingsConfigService(logger *zerolog.Logger, dbs func() *db.ReaderWriter) grpc.DeviceSettingsServiceServer
func NewGrpcService ¶
func NewGrpcService(logger *zerolog.Logger, dbs func() *db.ReaderWriter, s3Client *s3.Client, settings *config.Settings) p_grpc.VehicleSignalDecodingServiceServer
func NewPidConfigService ¶ added in v0.4.4
func NewPidConfigService(logger *zerolog.Logger, dbs func() *db.ReaderWriter) grpc.PidConfigServiceServer
func NewTemplateConfigService ¶ added in v0.4.4
func NewTemplateConfigService(logger *zerolog.Logger, dbs func() *db.ReaderWriter) grpc.TemplateConfigServiceServer
func NewVehicleTemplateService ¶ added in v0.6.1
func NewVehicleTemplateService(logger *zerolog.Logger, dbs func() *db.ReaderWriter) grpc.VehicleTemplateServiceServer
func StartGrpcServer ¶
Types ¶
type DbcConfigService ¶ added in v0.4.4
type DbcConfigService struct { grpc.DbcConfigServiceServer // contains filtered or unexported fields }
func (*DbcConfigService) CreateDbc ¶ added in v0.4.4
func (s *DbcConfigService) CreateDbc(ctx context.Context, in *grpc.UpdateDbcRequest) (*emptypb.Empty, error)
func (*DbcConfigService) GetDbcByTemplateName ¶ added in v0.4.4
func (s *DbcConfigService) GetDbcByTemplateName(ctx context.Context, in *grpc.GetDbcByTemplateNameRequest) (*grpc.GetDbcByTemplateNameResponse, error)
func (*DbcConfigService) GetDbcList ¶ added in v0.4.4
func (s *DbcConfigService) GetDbcList(ctx context.Context, in *grpc.GetDbcListRequest) (*grpc.GetDbcListResponse, error)
func (*DbcConfigService) UpdateDbc ¶ added in v0.4.4
func (s *DbcConfigService) UpdateDbc(ctx context.Context, in *grpc.UpdateDbcRequest) (*emptypb.Empty, error)
type DeviceSettingsConfigService ¶ added in v0.4.4
type DeviceSettingsConfigService struct { grpc.DeviceSettingsServiceServer // contains filtered or unexported fields }
func (*DeviceSettingsConfigService) CreateDeviceSettings ¶ added in v0.4.4
func (s *DeviceSettingsConfigService) CreateDeviceSettings(ctx context.Context, in *grpc.UpdateDeviceSettingsRequest) (*emptypb.Empty, error)
func (*DeviceSettingsConfigService) GetDeviceSettingByName ¶ added in v0.6.6
func (s *DeviceSettingsConfigService) GetDeviceSettingByName(ctx context.Context, in *grpc.GetDeviceSettingByNameRequest) (*grpc.GetDeviceSettingByNameResponse, error)
func (*DeviceSettingsConfigService) GetDeviceSettingList ¶ added in v0.4.4
func (s *DeviceSettingsConfigService) GetDeviceSettingList(ctx context.Context, _ *emptypb.Empty) (*grpc.GetDeviceSettingListResponse, error)
func (*DeviceSettingsConfigService) UpdateDeviceSettings ¶ added in v0.4.4
func (s *DeviceSettingsConfigService) UpdateDeviceSettings(ctx context.Context, in *grpc.UpdateDeviceSettingsRequest) (*emptypb.Empty, error)
type GRPCPanicker ¶ added in v0.4.5
func (*GRPCPanicker) GRPCPanicRecoveryHandler ¶ added in v0.4.5
func (pr *GRPCPanicker) GRPCPanicRecoveryHandler(p any) (err error)
type GrpcService ¶
type GrpcService struct { p_grpc.VehicleSignalDecodingServiceServer DBS func() *db.ReaderWriter // contains filtered or unexported fields }
func (*GrpcService) CreateDBCCode ¶
func (s *GrpcService) CreateDBCCode(ctx context.Context, in *p_grpc.CreateDBCCodeRequest) (*p_grpc.VehicleSignalBaseResponse, error)
func (*GrpcService) CreateJobsByEtherumAddress ¶ added in v0.6.2
func (s *GrpcService) CreateJobsByEtherumAddress(ctx context.Context, in *p_grpc.CreateJobByEtherumAddressRequest) (*p_grpc.GetJobsByEtherumAddressItemResponse, error)
func (*GrpcService) CreateTestSignal ¶
func (s *GrpcService) CreateTestSignal(ctx context.Context, in *p_grpc.CreateTestSignalRequest) (*p_grpc.VehicleSignalBaseResponse, error)
func (*GrpcService) DeleteJobsByEtherumAddress ¶ added in v0.6.2
func (s *GrpcService) DeleteJobsByEtherumAddress(ctx context.Context, in *p_grpc.DeleteJobByEtherumAddressRequest) (*emptypb.Empty, error)
func (*GrpcService) DownloadCanBusDumpFile ¶ added in v0.6.0
func (s *GrpcService) DownloadCanBusDumpFile(ctx context.Context, in *p_grpc.DownloadCanBusDumpFileContentRequest) (*p_grpc.DownloadCanBusDumpFileContentResponse, error)
func (*GrpcService) GetCanBusDumpFiles ¶ added in v0.6.0
func (s *GrpcService) GetCanBusDumpFiles(ctx context.Context, in *p_grpc.GetCanBusDumpFileRequest) (*p_grpc.GetCanBusDumpFileResponse, error)
func (*GrpcService) GetDBCCodes ¶
func (s *GrpcService) GetDBCCodes(ctx context.Context, _ *emptypb.Empty) (*p_grpc.GetDBCCodeListResponse, error)
func (*GrpcService) GetDBCCodesByID ¶ added in v0.1.1
func (s *GrpcService) GetDBCCodesByID(ctx context.Context, in *p_grpc.GetByIdRequest) (*p_grpc.GetDBCCodeResponse, error)
func (*GrpcService) GetJobsByEtherumAddress ¶ added in v0.6.2
func (s *GrpcService) GetJobsByEtherumAddress(ctx context.Context, in *p_grpc.GetJobsByEtherumAddressRequest) (*p_grpc.GetJobsByEtherumAddressResponse, error)
func (*GrpcService) GetTestSignalByID ¶ added in v0.1.1
func (s *GrpcService) GetTestSignalByID(ctx context.Context, in *p_grpc.GetByIdRequest) (*p_grpc.GetTestSignalResponse, error)
func (*GrpcService) GetTestSignals ¶
func (s *GrpcService) GetTestSignals(ctx context.Context, _ *emptypb.Empty) (*p_grpc.GetTestSignalListResponse, error)
func (*GrpcService) GetTestSignalsByDBCCodeID ¶ added in v0.1.1
func (s *GrpcService) GetTestSignalsByDBCCodeID(ctx context.Context, in *p_grpc.GetByIdRequest) (*p_grpc.GetTestSignalListResponse, error)
func (*GrpcService) GetTestSignalsByDeviceDefinitionID ¶ added in v0.1.1
func (s *GrpcService) GetTestSignalsByDeviceDefinitionID(ctx context.Context, in *p_grpc.GetByIdRequest) (*p_grpc.GetTestSignalListResponse, error)
func (*GrpcService) GetTestSignalsByUserDeviceID ¶ added in v0.1.1
func (s *GrpcService) GetTestSignalsByUserDeviceID(ctx context.Context, in *p_grpc.GetByIdRequest) (*p_grpc.GetTestSignalListResponse, error)
func (*GrpcService) UpdateDBCCode ¶
func (s *GrpcService) UpdateDBCCode(ctx context.Context, in *p_grpc.UpdateDBCCodeRequest) (*p_grpc.VehicleSignalBaseResponse, error)
func (*GrpcService) UpdateTestSignal ¶
func (s *GrpcService) UpdateTestSignal(ctx context.Context, in *p_grpc.UpdateTestSignalRequest) (*p_grpc.VehicleSignalBaseResponse, error)
type PidConfigService ¶ added in v0.4.4
type PidConfigService struct { grpc.PidConfigServiceServer // contains filtered or unexported fields }
func (*PidConfigService) CreatePid ¶ added in v0.4.4
func (s *PidConfigService) CreatePid(ctx context.Context, in *grpc.UpdatePidRequest) (*emptypb.Empty, error)
func (*PidConfigService) DeletePid ¶ added in v0.4.8
func (s *PidConfigService) DeletePid(ctx context.Context, in *grpc.DeletePidRequest) (*emptypb.Empty, error)
func (*PidConfigService) GetPidByID ¶ added in v0.4.4
func (s *PidConfigService) GetPidByID(ctx context.Context, in *grpc.GetPidByIDRequest) (*grpc.GetPidByIDResponse, error)
func (*PidConfigService) GetPidList ¶ added in v0.4.4
func (s *PidConfigService) GetPidList(ctx context.Context, in *grpc.GetPidListRequest) (*grpc.GetPidListResponse, error)
func (*PidConfigService) UpdatePid ¶ added in v0.4.4
func (s *PidConfigService) UpdatePid(ctx context.Context, in *grpc.UpdatePidRequest) (*emptypb.Empty, error)
type TemplateConfigService ¶ added in v0.4.4
type TemplateConfigService struct { grpc.TemplateConfigServiceServer // contains filtered or unexported fields }
func (*TemplateConfigService) CreateTemplate ¶ added in v0.4.4
func (s *TemplateConfigService) CreateTemplate(ctx context.Context, in *grpc.UpdateTemplateRequest) (*emptypb.Empty, error)
func (*TemplateConfigService) GetTemplateByName ¶ added in v0.4.4
func (s *TemplateConfigService) GetTemplateByName(ctx context.Context, in *grpc.GetTemplateByNameRequest) (*grpc.GetTemplateByNameResponse, error)
func (*TemplateConfigService) GetTemplateList ¶ added in v0.4.4
func (s *TemplateConfigService) GetTemplateList(ctx context.Context, in *grpc.GetTemplateListRequest) (*grpc.GetTemplateListResponse, error)
func (*TemplateConfigService) UpdateTemplate ¶ added in v0.4.4
func (s *TemplateConfigService) UpdateTemplate(ctx context.Context, in *grpc.UpdateTemplateRequest) (*emptypb.Empty, error)
type VechicleSignalDecodingData ¶
type VechicleSignalDecodingData struct {
Signals []map[string]commands.RunTestSignalItemCommandRequest `json:"signals"`
}
type VehicleTemplateService ¶ added in v0.6.1
type VehicleTemplateService struct { grpc.VehicleTemplateServiceServer // contains filtered or unexported fields }
func (*VehicleTemplateService) CreateVehicleTemplate ¶ added in v0.6.1
func (s *VehicleTemplateService) CreateVehicleTemplate(ctx context.Context, request *grpc.VehicleTemplate) (*emptypb.Empty, error)
func (*VehicleTemplateService) GetVehicleTemplate ¶ added in v0.6.1
func (s *VehicleTemplateService) GetVehicleTemplate(ctx context.Context, request *grpc.GetVehicleTemplateRequest) (*grpc.VehicleTemplate, error)
func (*VehicleTemplateService) GetVehicleTemplates ¶ added in v0.6.1
func (s *VehicleTemplateService) GetVehicleTemplates(ctx context.Context, request *grpc.GetVehicleTemplatesRequest) (*grpc.GetVehicleTemplatesResponse, error)
func (*VehicleTemplateService) UpdateVehicleTemplate ¶ added in v0.6.3
func (s *VehicleTemplateService) UpdateVehicleTemplate(ctx context.Context, request *grpc.VehicleTemplate) (*emptypb.Empty, error)
type WorkerListenerService ¶
type WorkerListenerService struct {
// contains filtered or unexported fields
}
func NewWorkerListenerService ¶
func NewWorkerListenerService(logger zerolog.Logger, handler commands.RunTestSignalCommandHandler) *WorkerListenerService
func (*WorkerListenerService) ProcessWorker ¶
func (i *WorkerListenerService) ProcessWorker(messages <-chan *message.Message)
Click to show internal directories.
Click to hide internal directories.