Documentation
¶
Index ¶
- func AddHandler(svr *kitNetGrpc.Server, config HandlerConfig, clientTLS *tls.Config) error
- func Register(server *grpc.Server, handler *RequestHandler)
- type Config
- type HandlerConfig
- type RequestHandler
- func (r *RequestHandler) Close()
- func (r *RequestHandler) DeleteResource(ctx context.Context, req *pb.DeleteResourceRequest) (*pb.DeleteResourceResponse, error)
- func (r *RequestHandler) GetClientConfiguration(ctx context.Context, req *pb.ClientConfigurationRequest) (*pb.ClientConfigurationResponse, error)
- func (r *RequestHandler) GetDevices(req *pb.GetDevicesRequest, srv pb.GrpcGateway_GetDevicesServer) error
- func (r *RequestHandler) GetResourceLinks(req *pb.GetResourceLinksRequest, srv pb.GrpcGateway_GetResourceLinksServer) error
- func (r *RequestHandler) RetrieveResourceFromDevice(ctx context.Context, req *pb.RetrieveResourceFromDeviceRequest) (*pb.RetrieveResourceFromDeviceResponse, error)
- func (r *RequestHandler) RetrieveResourcesValues(req *pb.RetrieveResourcesValuesRequest, ...) error
- func (r *RequestHandler) SubscribeForEvents(srv pb.GrpcGateway_SubscribeForEventsServer) (errRet error)
- func (r *RequestHandler) UpdateResourcesValues(ctx context.Context, req *pb.UpdateResourceValuesRequest) (*pb.UpdateResourceValuesResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddHandler ¶
func AddHandler(svr *kitNetGrpc.Server, config HandlerConfig, clientTLS *tls.Config) error
func Register ¶
func Register(server *grpc.Server, handler *RequestHandler)
Register registers the handler instance with a gRPC server.
Types ¶
type Config ¶
type Config struct {
ResourceDirectoryAddr string `envconfig:"RESOURCE_DIRECTORY_ADDRESS" default:"127.0.0.1:9100"`
}
Config represent application configuration
type HandlerConfig ¶
type HandlerConfig struct {
Service Config
}
type RequestHandler ¶
type RequestHandler struct {
// contains filtered or unexported fields
}
RequestHandler handles incoming requests.
func NewRequestHandler ¶
func NewRequestHandler( resourceDirectoryClient pb.GrpcGatewayClient, closeFunc func(), ) *RequestHandler
NewRequestHandler factory for new RequestHandler.
func NewRequestHandlerFromConfig ¶
func NewRequestHandlerFromConfig(config HandlerConfig, clientTLS *tls.Config) (*RequestHandler, error)
func (*RequestHandler) Close ¶
func (r *RequestHandler) Close()
func (*RequestHandler) DeleteResource ¶ added in v1.1.0
func (r *RequestHandler) DeleteResource(ctx context.Context, req *pb.DeleteResourceRequest) (*pb.DeleteResourceResponse, error)
func (*RequestHandler) GetClientConfiguration ¶
func (r *RequestHandler) GetClientConfiguration(ctx context.Context, req *pb.ClientConfigurationRequest) (*pb.ClientConfigurationResponse, error)
func (*RequestHandler) GetDevices ¶
func (r *RequestHandler) GetDevices(req *pb.GetDevicesRequest, srv pb.GrpcGateway_GetDevicesServer) error
func (*RequestHandler) GetResourceLinks ¶
func (r *RequestHandler) GetResourceLinks(req *pb.GetResourceLinksRequest, srv pb.GrpcGateway_GetResourceLinksServer) error
func (*RequestHandler) RetrieveResourceFromDevice ¶
func (r *RequestHandler) RetrieveResourceFromDevice(ctx context.Context, req *pb.RetrieveResourceFromDeviceRequest) (*pb.RetrieveResourceFromDeviceResponse, error)
func (*RequestHandler) RetrieveResourcesValues ¶
func (r *RequestHandler) RetrieveResourcesValues(req *pb.RetrieveResourcesValuesRequest, srv pb.GrpcGateway_RetrieveResourcesValuesServer) error
func (*RequestHandler) SubscribeForEvents ¶
func (r *RequestHandler) SubscribeForEvents(srv pb.GrpcGateway_SubscribeForEventsServer) (errRet error)
func (*RequestHandler) UpdateResourcesValues ¶
func (r *RequestHandler) UpdateResourcesValues(ctx context.Context, req *pb.UpdateResourceValuesRequest) (*pb.UpdateResourceValuesResponse, error)
Source Files
Click to show internal directories.
Click to hide internal directories.