commands

Documentation

Index

• type BaseCommandHandler
  • func NewBaseCommandHandler(dbs func() *db.ReaderWriter) BaseCommandHandler
  • func (h BaseCommandHandler) Execute(ctx context.Context, command *BaseCommandRequest) (*BaseCommandResponse, error)
• type BaseCommandRequest
• type BaseCommandResponse
• type CreateDBCCodeCommandHandler
  • func NewCreateDBCCodeCommandHandler(dbs func() *db.ReaderWriter) CreateDBCCodeCommandHandler
  • func (h CreateDBCCodeCommandHandler) Execute(ctx context.Context, command *CreateDBCCodeCommandRequest) (*CreateDBCCodeCommandResponse, error)
• type CreateDBCCodeCommandRequest
• type CreateDBCCodeCommandResponse
• type CreateTestSignalCommandHandler
  • func NewCreateTestSignalCommandHandler(dbs func() *db.ReaderWriter) CreateTestSignalCommandHandler
  • func (h CreateTestSignalCommandHandler) Execute(ctx context.Context, command *CreateTestSignalCommandRequest) (*CreateTestSignalCommandResponse, error)
• type CreateTestSignalCommandRequest
• type CreateTestSignalCommandResponse
• type RunTestSignalCommandHandler
  • func NewRunTestSignalCommandHandler(dbs func() *db.ReaderWriter, logger zerolog.Logger, ...) RunTestSignalCommandHandler
  • func (h RunTestSignalCommandHandler) Execute(ctx context.Context, command *RunTestSignalCommandRequest) error
• type RunTestSignalCommandRequest
• type RunTestSignalCommandResponse
• type RunTestSignalItemCommandRequest
• type UpdateDBCCodeCommandHandler
  • func NewUpdateDBCCodeCommandHandler(dbs func() *db.ReaderWriter) UpdateDBCCodeCommandHandler
  • func (h UpdateDBCCodeCommandHandler) Execute(ctx context.Context, command *UpdateDBCCodeCommandRequest) (*UpdateDBCCodeCommandResponse, error)
• type UpdateDBCCodeCommandRequest
• type UpdateDBCCodeCommandResponse
• type UpdateTestSignalCommandHandler
  • func NewUpdateTestSignalCommandHandler(dbs func() *db.ReaderWriter) UpdateTestSignalCommandHandler
  • func (h UpdateTestSignalCommandHandler) Execute(ctx context.Context, command *UpdateTestSignalCommandRequest) (*UpdateTestSignalCommandResponse, error)
• type UpdateTestSignalCommandRequest
• type UpdateTestSignalCommandResponse

Types

type BaseCommandHandler

type BaseCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewBaseCommandHandler

func NewBaseCommandHandler(dbs func() *db.ReaderWriter) BaseCommandHandler

func (BaseCommandHandler) Execute

func (h BaseCommandHandler) Execute(ctx context.Context, command *BaseCommandRequest) (*BaseCommandResponse, error)

type BaseCommandRequest

type BaseCommandRequest struct {
	Input string
}

type BaseCommandResponse

type BaseCommandResponse struct {
	Result bool
}

type CreateDBCCodeCommandHandler

type CreateDBCCodeCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewCreateDBCCodeCommandHandler

func NewCreateDBCCodeCommandHandler(dbs func() *db.ReaderWriter) CreateDBCCodeCommandHandler

func (CreateDBCCodeCommandHandler) Execute

func (h CreateDBCCodeCommandHandler) Execute(ctx context.Context, command *CreateDBCCodeCommandRequest) (*CreateDBCCodeCommandResponse, error)

type CreateDBCCodeCommandRequest

type CreateDBCCodeCommandRequest struct {
	Name             string
	DBCContents      string
	Header           int
	Trigger          string
	RecordingEnabled bool
	MaxSampleSize    int32
}

type CreateDBCCodeCommandResponse

type CreateDBCCodeCommandResponse struct {
	ID   string
	Name string
}

type CreateTestSignalCommandHandler

type CreateTestSignalCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewCreateTestSignalCommandHandler

func NewCreateTestSignalCommandHandler(dbs func() *db.ReaderWriter) CreateTestSignalCommandHandler

func (CreateTestSignalCommandHandler) Execute

func (h CreateTestSignalCommandHandler) Execute(ctx context.Context, command *CreateTestSignalCommandRequest) (*CreateTestSignalCommandResponse, error)

type CreateTestSignalCommandRequest

type CreateTestSignalCommandRequest struct {
	DeviceDefinitionID string
	DBCCodesID         string
	UserDeviceID       string
	AutoPIUnitID       string
	Value              string
	Approved           bool
}

type CreateTestSignalCommandResponse

type CreateTestSignalCommandResponse struct {
	ID string
}

type RunTestSignalCommandHandler

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

func NewRunTestSignalCommandHandler

func NewRunTestSignalCommandHandler(dbs func() *db.ReaderWriter, logger zerolog.Logger, userDeviceService services.UserDeviceService) RunTestSignalCommandHandler

func (RunTestSignalCommandHandler) Execute

func (h RunTestSignalCommandHandler) Execute(ctx context.Context, command *RunTestSignalCommandRequest) error

type RunTestSignalCommandRequest

type RunTestSignalCommandRequest struct {
	AutoPIUnitID string
	Time         time.Time
	Signals      map[string]RunTestSignalItemCommandRequest
}

type RunTestSignalCommandResponse

type RunTestSignalCommandResponse struct {
}

type RunTestSignalItemCommandRequest

type RunTestSignalItemCommandRequest struct {
	Value any    `json:"value"`
	Time  string `json:"_stamp"`
}

type UpdateDBCCodeCommandHandler

type UpdateDBCCodeCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewUpdateDBCCodeCommandHandler

func NewUpdateDBCCodeCommandHandler(dbs func() *db.ReaderWriter) UpdateDBCCodeCommandHandler

func (UpdateDBCCodeCommandHandler) Execute

func (h UpdateDBCCodeCommandHandler) Execute(ctx context.Context, command *UpdateDBCCodeCommandRequest) (*UpdateDBCCodeCommandResponse, error)

type UpdateDBCCodeCommandRequest

type UpdateDBCCodeCommandRequest struct {
	ID               string
	Name             string
	DBCContents      string
	Header           int
	Trigger          string
	RecordingEnabled bool
	MaxSampleSize    int32
}

type UpdateDBCCodeCommandResponse

type UpdateDBCCodeCommandResponse struct {
	ID   string
	Name string
}

type UpdateTestSignalCommandHandler

type UpdateTestSignalCommandHandler struct {
	DBS func() *db.ReaderWriter
}

func NewUpdateTestSignalCommandHandler

func NewUpdateTestSignalCommandHandler(dbs func() *db.ReaderWriter) UpdateTestSignalCommandHandler

func (UpdateTestSignalCommandHandler) Execute

func (h UpdateTestSignalCommandHandler) Execute(ctx context.Context, command *UpdateTestSignalCommandRequest) (*UpdateTestSignalCommandResponse, error)

type UpdateTestSignalCommandRequest

type UpdateTestSignalCommandRequest struct {
	ID                 string
	DeviceDefinitionID string
	DBCCodesID         string
	UserDeviceID       string
	AutoPIUnitID       string
	Value              string
	Approved           bool
}

type UpdateTestSignalCommandResponse

type UpdateTestSignalCommandResponse struct {
	ID string
}