grpc

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 25, 2022 License: Apache-2.0 Imports: 58 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultTimeout = 2 * time.Second
	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(cfg *atomic.Pointer[config.Config], serviceDevice *serviceDevice.Service, info *configGrpc.ServiceInformation, logger log.Logger) *ClientApplicationServer

func (*ClientApplicationServer) ClearCache 

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

func (*ClientApplicationServer) Close added in v0.2.0 

func (s *ClientApplicationServer) Close()

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) FinishInitialize added in v0.2.0 

func (s *ClientApplicationServer) FinishInitialize(ctx context.Context, req *pb.FinishInitializeRequest) (*pb.FinishInitializeResponse, error)

func (*ClientApplicationServer) FinishOwnDevice added in v0.2.0 

func (s *ClientApplicationServer) FinishOwnDevice(ctx context.Context, req *pb.FinishOwnDeviceRequest) (*pb.FinishOwnDeviceResponse, error)

func (*ClientApplicationServer) GetConfig added in v0.3.0 

func (s *ClientApplicationServer) GetConfig() config.Config

func (*ClientApplicationServer) GetConfiguration added in v0.2.0 

func (s *ClientApplicationServer) GetConfiguration(ctx context.Context, _ *pb.GetConfigurationRequest) (*pb.GetConfigurationResponse, error)

func (*ClientApplicationServer) GetDevice 

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 (*ClientApplicationServer) GetDevices 

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

func (*ClientApplicationServer) GetIdentityCertificate added in v0.2.0 

func (s *ClientApplicationServer) GetIdentityCertificate(ctx context.Context, req *pb.GetIdentityCertificateRequest) (*pb.GetIdentityCertificateResponse, error)

func (*ClientApplicationServer) GetJSONWebKeys added in v0.2.0 

func (s *ClientApplicationServer) GetJSONWebKeys(ctx context.Context, req *pb.GetJSONWebKeysRequest) (*structpb.Struct, error)

func (*ClientApplicationServer) GetResource 

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

func (*ClientApplicationServer) HasJWTAuthorizationEnabled added in v0.2.0 

func (s *ClientApplicationServer) HasJWTAuthorizationEnabled() bool

func (*ClientApplicationServer) Initialize added in v0.2.0 

func (s *ClientApplicationServer) Initialize(ctx context.Context, req *pb.InitializeRequest) (*pb.InitializeResponse, error)

func (*ClientApplicationServer) InitializeRemoteProvisioning added in v0.3.0 

func (s *ClientApplicationServer) InitializeRemoteProvisioning(ctx context.Context, req *pb.InitializeRequest) (*pb.InitializeResponse, error)

func (*ClientApplicationServer) OwnDevice 

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

func (*ClientApplicationServer) ParseWithClaims added in v0.2.0 

func (s *ClientApplicationServer) ParseWithClaims(token string, claims jwt.Claims) error

func (*ClientApplicationServer) Reset added in v0.2.0 

func (s *ClientApplicationServer) Reset(ctx context.Context, req *pb.ResetRequest) (*pb.ResetResponse, error)

func (*ClientApplicationServer) StoreConfig added in v0.3.0 

func (s *ClientApplicationServer) StoreConfig(cfg config.Config) error

func (*ClientApplicationServer) UpdateJSONWebKeys added in v0.2.0 

func (s *ClientApplicationServer) UpdateJSONWebKeys(ctx context.Context, jwksReq *structpb.Struct) error

func (*ClientApplicationServer) UpdatePSK added in v0.3.0 

func (s *ClientApplicationServer) UpdatePSK(subjectUUID, key string) error

func (*ClientApplicationServer) UpdateResource 

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

func (*ClientApplicationServer) Version added in v0.0.6 

func (s *ClientApplicationServer) Version() string

type JSONWebKeyCache added in v0.2.0 

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

func NewJSONWebKeyCache added in v0.2.0 

func NewJSONWebKeyCache(owner uuid.UUID, keys jwk.Set) *JSONWebKeyCache

func (*JSONWebKeyCache) GetKey added in v0.2.0 

func (c *JSONWebKeyCache) GetKey(token *jwt.Token) (interface{}, error)

func (*JSONWebKeyCache) LookupKey added in v0.2.0 

func (c *JSONWebKeyCache) LookupKey(token *jwt.Token) (jwk.Key, error)

type Service 

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

func New 

func New(ctx context.Context, serviceName string, config configGrpc.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) Close added in v0.2.0 

func (s *Service) Close() error

Shutdown ends serving

func (*Service) Serve 

func (s *Service) Serve() error

Serve starts the service's HTTP server and blocks

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.