Documentation ¶
Index ¶
- type GatewayRPCBroker
- func (_m *GatewayRPCBroker) CancelGatewayRequest(gwId string, reqId uint32) error
- func (_m *GatewayRPCBroker) CleanupGateway(gwId string) error
- func (_m *GatewayRPCBroker) InitializeGateway(gwId string) chan *protos.SyncRPCRequest
- func (_m *GatewayRPCBroker) ProcessGatewayResponse(response *protos.SyncRPCResponse) error
- func (_m *GatewayRPCBroker) SendRequestToGateway(gwReq *protos.GatewayRequest) (*broker.GatewayResponseChannel, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type GatewayRPCBroker ¶
GatewayRPCBroker is an autogenerated mock type for the GatewayRPCBroker type
func (*GatewayRPCBroker) CancelGatewayRequest ¶
func (_m *GatewayRPCBroker) CancelGatewayRequest(gwId string, reqId uint32) error
CancelGatewayRequest provides a mock function with given fields: gwId, reqId
func (*GatewayRPCBroker) CleanupGateway ¶
func (_m *GatewayRPCBroker) CleanupGateway(gwId string) error
CleanupGateway provides a mock function with given fields: gwId
func (*GatewayRPCBroker) InitializeGateway ¶
func (_m *GatewayRPCBroker) InitializeGateway(gwId string) chan *protos.SyncRPCRequest
InitializeGateway provides a mock function with given fields: gwId
func (*GatewayRPCBroker) ProcessGatewayResponse ¶
func (_m *GatewayRPCBroker) ProcessGatewayResponse(response *protos.SyncRPCResponse) error
ProcessGatewayResponse provides a mock function with given fields: response
func (*GatewayRPCBroker) SendRequestToGateway ¶
func (_m *GatewayRPCBroker) SendRequestToGateway(gwReq *protos.GatewayRequest) (*broker.GatewayResponseChannel, error)
SendRequestToGateway provides a mock function with given fields: gwReq
Click to show internal directories.
Click to hide internal directories.