service

Documentation

Index

• func AddHandler(svr *kitNetGrpc.Server, config HandlerConfig, clientTLS *tls.Config) error
• func Register(server *grpc.Server, handler *RequestHandler)
• type Config
  • func (c Config) String() string
• type HandlerConfig
• type RequestHandler
  • func NewRequestHandler(resourceDirectoryClient pb.GrpcGatewayClient, closeFunc func()) *RequestHandler
  • func NewRequestHandlerFromConfig(config HandlerConfig, clientTLS *tls.Config) (*RequestHandler, error)
  • 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)

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

func (Config) String

func (c Config) String() string

String return string representation of Config

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

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)