scalaris

Module scalaris

Classes

JSONConnection
Abstracts connections to scalaris using JSON

ScalarisError
Base class for errors in the scalaris package.

AbortError
Exception that is thrown if a the commit of a write operation on a scalaris ring fails.

ConnectionError
Exception that is thrown if an operation on a scalaris ring fails because a connection does not exist or has been disconnected.

KeyChangedError
Exception that is thrown if a test_and_set operation on a scalaris ring fails because the old value did not match the expected value.

NodeNotFoundError
Exception that is thrown if a delete operation on a scalaris ring fails because no scalaris node was found.

NotFoundError
Exception that is thrown if a read operation on a scalaris ring fails because the key did not exist before.

NotAListError
Exception that is thrown if a add_del_on_list operation on a scalaris ring fails because the participating values are not lists.

NotANumberError
Exception that is thrown if a add_del_on_list operation on a scalaris ring fails because the participating values are not numbers.

TimeoutError
Exception that is thrown if a read or write operation on a scalaris ring fails due to a timeout.

ConfigError
Exception that is thrown if a autoscale operation fails, because it was not configured correctly.

LockError
Exception that is thrown if a autoscale lock/unlock operation fails, because of a wrong lock state, i.e.

UnknownError
Generic exception that is thrown during operations on a scalaris ring, e.g.

DeleteResult
Stores the result of a delete operation.

ConnectionPool
Implements a simple (thread-safe) connection pool for Scalaris connections.

TransactionSingleOp
Single write or read operations on scalaris.

Transaction
Write or read operations on scalaris inside a transaction.

_JSONReqList
Generic request list.

_JSONReqListTransaction
Request list for use with Transaction.req_list().

_JSONReqListTransactionSingleOp
Request list for use with TransactionSingleOp.req_list() which does not support commits.

ReplicatedDHT
Non-transactional operations on the replicated DHT of scalaris

RoutingTable
API for using routing tables

ScalarisVM
Provides methods to interact with a specific Scalaris (Erlang) VM.

Autoscale
Provides methods to interact with autoscale API.

Functions

[hide private]

str_to_list(value)
Converts a string to a list of integers.

source code

Variables

[hide private]

DEFAULT_URL = 'http://localhost:8000'
default URL and port to a scalaris node

DEFAULT_PATH = '/jsonrpc.yaws'
path to the json rpc page

__package__ = None

Imports: httplib, urlparse, base64, urllib, os, threading, numbers, socket, datetime, timedelta, json

Function Details

[hide private]

str_to_list(value)

source code

Converts a string to a list of integers. If the expected value of a read operation is a list, the returned value could be (mistakenly) a string if it is a list of integers.