grpcMgr

README

#Running grpc client test cases.

Test cases

`

Documentation

Overview

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

Index

• Constants
• func GrpcMgrInit(mgrId int, transportMgrChan chan string)
• func RemoveRoutingForwardResponse(response string)
• type GrpcRequestMessage
• type GrpcRoutingData
• type Handler
  • func (h *Handler) HandleConn(c context.Context, s stats.ConnStats)
  • func (h *Handler) HandleRPC(context.Context, stats.RPCStats)
  • func (h *Handler) TagConn(context.Context, *stats.ConnTagInfo) context.Context
  • func (h *Handler) TagRPC(context.Context, *stats.RPCTagInfo) context.Context
• type Server
  • func (s *Server) GetRequest(ctx context.Context, in *pb.GetRequestMessage) (*pb.GetResponseMessage, error)
  • func (s *Server) SetRequest(ctx context.Context, in *pb.SetRequestMessage) (*pb.SetResponseMessage, error)
  • func (s *Server) SubscribeRequest(in *pb.SubscribeRequestMessage, stream pb.VISS_SubscribeRequestServer) error
  • func (s *Server) UnsubscribeRequest(ctx context.Context, in *pb.UnsubscribeRequestMessage) (*pb.UnsubscribeResponseMessage, error)

Constants

const KILL_MESSAGE = "kill subscription"

const MAXGRPCCLIENTS = 50

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 Handler

type Handler struct {
}

func (*Handler) HandleConn

func (h *Handler) HandleConn(c context.Context, s stats.ConnStats)

HandleConn processes the Conn stats.

func (*Handler) HandleRPC

func (h *Handler) HandleRPC(context.Context, stats.RPCStats)

HandleRPC processes the RPC stats.

func (*Handler) TagConn

func (h *Handler) TagConn(context.Context, *stats.ConnTagInfo) context.Context

func (*Handler) TagRPC

func (h *Handler) TagRPC(context.Context, *stats.RPCTagInfo) context.Context

type Server

type Server struct {
	pb.UnimplementedVISSServer
}

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.VISS_SubscribeRequestServer) error

func (*Server) UnsubscribeRequest

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