A lightweight, distributed, relational network architecture for MPC.
Project description
DaaS
中文版 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
Release history Release notifications | RSS feed
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)
Built Distribution
daas-0.0.13-py3-none-any.whl
(181.1 kB
view details)
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
Algorithm | Hash digest | |
---|---|---|
SHA256 | 6ee6a46e3111ce0bc091af8db5f382d1318eff2dc7e2580eb583bc0e8317b47d |
|
MD5 | 0457b9b8eb0251ed1635eb1e301b8478 |
|
BLAKE2b-256 | 8cc666abdbcb6afa510d983cdb86ae513ef00e0379ccf7dcbadfae1ac8455671 |
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
Algorithm | Hash digest | |
---|---|---|
SHA256 | d6986dd7da961c504b9b83393790658cd94d04340ab70bad67f2b5899ee905c8 |
|
MD5 | eac60b1c4c2127e38fbd0a9fe65d42e7 |
|
BLAKE2b-256 | ad6ae3da701783788dec53ef94f2b3aacd53a0dbf8ff1955c51634e96feb3326 |