grpc

package

v0.0.4 Latest Latest Go to latest Published: Jun 30, 2022 License: Apache-2.0 Imports: 42 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/plgd-dev/client-application

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
type ClientApplicationServer
- func NewClientApplicationServer(serviceDevice *serviceDevice.Service, logger log.Logger) *ClientApplicationServer
type Config
type Service
- func New(ctx context.Context, serviceName string, config Config, ...) (*Service, error)

Constants ¶

View Source

const (
	DefaultTimeout = 2000
	MulticastPort  = 5683
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type ClientApplicationServer ¶

type ClientApplicationServer struct {
	pb.UnimplementedClientApplicationServer
	// contains filtered or unexported fields
}

func NewClientApplicationServer ¶

func NewClientApplicationServer(serviceDevice *serviceDevice.Service, logger log.Logger) *ClientApplicationServer

func (*ClientApplicationServer) ClearCache ¶

func (s *ClientApplicationServer) ClearCache(ctx context.Context, _ *pb.ClearCacheRequest) (*pb.ClearCacheResponse, error)

func (*ClientApplicationServer) CreateResource ¶

func (s *ClientApplicationServer) CreateResource(ctx context.Context, req *pb.CreateResourceRequest) (*grpcgwPb.CreateResourceResponse, error)

func (*ClientApplicationServer) DeleteResource ¶

func (s *ClientApplicationServer) DeleteResource(ctx context.Context, req *pb.DeleteResourceRequest) (*grpcgwPb.DeleteResourceResponse, error)

func (*ClientApplicationServer) DisownDevice ¶

func (s *ClientApplicationServer) DisownDevice(ctx context.Context, req *pb.DisownDeviceRequest) (*pb.DisownDeviceResponse, error)

func (*ClientApplicationServer) GetDevice ¶

func (s *ClientApplicationServer) GetDevice(ctx context.Context, req *pb.GetDeviceRequest) (*grpcgwPb.Device, error)

func (*ClientApplicationServer) GetDeviceResourceLinks ¶

func (s *ClientApplicationServer) GetDeviceResourceLinks(ctx context.Context, req *pb.GetDeviceResourceLinksRequest) (*events.ResourceLinksPublished, error)

func (*ClientApplicationServer) GetDevices ¶

func (s *ClientApplicationServer) GetDevices(req *pb.GetDevicesRequest, srv pb.ClientApplication_GetDevicesServer) error

func (*ClientApplicationServer) GetResource ¶

func (s *ClientApplicationServer) GetResource(ctx context.Context, req *pb.GetResourceRequest) (*grpcgwPb.Resource, error)

func (*ClientApplicationServer) OwnDevice ¶

func (s *ClientApplicationServer) OwnDevice(ctx context.Context, req *pb.OwnDeviceRequest) (*pb.OwnDeviceResponse, error)

func (*ClientApplicationServer) UpdateResource ¶

func (s *ClientApplicationServer) UpdateResource(ctx context.Context, req *pb.UpdateResourceRequest) (*grpcgwPb.UpdateResourceResponse, error)

type Config ¶

type Config = server.Config

type Service ¶

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

func New ¶

func New(ctx context.Context, serviceName string, config Config, clientApplicationServer *ClientApplicationServer, logger log.Logger, tracerProvider trace.TracerProvider) (*Service, error)

New creates new GRPC service

func (*Service) Address ¶

func (s *Service) Address() string

func (*Service) Serve ¶

func (s *Service) Serve() error

Serve starts the service's HTTP server and blocks

func (*Service) Stop ¶

func (s *Service) Stop()

Shutdown ends serving

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL