grpcMgr

package
v0.0.0-...-9b0a49c Latest Latest
Warning

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

 Go to latest Published: Feb 29, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Overview

* * (C) 2023 Ford Motor Company * * All files and artifacts in the repository at https://github.com/w3c/automotive-viss2 * are licensed under the provisions of the license provided by the LICENSE file in this repository. * *

Index

Constants

View Source 
const KILL_MESSAGE = "kill subscription"
View Source 
const MAXGRPCCLIENTS = 50

Variables

This section is empty.

Functions

func GrpcMgrInit 

func GrpcMgrInit(mgrId int, transportMgrChan chan string)

func RemoveRoutingForwardResponse 

func RemoveRoutingForwardResponse(response string)

Types

type GrpcRequestMessage 

type GrpcRequestMessage struct {
	VssReq       string
	GrpcRespChan chan string
}

type GrpcRoutingData 

type GrpcRoutingData struct {
	ClientId         int
	SubscriptionId   string
	GrpcRespChannel  chan string
	IsMultipleEvents bool
}

type Server 

type Server struct {
	pb.UnimplementedVISSv2Server
}

func (*Server) GetRequest 

func (s *Server) GetRequest(ctx context.Context, in *pb.GetRequestMessage) (*pb.GetResponseMessage, error)

func (*Server) SetRequest 

func (s *Server) SetRequest(ctx context.Context, in *pb.SetRequestMessage) (*pb.SetResponseMessage, error)

func (*Server) SubscribeRequest 

func (s *Server) SubscribeRequest(in *pb.SubscribeRequestMessage, stream pb.VISSv2_SubscribeRequestServer) error

func (*Server) UnsubscribeRequest 

func (s *Server) UnsubscribeRequest(ctx context.Context, in *pb.UnsubscribeRequestMessage) (*pb.UnsubscribeResponseMessage, error)

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.