api

package
v0.10.1 Latest Latest
Warning

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

 Go to latest Published: Jul 10, 2024 License: Apache-2.0 Imports: 49 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ErrorHandler added in v0.2.4 

func ErrorHandler(c *fiber.Ctx, err error, logger zerolog.Logger) error

ErrorHandler handles errors returned from fiber handlers / controllers

func NewAftermarketDeviceTemplateService added in v0.7.41 

func NewAftermarketDeviceTemplateService(logger *zerolog.Logger, dbs func() *db.ReaderWriter) grpc.AftermarketDeviceTemplateServiceServer

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) pgrpc.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 Run 

func Run(ctx context.Context, logger zerolog.Logger, settings *config.Settings)

func StartGrpcServer 

func StartGrpcServer(logger zerolog.Logger, dbs func() *db.ReaderWriter, s *config.Settings, s3Client *s3.Client)

Types

type AftermarketDeviceTemplateService added in v0.7.41 

type AftermarketDeviceTemplateService struct {
	grpc.AftermarketDeviceTemplateServiceServer
	// contains filtered or unexported fields
}

func (*AftermarketDeviceTemplateService) CreateAftermarketDeviceTemplate added in v0.7.41 

func (s *AftermarketDeviceTemplateService) CreateAftermarketDeviceTemplate(ctx context.Context, request *grpc.AftermarketDeviceTemplateRequest) (*emptypb.Empty, error)

func (*AftermarketDeviceTemplateService) DeleteAftermarketDeviceTemplate added in v0.7.41 

func (s *AftermarketDeviceTemplateService) DeleteAftermarketDeviceTemplate(ctx context.Context, request *grpc.AftermarketDeviceTemplateRequest) (*emptypb.Empty, error)

func (*AftermarketDeviceTemplateService) GetAftermarketDeviceTemplate added in v0.7.42 

func (s *AftermarketDeviceTemplateService) GetAftermarketDeviceTemplate(ctx context.Context, request *grpc.AftermarketDeviceTemplateRequest) (*grpc.AftermarketDeviceTemplate, error)

func (*AftermarketDeviceTemplateService) GetAftermarketDeviceTemplates added in v0.7.41 

func (s *AftermarketDeviceTemplateService) GetAftermarketDeviceTemplates(ctx context.Context, _ *emptypb.Empty) (*grpc.AftermarketDeviceTemplates, error)

type CodeResp added in v0.2.4 

type CodeResp struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type DbcConfigService added in v0.4.4 

type DbcConfigService struct {
	grpc.DbcConfigServiceServer
	// contains filtered or unexported fields
}

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) UpsertDbc added in v0.7.4 

func (s *DbcConfigService) UpsertDbc(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 

type GRPCPanicker struct {
	Logger *zerolog.Logger
}

func (*GRPCPanicker) GRPCPanicRecoveryHandler added in v0.4.5 

func (pr *GRPCPanicker) GRPCPanicRecoveryHandler(p any) (err error)

type GrpcService 

type GrpcService struct {
	pgrpc.VehicleSignalDecodingServiceServer

	DBS func() *db.ReaderWriter
	// contains filtered or unexported fields
}

func (*GrpcService) CreateDBCCode 

func (s *GrpcService) CreateDBCCode(ctx context.Context, in *pgrpc.CreateDBCCodeRequest) (*pgrpc.VehicleSignalBaseResponse, error)

func (*GrpcService) CreateJobsByEtherumAddress added in v0.6.2 

func (s *GrpcService) CreateJobsByEtherumAddress(ctx context.Context, in *pgrpc.CreateJobByEtherumAddressRequest) (*pgrpc.GetJobsByEtherumAddressItemResponse, error)

func (*GrpcService) CreateTestSignal 

func (s *GrpcService) CreateTestSignal(ctx context.Context, in *pgrpc.CreateTestSignalRequest) (*pgrpc.VehicleSignalBaseResponse, error)

func (*GrpcService) DeleteJobsByEtherumAddress added in v0.6.2 

func (s *GrpcService) DeleteJobsByEtherumAddress(ctx context.Context, in *pgrpc.DeleteJobByEtherumAddressRequest) (*emptypb.Empty, error)

func (*GrpcService) DownloadCanBusDumpFile added in v0.6.0 

func (s *GrpcService) DownloadCanBusDumpFile(ctx context.Context, in *pgrpc.DownloadCanBusDumpFileContentRequest) (*pgrpc.DownloadCanBusDumpFileContentResponse, error)

func (*GrpcService) GetCanBusDumpFiles added in v0.6.0 

func (s *GrpcService) GetCanBusDumpFiles(ctx context.Context, in *pgrpc.GetCanBusDumpFileRequest) (*pgrpc.GetCanBusDumpFileResponse, error)

func (*GrpcService) GetDBCCodes 

func (s *GrpcService) GetDBCCodes(ctx context.Context, _ *emptypb.Empty) (*pgrpc.GetDBCCodeListResponse, error)

func (*GrpcService) GetDBCCodesByID added in v0.1.1 

func (s *GrpcService) GetDBCCodesByID(ctx context.Context, in *pgrpc.GetByIdRequest) (*pgrpc.GetDBCCodeResponse, error)

func (*GrpcService) GetJobsByEtherumAddress added in v0.6.2 

func (s *GrpcService) GetJobsByEtherumAddress(ctx context.Context, in *pgrpc.GetJobsByEtherumAddressRequest) (*pgrpc.GetJobsByEtherumAddressResponse, error)

func (*GrpcService) GetTestSignalByID added in v0.1.1 

func (s *GrpcService) GetTestSignalByID(ctx context.Context, in *pgrpc.GetByIdRequest) (*pgrpc.GetTestSignalResponse, error)

func (*GrpcService) GetTestSignals 

func (s *GrpcService) GetTestSignals(ctx context.Context, _ *emptypb.Empty) (*pgrpc.GetTestSignalListResponse, error)

func (*GrpcService) GetTestSignalsByDBCCodeID added in v0.1.1 

func (s *GrpcService) GetTestSignalsByDBCCodeID(ctx context.Context, in *pgrpc.GetByIdRequest) (*pgrpc.GetTestSignalListResponse, error)

func (*GrpcService) GetTestSignalsByDeviceDefinitionID added in v0.1.1 

func (s *GrpcService) GetTestSignalsByDeviceDefinitionID(ctx context.Context, in *pgrpc.GetByIdRequest) (*pgrpc.GetTestSignalListResponse, error)

func (*GrpcService) GetTestSignalsByUserDeviceID added in v0.1.1 

func (s *GrpcService) GetTestSignalsByUserDeviceID(ctx context.Context, in *pgrpc.GetByIdRequest) (*pgrpc.GetTestSignalListResponse, error)

func (*GrpcService) UpdateDBCCode 

func (s *GrpcService) UpdateDBCCode(ctx context.Context, in *pgrpc.UpdateDBCCodeRequest) (*pgrpc.VehicleSignalBaseResponse, error)

func (*GrpcService) UpdateTestSignal 

func (s *GrpcService) UpdateTestSignal(ctx context.Context, in *pgrpc.UpdateTestSignalRequest) (*pgrpc.VehicleSignalBaseResponse, error)

type PidConfigService added in v0.4.4 

type PidConfigService struct {
	grpc.PidConfigServiceServer
	// contains filtered or unexported fields
}

func (*PidConfigService) ChangePidEnableStatus added in v0.8.6 

func (s *PidConfigService) ChangePidEnableStatus(ctx context.Context, in *grpc.ChangePidEnableStatusRequest) (*emptypb.Empty, error)

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 TemplateDeviceDefinitionService added in v0.7.4 

type TemplateDeviceDefinitionService struct {
	grpc.TemplateDeviceDefinitionServiceServer
	// contains filtered or unexported fields
}

func NewTemplateDeviceDefinitionService added in v0.7.4 

func NewTemplateDeviceDefinitionService(logger *zerolog.Logger, dbs func() *db.ReaderWriter) *TemplateDeviceDefinitionService

func (*TemplateDeviceDefinitionService) CreateTemplateDeviceDefinition added in v0.7.4 

func (s *TemplateDeviceDefinitionService) CreateTemplateDeviceDefinition(ctx context.Context, request *grpc.TemplateDeviceDefinition) (*grpc.CreateTemplateDeviceDefinitionResponse, error)

func (*TemplateDeviceDefinitionService) DeleteTemplateDeviceDefinition added in v0.7.4 

func (s *TemplateDeviceDefinitionService) DeleteTemplateDeviceDefinition(ctx context.Context, request *grpc.DeleteTemplateDeviceDefinitionRequest) (*emptypb.Empty, error)

func (*TemplateDeviceDefinitionService) GetTemplateDeviceDefinition added in v0.7.4 

func (s *TemplateDeviceDefinitionService) GetTemplateDeviceDefinition(ctx context.Context, request *grpc.GetTemplateDeviceDefinitionByIdRequest) (*grpc.TemplateDeviceDefinition, error)

func (*TemplateDeviceDefinitionService) GetTemplateDeviceDefinitions added in v0.7.4 

func (s *TemplateDeviceDefinitionService) GetTemplateDeviceDefinitions(ctx context.Context, _ *emptypb.Empty) (*grpc.GetTemplateDeviceDefinitionResponse, error)

func (*TemplateDeviceDefinitionService) UpdateTemplateDeviceDefinition added in v0.7.4 

func (s *TemplateDeviceDefinitionService) UpdateTemplateDeviceDefinition(ctx context.Context, request *grpc.TemplateDeviceDefinition) (*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) (*grpc.CreateVehicleTemplateResponse, error)

func (*VehicleTemplateService) DeleteVehicleTemplate added in v0.9.8 

func (s *VehicleTemplateService) DeleteVehicleTemplate(ctx context.Context, request *grpc.DeleteVehicleTemplateRequest) (*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)

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.