Octopus

Octopus is an asynchronous socket server for the linux environment and is built use EPOLL only.

                    .-'   `'.
                   /         \
                   |         ;
                   |         |           ___.--,
          _.._     |0) ~ (0) |    _.---'`__.-( (_.
   __.--'`_.. '.__.\    '--. \_.-' ,.--'`     `""`
  ( ,.--'`   ',__ /./;   ;, '.__.'`    __
 _`) )  .---.__.' / |   |\   \__..--""  "'"--.,_
 `---' .'.''-._.-'`_./  /\ '.  \ _.-~~~````~~~-._`-.__.'
       | |  .' _.-' |  |  \  \  '.               `~---`
            \ \/ .'     \  \   '. '-._)
             \/ /        \  \    `=.__`~-.
        jgs  / /\         `) )    / / `"".`\
       , _.-'.'\ \        / /    ( (     / /
        `--~`   ) )    .-'.'      '.'.  | (
               (/`    ( (`          ) )  '-;
                `      '-;         (-'

It is ideal for providing local services over a Unix Domain Socket or to anywhere using an inet socket.

You initialise the server with a connection object which contains the application logic and routing.

Code example: A server that echoes any message sent to it out to all open connections

from octopus import Octopus, SocketConnection

class EchoConnection(SocketConnection):
    
    connections = []

    def connect(self):
        self.connections.append(self)

    def receive(self, message):
        for connection in self.connections:
            connection.send(message)

    def close(self):
        self.connections.remove(self)
    
    if __main__ == '__main__':
        server = Octopus(EchoConnection)
        server.listen(9876)
        server.start()

The server will listen on port 9876 any connected socket can send a message and all connections will recieve a copy of that message

So, to create a different type of connection you:

1. Subclass SocketConnection
2. Overide the connect, close, and or receive methods where appropriate
3. Create a server instance passing in your connection type
4. Tell the server to listen on a port
5. Start the servers event loop