Documentation ¶
Index ¶
- func NewResourceCtx() func(context.Context) (eventstore.Model, error)
- type Config
- type Device
- type DeviceDirectory
- type Projection
- type RequestHandler
- func (r *RequestHandler) GetDevices(req *pbDD.GetDevicesRequest, srv pbDD.DeviceDirectory_GetDevicesServer) error
- func (r *RequestHandler) GetResourceLinks(req *pbRD.GetResourceLinksRequest, ...) error
- func (r *RequestHandler) GetUsersDevices(ctx context.Context, authCtx *pbCQRS.AuthorizationContext, ...) ([]string, error)
- func (r *RequestHandler) RetrieveResourcesValues(req *pbRS.RetrieveResourcesValuesRequest, ...) error
- type ResourceDirectory
- type ResourceShadow
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewResourceCtx ¶
func NewResourceCtx() func(context.Context) (eventstore.Model, error)
Types ¶
type Config ¶
type Config struct { grpc.Config FQDN string `envconfig:"FQDN" default:"grpc-gateway"` AuthServerAddr string `envconfig:"AUTH_SERVER_ADDRESS" default:"127.0.0.1:9100"` }
Config represent application configuration
type DeviceDirectory ¶
type DeviceDirectory struct {
// contains filtered or unexported fields
}
func NewDeviceDirectory ¶
func NewDeviceDirectory(projection *Projection, deviceIds []string) *DeviceDirectory
NewDeviceDirectory creates new device directory.
func (*DeviceDirectory) GetDevices ¶
func (dd *DeviceDirectory) GetDevices(ctx context.Context, req *pbDD.GetDevicesRequest, responseHandler func(*pbDD.Device) error) (statusCode codes.Code, err error)
GetDevices provides list state of devices.
type Projection ¶
type Projection struct {
// contains filtered or unexported fields
}
func NewProjection ¶
func NewProjection(ctx context.Context, name string, store eventstore.EventStore, subscriber eventbus.Subscriber, expiration time.Duration) (*Projection, error)
func (*Projection) GetResourceCtxs ¶
type RequestHandler ¶
type RequestHandler struct {
// contains filtered or unexported fields
}
RequestHandler for handling incoming request
func NewRequestHandler ¶
func NewRequestHandler(authClient pbAS.AuthorizationServiceClient, projection *Projection) *RequestHandler
NewRequestHandler factory for new RequestHandler
func (*RequestHandler) GetDevices ¶
func (r *RequestHandler) GetDevices(req *pbDD.GetDevicesRequest, srv pbDD.DeviceDirectory_GetDevicesServer) error
func (*RequestHandler) GetResourceLinks ¶
func (r *RequestHandler) GetResourceLinks(req *pbRD.GetResourceLinksRequest, srv pbRD.ResourceDirectory_GetResourceLinksServer) error
func (*RequestHandler) GetUsersDevices ¶
func (r *RequestHandler) GetUsersDevices(ctx context.Context, authCtx *pbCQRS.AuthorizationContext, deviceIdsFilter []string) ([]string, error)
func (*RequestHandler) RetrieveResourcesValues ¶
func (r *RequestHandler) RetrieveResourcesValues(req *pbRS.RetrieveResourcesValuesRequest, srv pbRS.ResourceShadow_RetrieveResourcesValuesServer) error
type ResourceDirectory ¶
type ResourceDirectory struct {
// contains filtered or unexported fields
}
func NewResourceDirectory ¶
func NewResourceDirectory(projection *Projection, deviceIds []string) *ResourceDirectory
func (*ResourceDirectory) GetResourceLinks ¶
func (rd *ResourceDirectory) GetResourceLinks(ctx context.Context, in *pbRD.GetResourceLinksRequest, responseHandler func(*pbRD.ResourceLink) error) (statusCode codes.Code, err error)
type ResourceShadow ¶
type ResourceShadow struct {
// contains filtered or unexported fields
}
func NewResourceShadow ¶
func NewResourceShadow(projection *Projection, deviceIds []string) *ResourceShadow
func (*ResourceShadow) RetrieveResourcesValues ¶
func (rd *ResourceShadow) RetrieveResourcesValues(ctx context.Context, req *pbRS.RetrieveResourcesValuesRequest, responseHandler func(*pbRS.ResourceValue) error) (statusCode codes.Code, err error)
Click to show internal directories.
Click to hide internal directories.