api

Documentation

Index

• 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 GrpcService
  • 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, in *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, in *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
• type WorkerListenerService
  • func NewWorkerListenerService(dbs func() *db.ReaderWriter, logger *zerolog.Logger) *WorkerListenerService
  • func (i *WorkerListenerService) ProcessWorker(messages <-chan *message.Message)

Functions

func NewGrpcService

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

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)

Types

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) CreateTestSignal

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

func (*GrpcService) GetDBCCodes

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

func (*GrpcService) GetDBCCodesByID

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

func (*GrpcService) GetTestSignalByID

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, in *emptypb.Empty) (*p_grpc.GetTestSignalListResponse, error)

func (*GrpcService) GetTestSignalsByDBCCodeID

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

func (*GrpcService) GetTestSignalsByDeviceDefinitionID

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

func (*GrpcService) GetTestSignalsByUserDeviceID

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 VechicleSignalDecodingData

type VechicleSignalDecodingData struct {
}

type WorkerListenerService

type WorkerListenerService struct {
	DBS func() *db.ReaderWriter
	// contains filtered or unexported fields
}

func NewWorkerListenerService

func NewWorkerListenerService(dbs func() *db.ReaderWriter, logger *zerolog.Logger) *WorkerListenerService

func (*WorkerListenerService) ProcessWorker

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