grpc

type ReverseUnaryMessage interface {
	proto.Message
	GetRequestId() string
}

type ReverseUnaryRPCs interface {
	Send(client string, req ReverseUnaryMessage) error
	WatchResponse(client string, reqID string, resp chan ReverseUnaryMessage) error
	DeleteWatch(client string, reqID string)

	ClientConnected(client string, stream grpc.ServerStream)
	ClientDisconnected(client string)
	ResponseReceived(client string, resp ReverseUnaryMessage) error
}