queries

Documentation

Index

• type BaseQueryHandler
  • func NewBaseQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger) BaseQueryHandler
  • func (h BaseQueryHandler) Handle(ctx context.Context, query *BaseQueryRequest) (*BaseQueryResponse, error)
• type BaseQueryRequest
• type BaseQueryResponse
• type GetDBCCodeAllQueryHandler
  • func NewGetDBCCodeAllQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger) GetDBCCodeAllQueryHandler
  • func (h GetDBCCodeAllQueryHandler) Handle(ctx context.Context, query *GetDBCCodeAllQueryRequest) (*p_grpc.GetDBCCodeListResponse, error)
• type GetDBCCodeAllQueryRequest
• type GetDBCCodeByIDQueryHandler
  • func NewGetDBCCodeByIDQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger) GetDBCCodeByIDQueryHandler
  • func (h GetDBCCodeByIDQueryHandler) Handle(ctx context.Context, query *GetDBCCodeByIDQueryRequest) (*p_grpc.GetDBCCodeResponse, error)
• type GetDBCCodeByIDQueryRequest
• type GetTestSignalAllQueryHandler
  • func NewGetTestSignalAllQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger) GetTestSignalAllQueryHandler
  • func (h GetTestSignalAllQueryHandler) Handle(ctx context.Context, query *GetTestSignalAllQueryRequest) (*p_grpc.GetTestSignalListResponse, error)
• type GetTestSignalAllQueryRequest
• type GetTestSignalByIDQueryHandler
  • func NewGetTestSignalByIDQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger) GetTestSignalByIDQueryHandler
  • func (h GetTestSignalByIDQueryHandler) Handle(ctx context.Context, query *GetTestSignalByIDQueryRequest) (*p_grpc.GetTestSignalResponse, error)
• type GetTestSignalByIDQueryRequest
• type GetTestSignalFilterQueryHandler
  • func NewGetTestSignalFilterQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger) GetTestSignalFilterQueryHandler
  • func (h GetTestSignalFilterQueryHandler) Handle(ctx context.Context, query *GetTestSignalFilterQueryRequest) (*p_grpc.GetTestSignalListResponse, error)
• type GetTestSignalFilterQueryRequest

Types

type BaseQueryHandler

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

func NewBaseQueryHandler

func NewBaseQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger) BaseQueryHandler

func (BaseQueryHandler) Handle

func (h BaseQueryHandler) Handle(ctx context.Context, query *BaseQueryRequest) (*BaseQueryResponse, error)

type BaseQueryRequest

type BaseQueryRequest struct {
	Input string
}

type BaseQueryResponse

type BaseQueryResponse struct {
	Input string
}

type GetDBCCodeAllQueryHandler

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

func NewGetDBCCodeAllQueryHandler

func NewGetDBCCodeAllQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger) GetDBCCodeAllQueryHandler

func (GetDBCCodeAllQueryHandler) Handle

func (h GetDBCCodeAllQueryHandler) Handle(ctx context.Context, query *GetDBCCodeAllQueryRequest) (*p_grpc.GetDBCCodeListResponse, error)

type GetDBCCodeAllQueryRequest

type GetDBCCodeAllQueryRequest struct {
}

type GetDBCCodeByIDQueryHandler

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

func NewGetDBCCodeByIDQueryHandler

func NewGetDBCCodeByIDQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger) GetDBCCodeByIDQueryHandler

func (GetDBCCodeByIDQueryHandler) Handle

func (h GetDBCCodeByIDQueryHandler) Handle(ctx context.Context, query *GetDBCCodeByIDQueryRequest) (*p_grpc.GetDBCCodeResponse, error)

type GetDBCCodeByIDQueryRequest

type GetDBCCodeByIDQueryRequest struct {
	ID string
}

type GetTestSignalAllQueryHandler

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

func NewGetTestSignalAllQueryHandler

func NewGetTestSignalAllQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger) GetTestSignalAllQueryHandler

func (GetTestSignalAllQueryHandler) Handle

func (h GetTestSignalAllQueryHandler) Handle(ctx context.Context, query *GetTestSignalAllQueryRequest) (*p_grpc.GetTestSignalListResponse, error)

type GetTestSignalAllQueryRequest

type GetTestSignalAllQueryRequest struct {
	Input string
}

type GetTestSignalByIDQueryHandler

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

func NewGetTestSignalByIDQueryHandler

func NewGetTestSignalByIDQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger) GetTestSignalByIDQueryHandler

func (GetTestSignalByIDQueryHandler) Handle

func (h GetTestSignalByIDQueryHandler) Handle(ctx context.Context, query *GetTestSignalByIDQueryRequest) (*p_grpc.GetTestSignalResponse, error)

type GetTestSignalByIDQueryRequest

type GetTestSignalByIDQueryRequest struct {
	ID string
}

type GetTestSignalFilterQueryHandler

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

func NewGetTestSignalFilterQueryHandler

func NewGetTestSignalFilterQueryHandler(dbs func() *db.ReaderWriter, logger *zerolog.Logger) GetTestSignalFilterQueryHandler

func (GetTestSignalFilterQueryHandler) Handle

func (h GetTestSignalFilterQueryHandler) Handle(ctx context.Context, query *GetTestSignalFilterQueryRequest) (*p_grpc.GetTestSignalListResponse, error)

type GetTestSignalFilterQueryRequest

type GetTestSignalFilterQueryRequest struct {
	DeviceDefinitionID string
	DBCCodeID          string
	UserDeviceID       string
}