Index

A

abort() (kbus.Stream method) Aborted

address (kbus.core.Listener property) attach_acceptor() (kbus.Dispatcher method) attach_link() (kbus.Dispatcher method)

C

call() (kbus.core.Connection method) (kbus.Member method) close() (kbus.core.Connection method) (kbus.core.Listener method) (kbus.Dispatcher method) (kbus.Link method) (kbus.LinkAcceptor method) (kbus.Member method) (kbus.Stream method)

closed (kbus.core.Connection property) connect() (in module kbus.core) (kbus.Member method) Connection (class in kbus.core)

D

Dispatcher (class in kbus)

dispatcher (kbus.Member property)

E

Error

expose() (in module kbus)

F

fail() (kbus.Reply method)

FrameTooLarge

K

kbus.core module

L

Limits (class in kbus) Link (class in kbus) LinkAcceptor (class in kbus) LinkLost

listen() (in module kbus.core) (kbus.Dispatcher method) (kbus.LinkAcceptor method) Listener (class in kbus.core)

M

Member (class in kbus) Message (class in kbus)

module kbus.core

N

name (kbus.Member property) NoSuchInstance

NoSuchMember NoSuchRoute

O

on_disconnect() (kbus.Dispatcher method) on_message() (kbus.Dispatcher method) on_reply() (kbus.Member method)

open() (kbus.core.Connection method) (kbus.Member method) Overloaded

P

pipe() (in module kbus.core)

ProtocolError

R

reachable (kbus.Link property) Reconnect (class in kbus) Refused

Rejected RemoteError Reply (class in kbus) route() (kbus.Member method)

S

send() (kbus.core.Connection method) (kbus.Member method) (kbus.Reply method) (kbus.Stream method)

Stream (class in kbus)

U

Unreachable

W

wait_closed() (kbus.core.Connection method)

wait_reachable() (kbus.Link method) wait_unreachable() (kbus.Link method)