grpc

Documentation

Index

• Constants
• type ClientApplicationServer
  • func NewClientApplicationServer(serviceDevice *serviceDevice.Service, info *ServiceInformation, ...) *ClientApplicationServer
  • func (s *ClientApplicationServer) ClearCache(ctx context.Context, _ *pb.ClearCacheRequest) (*pb.ClearCacheResponse, error)
  • func (s *ClientApplicationServer) CreateResource(ctx context.Context, req *pb.CreateResourceRequest) (*grpcgwPb.CreateResourceResponse, error)
  • func (s *ClientApplicationServer) DeleteResource(ctx context.Context, req *pb.DeleteResourceRequest) (*grpcgwPb.DeleteResourceResponse, error)
  • func (s *ClientApplicationServer) DisownDevice(ctx context.Context, req *pb.DisownDeviceRequest) (*pb.DisownDeviceResponse, error)
  • func (s *ClientApplicationServer) GetDevice(ctx context.Context, req *pb.GetDeviceRequest) (*grpcgwPb.Device, error)
  • func (s *ClientApplicationServer) GetDeviceResourceLinks(ctx context.Context, req *pb.GetDeviceResourceLinksRequest) (*events.ResourceLinksPublished, error)
  • func (s *ClientApplicationServer) GetDevices(req *pb.GetDevicesRequest, srv pb.ClientApplication_GetDevicesServer) error
  • func (s *ClientApplicationServer) GetInformation(ctx context.Context, _ *pb.GetInformationRequest) (*pb.GetInformationResponse, error)
  • func (s *ClientApplicationServer) GetResource(ctx context.Context, req *pb.GetResourceRequest) (*grpcgwPb.Resource, error)
  • func (s *ClientApplicationServer) OwnDevice(ctx context.Context, req *pb.OwnDeviceRequest) (*pb.OwnDeviceResponse, error)
  • func (s *ClientApplicationServer) UpdateResource(ctx context.Context, req *pb.UpdateResourceRequest) (*grpcgwPb.UpdateResourceResponse, error)
  • func (s *ClientApplicationServer) Version() string
• type Config
• type Service
  • func New(ctx context.Context, serviceName string, config Config, ...) (*Service, error)
  • func (s *Service) Address() string
  • func (s *Service) Serve() error
  • func (s *Service) Stop()
• type ServiceInformation

Constants

const (
	DefaultTimeout = 2000
	MulticastPort  = 5683
)

Types

type ClientApplicationServer

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

func NewClientApplicationServer

func NewClientApplicationServer(serviceDevice *serviceDevice.Service, info *ServiceInformation, 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) GetInformation

func (s *ClientApplicationServer) GetInformation(ctx context.Context, _ *pb.GetInformationRequest) (*pb.GetInformationResponse, 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)

func (*ClientApplicationServer) Version

func (s *ClientApplicationServer) Version() string

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, fileWatcher *fsnotify.Watcher, 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

type ServiceInformation

type ServiceInformation = pb.GetInformationResponse