jina.peapods.stream.gateway module

class jina.peapods.stream.gateway.ZmqGatewayStreamer(args, iolet)[source]

Bases: jina.peapods.stream.gateway.GatewayStreamer

Streamer used at Gateway to stream ZMQ requests/responses to/from Executors

Parameters
  • args (Namespace) – args from CLI

  • iolet (Union[ForwardRef, ForwardRef, ForwardRef, ForwardRef]) – One of AsyncZmqlet or Grpclet. Used for sending/receiving data to/from the Flow

class jina.peapods.stream.gateway.GrpcGatewayStreamer(args, iolet)[source]

Bases: jina.peapods.stream.gateway.GatewayStreamer

Streamer used at Gateway to stream GRPC requests/responses to/from Executors

Parameters
  • args (Namespace) – args from CLI

  • iolet (Grpclet) – One of AsyncZmqlet or Grpclet. Used for sending/receiving data to/from the Flow