server

Documentation

Index

• type CommonRPCServer
  • func NewCommonRPCServer() *CommonRPCServer
  • func (crs *CommonRPCServer) Ping(context.Context, *emptypb.Empty) (*drivercommon.Pong, error)
  • func (crs *CommonRPCServer) Version(context.Context, *emptypb.Empty) (*drivercommon.VersionResponse, error)
• type RpcService
  • func NewRpcService(ctx context.Context, wg *sync.WaitGroup, cancel context.CancelFunc, ...) (*RpcService, error)
  • func (server *RpcService) CloudInstanceStatueCallback(ctx context.Context, ...) (*emptypb.Empty, error)
  • func (server *RpcService) CreateDeviceCallback(ctx context.Context, request *devicecallback.CreateDeviceCallbackRequest) (*emptypb.Empty, error)
  • func (server *RpcService) CreateProductCallback(ctx context.Context, request *productcallback.CreateProductCallbackRequest) (*emptypb.Empty, error)
  • func (server *RpcService) DeleteDeviceCallback(ctx context.Context, request *devicecallback.DeleteDeviceCallbackRequest) (*emptypb.Empty, error)
  • func (server *RpcService) DeleteProductCallback(ctx context.Context, request *productcallback.DeleteProductCallbackRequest) (*emptypb.Empty, error)
  • func (server *RpcService) Start() error
  • func (server *RpcService) ThingModelMsgIssue(ctx context.Context, request *thingmodel.ThingModelIssueMsg) (*emptypb.Empty, error)
  • func (server *RpcService) UpdateDeviceCallback(ctx context.Context, request *devicecallback.UpdateDeviceCallbackRequest) (*emptypb.Empty, error)
  • func (server *RpcService) UpdateProductCallback(ctx context.Context, request *productcallback.UpdateProductCallbackRequest) (*emptypb.Empty, error)

Types

type CommonRPCServer

type CommonRPCServer struct {
	drivercommon.UnimplementedCommonServer
}

func NewCommonRPCServer

func NewCommonRPCServer() *CommonRPCServer

func (*CommonRPCServer) Ping

func (crs *CommonRPCServer) Ping(context.Context, *emptypb.Empty) (*drivercommon.Pong, error)

Ping tests whether the service is working

func (*CommonRPCServer) Version

func (crs *CommonRPCServer) Version(context.Context, *emptypb.Empty) (*drivercommon.VersionResponse, error)

Version obtains version information from the target service.

type RpcService

type RpcService struct {
	thingmodel.UnimplementedThingModelDownServiceServer
	productcallback.UnimplementedProductCallBackServiceServer
	devicecallback.UnimplementedDeviceCallBackServiceServer
	cloudinstancecallback.UnimplementedCloudInstanceCallBackServiceServer

	*CommonRPCServer
	// contains filtered or unexported fields
}

func NewRpcService

func NewRpcService(ctx context.Context, wg *sync.WaitGroup, cancel context.CancelFunc, cfg config.RPCConfig,
	dc cache.DeviceProvider, pc cache.ProductProvider, driverProvider interfaces.Driver, cli *client.ResourceClient,
	logger logger.Logger) (*RpcService, error)

func (*RpcService) CloudInstanceStatueCallback

func (server *RpcService) CloudInstanceStatueCallback(ctx context.Context,
	request *cloudinstancecallback.CloudInstanceStatueCallbackRequest) (*emptypb.Empty, error)

func (*RpcService) CreateDeviceCallback

func (server *RpcService) CreateDeviceCallback(ctx context.Context, request *devicecallback.CreateDeviceCallbackRequest) (*emptypb.Empty, error)

func (*RpcService) CreateProductCallback

func (server *RpcService) CreateProductCallback(ctx context.Context, request *productcallback.CreateProductCallbackRequest) (*emptypb.Empty, error)

func (*RpcService) DeleteDeviceCallback

func (server *RpcService) DeleteDeviceCallback(ctx context.Context, request *devicecallback.DeleteDeviceCallbackRequest) (*emptypb.Empty, error)

func (*RpcService) DeleteProductCallback

func (server *RpcService) DeleteProductCallback(ctx context.Context, request *productcallback.DeleteProductCallbackRequest) (*emptypb.Empty, error)

func (*RpcService) Start

func (server *RpcService) Start() error

func (*RpcService) ThingModelMsgIssue

func (server *RpcService) ThingModelMsgIssue(ctx context.Context, request *thingmodel.ThingModelIssueMsg) (*emptypb.Empty, error)

func (*RpcService) UpdateDeviceCallback

func (server *RpcService) UpdateDeviceCallback(ctx context.Context, request *devicecallback.UpdateDeviceCallbackRequest) (*emptypb.Empty, error)

func (*RpcService) UpdateProductCallback

func (server *RpcService) UpdateProductCallback(ctx context.Context, request *productcallback.UpdateProductCallbackRequest) (*emptypb.Empty, error)