api

package
v0.7.2 Latest Latest
Warning

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

Go to latest
Published: Jan 25, 2024 License: Apache-2.0 Imports: 45 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 (*DbcConfigService) GetDbcByTemplateName added in v0.4.4

func (*DbcConfigService) GetDbcList added in v0.4.4

func (*DbcConfigService) UpdateDbc added in v0.4.4

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 (*DeviceSettingsConfigService) GetDeviceSettingByName added in v0.6.6

func (*DeviceSettingsConfigService) GetDeviceSettingList added in v0.4.4

func (*DeviceSettingsConfigService) UpdateDeviceSettings added in v0.4.4

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 (*GrpcService) CreateJobsByEtherumAddress added in v0.6.2

func (*GrpcService) CreateTestSignal

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 (*GrpcService) GetCanBusDumpFiles added in v0.6.0

func (*GrpcService) GetDBCCodes

func (*GrpcService) GetDBCCodesByID added in v0.1.1

func (*GrpcService) GetJobsByEtherumAddress added in v0.6.2

func (*GrpcService) GetTestSignalByID added in v0.1.1

func (*GrpcService) GetTestSignals

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 (*GrpcService) UpdateTestSignal

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 (*PidConfigService) DeletePid added in v0.4.8

func (*PidConfigService) GetPidByID added in v0.4.4

func (*PidConfigService) GetPidList added in v0.4.4

func (*PidConfigService) UpdatePid added in v0.4.4

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 (*TemplateConfigService) GetTemplateByName added in v0.4.4

func (*TemplateConfigService) GetTemplateList added in v0.4.4

func (*TemplateConfigService) UpdateTemplate added in v0.4.4

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 (*VehicleTemplateService) GetVehicleTemplates added in v0.6.1

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 (*WorkerListenerService) ProcessWorker

func (i *WorkerListenerService) ProcessWorker(messages <-chan *message.Message)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL