api

package

v0.4.0 Latest Latest Go to latest Published: Sep 30, 2023 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

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

Code below copied from device-data-api/main.go

func NewGrpcService(logger *zerolog.Logger, dbs func() *db.ReaderWriter) p_grpc.VehicleSignalDecodingServiceServer

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 struct {
	Code    int    `json:"code"`
	Message string `json:"message"`
}

type GrpcService struct {
	p_grpc.VehicleSignalDecodingServiceServer

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

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

func (s *GrpcService) CreateTestSignal(ctx context.Context, in *p_grpc.CreateTestSignalRequest) (*p_grpc.VehicleSignalBaseResponse, 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) 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 VechicleSignalDecodingData struct {
	Signals []map[string]commands.RunTestSignalItemCommandRequest `json:"signals"`
}

type WorkerListenerService struct {
	// contains filtered or unexported fields
}

func NewWorkerListenerService(logger zerolog.Logger, handler commands.RunTestSignalCommandHandler) *WorkerListenerService

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

Path	Synopsis
common