Versions in this module Expand all Collapse all v1 v1.2.1 Aug 20, 2020 v1.2.0 Aug 20, 2020 Changes in this version + type GatewayRPCBroker interface + CancelGatewayRequest func(gwId string, reqId uint32) error + CleanupGateway func(gwId string) error + InitializeGateway func(gwId string) chan *protos.SyncRPCRequest + ProcessGatewayResponse func(response *protos.SyncRPCResponse) error + SendRequestToGateway func(gwReq *protos.GatewayRequest) (*GatewayResponseChannel, error) + type GatewayRPCBrokerImpl struct + func NewGatewayReqRespBroker() *GatewayRPCBrokerImpl + func (broker *GatewayRPCBrokerImpl) CancelGatewayRequest(gwId string, reqId uint32) error + func (broker *GatewayRPCBrokerImpl) CleanupGateway(gwId string) error + func (broker *GatewayRPCBrokerImpl) InitializeGateway(gwId string) chan *protos.SyncRPCRequest + func (broker *GatewayRPCBrokerImpl) ProcessGatewayResponse(response *protos.SyncRPCResponse) error + func (broker *GatewayRPCBrokerImpl) SendRequestToGateway(gwReq *protos.GatewayRequest) (*GatewayResponseChannel, error) + type GatewayResponseChannel struct + ReqId uint32 + RespChan chan *protos.GatewayResponse
Go to main page