MPIPipeline constructor

MPIPipeline(
  1. InvocationHandler _h
)

Implementation

MPIPipeline(this._h) {
  _methods = {
    'peek': Method(
      {
        MPI: const MPI(
          name: 'mesh.chan.peek',
          version: '0.0.0',
          proto: 'grpc',
          codec: 'json',
          flags: 0,
          timeout: 12000,
          retries: 3,
          idc: '',
          zone: '',
          cluster: '',
          cell: '',
          group: '',
          address: '',
        ),
      },
      Pipeline,
      _MeshPipelinePeekParameters,
      _MeshPipelinePeekReturns,
    ),
    'pop': Method(
      {
        MPI: const MPI(
          name: 'mesh.chan.pop',
          version: '0.0.0',
          proto: 'grpc',
          codec: 'json',
          flags: 0,
          timeout: 12000,
          retries: 3,
          idc: '',
          zone: '',
          cluster: '',
          cell: '',
          group: '',
          address: '',
        ),
      },
      Pipeline,
      _MeshPipelinePopParameters,
      _MeshPipelinePopReturns,
    ),
    'push': Method(
      {
        MPI: const MPI(
          name: 'mesh.chan.push',
          version: '0.0.0',
          proto: 'grpc',
          codec: 'json',
          flags: 0,
          timeout: 12000,
          retries: 3,
          idc: '',
          zone: '',
          cluster: '',
          cell: '',
          group: '',
          address: '',
        ),
      },
      Pipeline,
      _MeshPipelinePushParameters,
      _MeshPipelinePushReturns,
    ),
    'release': Method(
      {
        MPI: const MPI(
          name: 'mesh.chan.release',
          version: '0.0.0',
          proto: 'grpc',
          codec: 'json',
          flags: 0,
          timeout: 12000,
          retries: 3,
          idc: '',
          zone: '',
          cluster: '',
          cell: '',
          group: '',
          address: '',
        ),
      },
      Pipeline,
      _MeshPipelineReleaseParameters,
      _MeshPipelineReleaseReturns,
    ),
  };
}