Storemanager

Instance Constructors

new Storemanager(map: ConcurrentHashMap[String, Array[Byte]], index: (String, String), storemanagerType: StoremanagerType, ninjas: Array[ActorRef] = null)

map
the data to manage
index
the index of data
storemanagerType
the behaviour of the storemanager
ninjas
the ninjas of the storemanager

Type Members

class Child extends AnyRef

Class that represents a child of a storemanager.
type Receive = PartialFunction[Any, Unit]

Definition Classes
Actor

Value Members

final def !=(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def !=(arg0: Any): Boolean

Definition Classes
Any
final def ##(): Int

Definition Classes
AnyRef → Any
final def ==(arg0: AnyRef): Boolean

Definition Classes
AnyRef
final def ==(arg0: Any): Boolean

Definition Classes
Any
def aroundPostRestart(reason: Throwable): Unit

Attributes
protected[akka]
Definition Classes
Actor
def aroundPostStop(): Unit

Attributes
protected[akka]
Definition Classes
Actor
def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

Attributes
protected[akka]
Definition Classes
Actor
def aroundPreStart(): Unit

Attributes
protected[akka]
Definition Classes
Actor
def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit

Attributes
protected[akka]
Definition Classes
Actor
final def asInstanceOf[T0]: T0

Definition Classes
Any
def clone(): AnyRef

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( ... )
var clusterListener: ActorRef

Definition Classes
ClusterAwareActor
implicit val context: ActorContext

Definition Classes
Actor
def currentMethodName(): String

Return the name of the current running method.
Return the name of the current running method.
returns
The name of the method that call this.

Definition Classes
ReplyActor
implicit val ec: ExecutionContextExecutor

Definition Classes
ClusterAwareActor
final def eq(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def equals(arg0: Any): Boolean

Definition Classes
AnyRef → Any
def finalize(): Unit

Attributes
protected[java.lang]
Definition Classes
AnyRef
Annotations
@throws( classOf[java.lang.Throwable] )
final def getClass(): Class[_]

Definition Classes
AnyRef → Any
def hashCode(): Int

Definition Classes
AnyRef → Any
val index: (String, String)

the index of data
final def isInstanceOf[T0]: Boolean

Definition Classes
Any
var leftChild: Child
def log: LoggingAdapter

Definition Classes
ActorLogging
def logAndReply(reply: ReplyMessage, sender: ActorRef = sender): Unit

Logs the operation represent by the ReplyMessage message and sends the ReplyMessage to the sender.
Logs the operation represent by the ReplyMessage message and sends the ReplyMessage to the sender.
reply
The ReplyMessage message that represent the reply to a request.
sender
The sender's reference of the request.

Definition Classes
ReplyActor
See also
#writeLog(ReplyMessage)
#reply(ReplyMessage, ActorRef)
var map: ConcurrentHashMap[String, Array[Byte]]

the data to manage
final def ne(arg0: AnyRef): Boolean

Definition Classes
AnyRef
def nextAddress: Address

Returns an address of one node in the cluster.
Returns an address of one node in the cluster. This method sends a message to the ClusterListener of the same node of this actor so it will stop the thread of this actor while waiting for a response.
returns
the address of type akka.actor.Address.

Definition Classes
ClusterAwareActor
val ninjas: Array[ActorRef]

the ninjas of the storemanager
final def notify(): Unit

Definition Classes
AnyRef
final def notifyAll(): Unit

Definition Classes
AnyRef
def postRestart(reason: Throwable): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def postStop(): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def preRestart(reason: Throwable, message: Option[Any]): Unit

Definition Classes
Actor
Annotations
@throws( classOf[java.lang.Exception] )
def preStart(): Unit

Override of the actor's preStart method.
Override of the actor's preStart method. Changes the actor's behaviour based on the constructor.

Definition Classes
Storemanager → Actor
See also
#become(Actor.receive)
def receive: PartialFunction[Any, Unit]

Processes all incoming messages behaving like a Storekeeper actor.
Processes all incoming messages behaving like a Storekeeper actor. It handles only RowMessage messages

Definition Classes
Storemanager → Actor
See also
#handleRowMessageAsStorefinder(RowMessage)
def reply(reply: ReplyMessage, sender: ActorRef = sender): Unit

Send the ReplyMessage message to the sender.
Send the ReplyMessage message to the sender.
reply
The ReplyMessage message that represent the reply to a request.
sender
The sender's reference of the request.

Definition Classes
ReplyActor
val replyBuilder: ReplyBuilder

Definition Classes
ReplyActor
var rightChild: Child
implicit final val self: ActorRef

Definition Classes
Actor
final def sender(): ActorRef

Definition Classes
Actor
val storemanagerType: StoremanagerType

the behaviour of the storemanager
def supervisorStrategy: SupervisorStrategy

Definition Classes
Actor
final def synchronized[T0](arg0: ⇒ T0): T0

Definition Classes
AnyRef
implicit val timeout: Timeout

Definition Classes
ClusterAwareActor
def toString(): String

Definition Classes
AnyRef → Any
def unhandled(message: Any): Unit

Definition Classes
Actor
final def wait(): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long, arg1: Int): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
final def wait(arg0: Long): Unit

Definition Classes
AnyRef
Annotations
@throws( ... )
def writeLog(reply: ReplyMessage): Unit

Logs the operation represent by the ReplyMessage using the ReplyBuilder class.
Logs the operation represent by the ReplyMessage using the ReplyBuilder class.
reply
The ReplyMessage message that represent the reply to a request.

Definition Classes
ReplyActor
See also
ReplyBuilder

class Storemanager extends ReplyActor

Instance Constructors

new Storemanager(map: ConcurrentHashMap[String, Array[Byte]], index: (String, String), storemanagerType: StoremanagerType, ninjas: Array[ActorRef] = null)

Type Members

class Child extends AnyRef

type Receive = PartialFunction[Any, Unit]

Value Members

final def !=(arg0: AnyRef): Boolean

final def !=(arg0: Any): Boolean

final def ##(): Int

final def ==(arg0: AnyRef): Boolean

final def ==(arg0: Any): Boolean

def aroundPostRestart(reason: Throwable): Unit

def aroundPostStop(): Unit

def aroundPreRestart(reason: Throwable, message: Option[Any]): Unit

def aroundPreStart(): Unit

def aroundReceive(receive: akka.actor.Actor.Receive, msg: Any): Unit

final def asInstanceOf[T0]: T0

def clone(): AnyRef

var clusterListener: ActorRef

implicit val context: ActorContext

def currentMethodName(): String

implicit val ec: ExecutionContextExecutor

final def eq(arg0: AnyRef): Boolean

def equals(arg0: Any): Boolean

def finalize(): Unit

final def getClass(): Class[_]

def hashCode(): Int

val index: (String, String)

final def isInstanceOf[T0]: Boolean

var leftChild: Child

def log: LoggingAdapter

def logAndReply(reply: ReplyMessage, sender: ActorRef = sender): Unit

var map: ConcurrentHashMap[String, Array[Byte]]

final def ne(arg0: AnyRef): Boolean

def nextAddress: Address

val ninjas: Array[ActorRef]

final def notify(): Unit

final def notifyAll(): Unit

def postRestart(reason: Throwable): Unit

def postStop(): Unit

def preRestart(reason: Throwable, message: Option[Any]): Unit

def preStart(): Unit

def receive: PartialFunction[Any, Unit]

def reply(reply: ReplyMessage, sender: ActorRef = sender): Unit

val replyBuilder: ReplyBuilder

var rightChild: Child

implicit final val self: ActorRef

final def sender(): ActorRef

val storemanagerType: StoremanagerType

def supervisorStrategy: SupervisorStrategy

final def synchronized[T0](arg0: ⇒ T0): T0

implicit val timeout: Timeout

def toString(): String

def unhandled(message: Any): Unit

final def wait(): Unit

final def wait(arg0: Long, arg1: Int): Unit

final def wait(arg0: Long): Unit

def writeLog(reply: ReplyMessage): Unit

Inherited from ReplyActor

Inherited from ActorLogging

Inherited from ClusterAwareActor

Inherited from Actor

Inherited from AnyRef

Inherited from Any

Ungrouped