Skip to main content

A lightweight, distributed, relational network architecture for MPC.

Project description

DaaS

Build Status Financial Contributors on Open Collective codecov license

中文版 README

Introduction

Mesh is a standard implementation for Private Transmission Protocol specification.

Mesh Python develop kits base on Python3.6. Recommend use poetry to manage dependencies.

Features

As an open source Internet of Data infrastructure develop kits, Mesh has the following core functions:

  • Minimal kernel with SPI plugin architecture, everything is replacement.
  • Support full stack of service mesh architecture.
  • Support full stack of service oriented architecture.
  • Support transport with TCP, HTTP, or other RPC protocols.
  • Support rich routing features.
  • Support reliable upstream management and load balancing capabilities.
  • Support network and protocol layer observability.
  • Support mTLS and protocols on TLS.
  • Support rich extension mechanism to provide highly customizable expansion capabilities.
  • Support process smooth upgrade.

Get Started

poetry add imesh

or

pip install imesh

RPC

Declared rpc interface Facade.

from abc import ABC, abstractmethod

from mesh import spi, mpi


@spi("mesh")
class Tokenizer(ABC):

    @abstractmethod
    @mpi("mesh.trust.apply")
    def apply(self, kind: str, duration: int) -> str:
        """
        Apply a node token.
        :param kind:
        :param duration:
        :return:
        """
        pass

    @abstractmethod
    @mpi("mesh.trust.verify")
    def verify(self, token: str) -> bool:
        """
        Verify some token verifiable.
        :param token:
        :return:
        """
        pass

Declared rpc service Implement.

from mesh import mps, Tokenizer


@mps
class MeshTokenizer(Tokenizer):

    def apply(self, kind: str, duration: int) -> str:
        return "foo"

    def verify(self, token: str) -> bool:
        return True

Remote reference procedure call.

from mesh import mpi, Tokenizer


class Component:

    @mpi
    def tokenizer(self) -> Tokenizer:
        pass

    def invoke(self) -> bool:
        token = self.tokenizer().apply('PERMIT', 1000 * 60 * 5)
        return self.tokenizer().verify(token)

Transport

Transport is a full duplex communication stream implement.

import mesh
from mesh import Mesh, log, ServiceLoader, Transport, Routable
from mesh.prsim import Metadata


def main():
    mesh.start()

    transport = Routable.of(ServiceLoader.load(Transport).get("mesh"))
    session = transport.with_address("10.99.1.33:570").local().open('session_id_008', {
        Metadata.MESH_VERSION.key(): '',
        Metadata.MESH_TECH_PROVIDER_CODE.key(): 'LX',
        Metadata.MESH_TRACE_ID.key(): Mesh.context().get_trace_id(),
        Metadata.MESH_TOKEN.key(): 'x',
        Metadata.MESH_SESSION_ID.key(): 'session_id_008',
        Metadata.MESH_TARGET_INST_ID.key(): 'JG0100000100000000',
    })
    for index in range(100):
        inbound = f"节点4发送给节点5报文{index}"
        log.info(f"节点4发送:{inbound}")
        session.push(inbound.encode('utf-8'), {}, "topic")
        outbound = session.pop(10000, "topic")
        if outbound:
            log.info(f"节点4接收:{outbound.decode('utf-8')}")

Project details


Download files

Download the file for your platform. If you're not sure which to choose, learn more about installing packages.

Source Distribution

daas-0.0.13.tar.gz (111.1 kB view details)

Uploaded Source

Built Distribution

daas-0.0.13-py3-none-any.whl (181.1 kB view details)

Uploaded Python 3

File details

Details for the file daas-0.0.13.tar.gz.

File metadata

  • Download URL: daas-0.0.13.tar.gz
  • Upload date:
  • Size: 111.1 kB
  • Tags: Source
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.7.0 CPython/3.11.6 Darwin/22.6.0

File hashes

Hashes for daas-0.0.13.tar.gz
Algorithm Hash digest
SHA256 6ee6a46e3111ce0bc091af8db5f382d1318eff2dc7e2580eb583bc0e8317b47d
MD5 0457b9b8eb0251ed1635eb1e301b8478
BLAKE2b-256 8cc666abdbcb6afa510d983cdb86ae513ef00e0379ccf7dcbadfae1ac8455671

See more details on using hashes here.

File details

Details for the file daas-0.0.13-py3-none-any.whl.

File metadata

  • Download URL: daas-0.0.13-py3-none-any.whl
  • Upload date:
  • Size: 181.1 kB
  • Tags: Python 3
  • Uploaded using Trusted Publishing? No
  • Uploaded via: poetry/1.7.0 CPython/3.11.6 Darwin/22.6.0

File hashes

Hashes for daas-0.0.13-py3-none-any.whl
Algorithm Hash digest
SHA256 d6986dd7da961c504b9b83393790658cd94d04340ab70bad67f2b5899ee905c8
MD5 eac60b1c4c2127e38fbd0a9fe65d42e7
BLAKE2b-256 ad6ae3da701783788dec53ef94f2b3aacd53a0dbf8ff1955c51634e96feb3326

See more details on using hashes here.

Supported by

AWS AWS Cloud computing and Security Sponsor Datadog Datadog Monitoring Fastly Fastly CDN Google Google Download Analytics Microsoft Microsoft PSF Sponsor Pingdom Pingdom Monitoring Sentry Sentry Error logging StatusPage StatusPage Status page