org.togglz.cassandra

Class CassandraStateRepository

java.lang.Object

org.togglz.cassandra.CassandraStateRepository

All Implemented Interfaces:

StateRepository

public class CassandraStateRepository
extends Object
implements StateRepository

This repository implementation can be used to store the feature state in Cassandra using Astyanax client.

CassandraStateRepository stores the feature state in a column family called Togglz by default. You can choose the name of this column family using a builder provided by this class. If the repository doesn't find the column family, it will automatically create it.

The column family has the following format:

 create column family Togglz
    with comparator = 'UTF8Type'
    and default_validation_class = UTF8Type
    and key_validation_class = UTF8Type;
 

The class provides a builder which can be used to configure the repository:

 StateRepository repository = CassandraStateRepository.newBuilder(keyspace)
     .columnFamily("Togglz")
     .autoCreateColumnFamily(false)
     .mapSerializer(DefaultMapSerializer.singleline())
     .build();
 

You need to provide a Keyspace to use CassandraStateRepository. It can be created using KeyspaceBuilder or any other way.

Author:

artur@callfire.com

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	CassandraStateRepository.Builder Builder for a CassandraStateRepository

Constructor Summary

Constructors

Constructor and Description
CassandraStateRepository(com.netflix.astyanax.Keyspace keyspace)

Method Summary

Modifier and Type	Method and Description
FeatureState	getFeatureState(Feature feature) Get the persisted state of a feature from the repository.
static CassandraStateRepository.Builder	newBuilder(com.netflix.astyanax.Keyspace keyspace) Creates a new builder for creating a CassandraStateRepository.
void	setFeatureState(FeatureState featureState) Persist the supplied feature state.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CassandraStateRepository

public CassandraStateRepository(com.netflix.astyanax.Keyspace keyspace)

Method Detail

getFeatureState

public FeatureState getFeatureState(Feature feature)

Description copied from interface: StateRepository

Get the persisted state of a feature from the repository. If the repository doesn't contain any information regarding this feature it must return null.

Specified by:

getFeatureState in interface StateRepository

Parameters:

feature - The feature to read the state for

Returns:

The persisted feature state or null

setFeatureState

public void setFeatureState(FeatureState featureState)

Description copied from interface: StateRepository

Persist the supplied feature state. The repository implementation must ensure that subsequent calls to StateRepository.getFeatureState(Feature) return the same state as persisted using this method.

Specified by:

setFeatureState in interface StateRepository

Parameters:

featureState - The feature state to persist

newBuilder

public static CassandraStateRepository.Builder newBuilder(com.netflix.astyanax.Keyspace keyspace)

Creates a new builder for creating a CassandraStateRepository.

Parameters:

keyspace - the Keyspace Togglz should use to query cassandra. Can be created using the KeyspaceBuilder.