api

package
v0.6.3 Latest Latest
Warning

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

 Go to latest Published: Dec 1, 2023 License: Apache-2.0 Imports: 44 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 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 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 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) 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) GetDeviceSettingByTemplateName added in v0.4.4 

func (s *DeviceSettingsConfigService) GetDeviceSettingByTemplateName(ctx context.Context, in *grpc.GetDeviceSettingByTemplateNameRequest) (*grpc.GetDeviceSettingByTemplateNameResponse, error)

func (*DeviceSettingsConfigService) GetDeviceSettingList added in v0.4.4 

func (s *DeviceSettingsConfigService) GetDeviceSettingList(ctx context.Context, in *grpc.GetDeviceSettingListRequest) (*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 {
	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)

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.