A C D E F G H I L M N P R S T U V W

A

async - package async

AsyncExamples - Class in async

Examples using the asynchronous DSL

AsyncExamples() - Constructor for class async.AsyncExamples

C

cache - package cache

Clients - Class in pubsub

close() - Method in class discovery.ExampleServer

close() - Method in class leader.ExampleClient

close() - Method in class pubsub.SubPubTest

ContainerType - Class in modeled

ContainerType() - Constructor for class modeled.ContainerType

ContainerType(int) - Constructor for class modeled.ContainerType

create(CuratorFramework, String, byte[]) - Static method in class async.AsyncExamples

create(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples

CreateClientExamples - Class in framework

CreateClientExamples() - Constructor for class framework.CreateClientExamples

createEphemeral(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples

createEphemeralSequential(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples

createIdempotent(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples

createOrUpdate(ModeledFramework<PersonModel>, PersonModel) - Static method in class modeled.ModeledCuratorExamples

createOrUpdate(PersonModelSpec, PersonModel) - Static method in class modeled.ModeledCuratorExamplesAlt

createSimple(String) - Static method in class framework.CreateClientExamples

createThenWatch(CuratorFramework, String) - Static method in class async.AsyncExamples

createThenWatchSimple(CuratorFramework, String) - Static method in class async.AsyncExamples

createWithOptions(String, RetryPolicy, int, int) - Static method in class framework.CreateClientExamples

CrudExamples - Class in framework

CrudExamples() - Constructor for class framework.CrudExamples

CuratorCacheExample - Class in cache

Very simple example of creating a CuratorCache that listens to events and logs the changes to standard out.

CuratorCacheExample() - Constructor for class cache.CuratorCacheExample

D

delete(CuratorFramework, String) - Static method in class framework.CrudExamples

deleteIdempotent(CuratorFramework, String, int) - Static method in class framework.CrudExamples

discovery - package discovery

DiscoveryExample - Class in discovery

DiscoveryExample() - Constructor for class discovery.DiscoveryExample

doWork(long, TimeUnit) - Method in class locking.ExampleClientThatLocks

E

equals(Object) - Method in class modeled.ContainerType

equals(Object) - Method in class modeled.PersonId

equals(Object) - Method in class modeled.PersonModel

ExampleClient - Class in leader

An example leader selector client.

ExampleClient(CuratorFramework, String, String) - Constructor for class leader.ExampleClient

ExampleClientThatLocks - Class in locking

ExampleClientThatLocks(CuratorFramework, String, FakeLimitedResource, String) - Constructor for class locking.ExampleClientThatLocks

ExampleServer - Class in discovery

This shows a very simplified method of registering an instance with the service discovery.

ExampleServer(CuratorFramework, String, String, String) - Constructor for class discovery.ExampleServer

F

FakeLimitedResource - Class in locking

Simulates some external resource that can only be access by one process at a time

FakeLimitedResource() - Constructor for class locking.FakeLimitedResource

framework - package framework

G

getAge() - Method in class modeled.PersonModel

getContainerType() - Method in class modeled.PersonModel

getDescription() - Method in class discovery.InstanceDetails

getFirstName() - Method in class modeled.PersonModel

getGroupName() - Method in class pubsub.models.Group

getHostname() - Method in class pubsub.models.Instance

getId() - Method in class modeled.PersonId

getId() - Method in class modeled.PersonModel

getId() - Method in class pubsub.models.Instance

getId() - Method in class pubsub.models.Message

getLastName() - Method in class modeled.PersonModel

getName() - Method in class pubsub.messages.UserCreated

getPort() - Method in class pubsub.models.Instance

getPosition() - Method in class pubsub.messages.UserCreated

getPriority() - Method in class pubsub.models.Message

getThisInstance() - Method in class discovery.ExampleServer

getType() - Method in class pubsub.models.Instance

getTypeId() - Method in class modeled.ContainerType

Group - Class in pubsub.models

Group() - Constructor for class pubsub.models.Group

Group(String) - Constructor for class pubsub.models.Group

guaranteedDelete(CuratorFramework, String) - Static method in class framework.CrudExamples

H

hashCode() - Method in class modeled.ContainerType

hashCode() - Method in class modeled.PersonId

hashCode() - Method in class modeled.PersonModel

I

Instance - Class in pubsub.models

Instance() - Constructor for class pubsub.models.Instance

Instance(String, InstanceType, String, int) - Constructor for class pubsub.models.Instance

instanceClient - Static variable in class pubsub.Clients

A client template for Instance instances

InstanceDetails - Class in discovery

In a real application, the Service payload will most likely be more detailed than this.

InstanceDetails() - Constructor for class discovery.InstanceDetails

InstanceDetails(String) - Constructor for class discovery.InstanceDetails

InstanceType - Enum in pubsub.models

L

leader - package leader

LeaderSelectorExample - Class in leader

LeaderSelectorExample() - Constructor for class leader.LeaderSelectorExample

LocationAvailable - Class in pubsub.messages

LocationAvailable() - Constructor for class pubsub.messages.LocationAvailable

LocationAvailable(Priority, String, Duration) - Constructor for class pubsub.messages.LocationAvailable

LocationAvailable(String, Priority, String, Duration) - Constructor for class pubsub.messages.LocationAvailable

locationAvailableClient - Static variable in class pubsub.Clients

A client template for LocationAvailable instances

locking - package locking

LockingExample - Class in locking

LockingExample() - Constructor for class locking.LockingExample

M

main(String[]) - Static method in class cache.CuratorCacheExample

main(String[]) - Static method in class cache.PathCacheExample

main(String[]) - Static method in class cache.TreeCacheExample

main(String[]) - Static method in class discovery.DiscoveryExample

main(String[]) - Static method in class leader.LeaderSelectorExample

main(String[]) - Static method in class locking.LockingExample

main(String[]) - Static method in class pubsub.SubPubTest

Message - Class in pubsub.models

Message() - Constructor for class pubsub.models.Message

Message(Priority) - Constructor for class pubsub.models.Message

Message(String, Priority) - Constructor for class pubsub.models.Message

modeled - package modeled

ModeledCuratorExamples - Class in modeled

ModeledCuratorExamples() - Constructor for class modeled.ModeledCuratorExamples

ModeledCuratorExamplesAlt - Class in modeled

ModeledCuratorExamplesAlt() - Constructor for class modeled.ModeledCuratorExamplesAlt

N

nodeName() - Method in class pubsub.models.Group

nodeName() - Method in class pubsub.models.Instance

nodeName() - Method in class pubsub.models.Message

P

PathCacheExample - Class in cache

An example of the PathChildrenCache.

PathCacheExample() - Constructor for class cache.PathCacheExample

PersonId - Class in modeled

PersonId() - Constructor for class modeled.PersonId

PersonId(String) - Constructor for class modeled.PersonId

PersonModel - Class in modeled

PersonModel() - Constructor for class modeled.PersonModel

PersonModel(PersonId, ContainerType, String, String, int) - Constructor for class modeled.PersonModel

PersonModelSpec - Class in modeled

PersonModelSpec(AsyncCuratorFramework) - Constructor for class modeled.PersonModelSpec

Priority - Enum in pubsub.models

Publisher - Class in pubsub

Publisher(AsyncCuratorFramework) - Constructor for class pubsub.Publisher

publishInstance(Instance) - Method in class pubsub.Publisher

Publish the given instance using the Instance client template

publishInstances(List<Instance>) - Method in class pubsub.Publisher

Publish the given instances using the Instance client template in a transaction

publishLocationAvailable(Group, LocationAvailable) - Method in class pubsub.Publisher

Publish the given LocationAvailable using the LocationAvailable client template

publishLocationsAvailable(Group, List<LocationAvailable>) - Method in class pubsub.Publisher

Publish the given LocationAvailables using the LocationAvailable client template in a transaction

publishUserCreated(Group, UserCreated) - Method in class pubsub.Publisher

Publish the given UserCreated using the UserCreated client template

publishUsersCreated(Group, List<UserCreated>) - Method in class pubsub.Publisher

Publish the given UserCreateds using the UserCreated client template in a transaction

pubsub - package pubsub

pubsub.messages - package pubsub.messages

pubsub.models - package pubsub.models

R

readPerson(ModeledFramework<PersonModel>, String, Consumer<PersonModel>) - Static method in class modeled.ModeledCuratorExamples

readPerson(PersonModelSpec, ContainerType, PersonId, Consumer<PersonModel>) - Static method in class modeled.ModeledCuratorExamplesAlt

resolved(ContainerType, PersonId) - Method in class modeled.PersonModelSpec

S

setData(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples

setDataAsync(CuratorFramework, String, byte[]) - Static method in class framework.CrudExamples

setDataAsyncWithCallback(CuratorFramework, BackgroundCallback, String, byte[]) - Static method in class framework.CrudExamples

setDataIdempotent(CuratorFramework, String, byte[], int) - Static method in class framework.CrudExamples

setDescription(String) - Method in class discovery.InstanceDetails

start() - Method in class discovery.ExampleServer

start() - Method in class leader.ExampleClient

start() - Method in class pubsub.SubPubTest

startInstanceSubscriber(InstanceType) - Method in class pubsub.Subscriber

Start a subscriber (a CachedModeledFramework instance) using the Instance client template

startLocationAvailableSubscriber(Group, Priority) - Method in class pubsub.Subscriber

Start a subscriber (a CachedModeledFramework instance) using the LocationAvailable client template

startUserCreatedSubscriber(Group, Priority) - Method in class pubsub.Subscriber

Start a subscriber (a CachedModeledFramework instance) using the UserCreated client template

SubPubTest - Class in pubsub

SubPubTest() - Constructor for class pubsub.SubPubTest

Subscriber - Class in pubsub

Subscriber(AsyncCuratorFramework) - Constructor for class pubsub.Subscriber

T

takeLeadership(CuratorFramework) - Method in class leader.ExampleClient

toString() - Method in class modeled.ContainerType

toString() - Method in class modeled.PersonId

toString() - Method in class modeled.PersonModel

toString() - Method in class pubsub.messages.LocationAvailable

toString() - Method in class pubsub.messages.UserCreated

toString() - Method in class pubsub.models.Instance

toString() - Method in class pubsub.models.Message

transaction(CuratorFramework) - Static method in class framework.TransactionExamples

TransactionExamples - Class in framework

TransactionExamples() - Constructor for class framework.TransactionExamples

TreeCacheExample - Class in cache

TreeCacheExample() - Constructor for class cache.TreeCacheExample

U

use() - Method in class locking.FakeLimitedResource

UserCreated - Class in pubsub.messages

UserCreated() - Constructor for class pubsub.messages.UserCreated

UserCreated(Priority, String, String) - Constructor for class pubsub.messages.UserCreated

UserCreated(String, Priority, String, String) - Constructor for class pubsub.messages.UserCreated

userCreatedClient - Static variable in class pubsub.Clients

A client template for UserCreated instances

V

valueOf(String) - Static method in enum pubsub.models.InstanceType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum pubsub.models.Priority

Returns the enum constant of this type with the specified name.

values() - Static method in enum pubsub.models.InstanceType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum pubsub.models.Priority

Returns an array containing the constants of this enum type, in the order they are declared.

W

watchedGetChildren(CuratorFramework, String) - Static method in class framework.CrudExamples

watchedGetChildren(CuratorFramework, String, Watcher) - Static method in class framework.CrudExamples

wrap(CuratorFramework) - Static method in class async.AsyncExamples

wrap(AsyncCuratorFramework) - Static method in class modeled.ModeledCuratorExamples

A C D E F G H I L M N P R S T U V W