Index

_

__init__() (mosec.runtime.Runtime method) (mosec.server.Server method) (mosec.worker.Worker method)

A

append_worker() (mosec.server.Server method)

C

ClientError

D

DecodingError deserialize() (mosec.mixin.MsgpackMixin method) (mosec.mixin.TypedMsgPackMixin method) (mosec.worker.Worker method)

deserialize_ipc() (mosec.mixin.NumBinIPCMixin method) (mosec.mixin.PlasmaShmIPCMixin method) (mosec.mixin.RedisShmIPCMixin method) (mosec.worker.Worker method)

E

EncodingError

F

forward() (mosec.worker.Worker method)

G

generate_openapi() (in module mosec.server)

get_forward_json_schema() (mosec.mixin.TypedMsgPackMixin class method) (mosec.worker.Worker class method)

M

max_batch_size (mosec.worker.Worker property) module mosec.errors mosec.mixin mosec.runtime mosec.server mosec.worker mosec.errors module mosec.mixin module

mosec.runtime module mosec.server module mosec.worker module MosecError MosecTimeoutError MsgpackMixin (class in mosec.mixin)

N

NumBinIPCMixin (class in mosec.mixin)

P

PlasmaShmIPCMixin (class in mosec.mixin)

R

RedisShmIPCMixin (class in mosec.mixin) register_daemon() (mosec.server.Server method)

register_runtime() (mosec.server.Server method) run() (mosec.server.Server method) Runtime (class in mosec.runtime)

S

send_stream_event() (mosec.worker.SSEWorker method) serialize() (mosec.mixin.MsgpackMixin method) (mosec.mixin.TypedMsgPackMixin method) (mosec.worker.Worker method) serialize_ipc() (mosec.mixin.NumBinIPCMixin method) (mosec.mixin.PlasmaShmIPCMixin method) (mosec.mixin.RedisShmIPCMixin method) (mosec.worker.Worker method)

Server (class in mosec.server) ServerError set_plasma_path() (mosec.mixin.PlasmaShmIPCMixin class method) set_redis_url() (mosec.mixin.RedisShmIPCMixin class method) SSEWorker (class in mosec.worker) stage (mosec.worker.Worker property)

T

TypedMsgPackMixin (class in mosec.mixin)

V

ValidationError

W

Worker (class in mosec.worker)

worker_id (mosec.worker.Worker property)