view release on metacpan or  search on metacpan

Client.xs  view on Meta::CPAN

	unsigned timeout_ms;
	
	CODE:
		cass_cluster_set_connect_timeout(cass->cluster, timeout_ms);

void
cluster_set_request_timeout(cass, timeout_ms)
	Database::Cassandra::Client cass;
	unsigned timeout_ms;
	
	CODE:
		cass_cluster_set_request_timeout(cass->cluster, timeout_ms);

void
cluster_set_credentials(cass, username, password)
	Database::Cassandra::Client cass;
	const char* username;
	const char* password;
	
	CODE:
		cass_cluster_set_credentials(cass->cluster, username, password);

void
cluster_set_load_balance_round_robin(cass)
	Database::Cassandra::Client cass;
	
	CODE:
		cass_cluster_set_load_balance_round_robin(cass->cluster);

CassError
cluster_set_load_balance_dc_aware(cass, local_dc, used_hosts_per_remote_dc, allow_remote_dcs_for_local_cl)
	Database::Cassandra::Client cass;
	const char* local_dc;
	unsigned used_hosts_per_remote_dc;
	int allow_remote_dcs_for_local_cl;
	
	CODE:
		RETVAL = cass_cluster_set_load_balance_dc_aware(cass->cluster, local_dc,
														used_hosts_per_remote_dc,
														allow_remote_dcs_for_local_cl);
	OUTPUT:
		RETVAL

void
cluster_set_token_aware_routing(cass, enabled)
	Database::Cassandra::Client cass;
	int enabled;
	
	CODE:
		cass_cluster_set_token_aware_routing(cass->cluster, enabled);

void
cluster_set_tcp_nodelay(cass, enable)
	Database::Cassandra::Client cass;
	int enable;
	
	CODE:
		cass_cluster_set_tcp_nodelay(cass->cluster, enable);

void
cluster_set_tcp_keepalive(cass, enable, delay_secs)
	Database::Cassandra::Client cass;
	int enable;
	unsigned delay_secs;
	
	CODE:
		cass_cluster_set_tcp_keepalive(cass->cluster, enable, delay_secs);

void
cluster_free(cass)
	Database::Cassandra::Client cass;
	
	CODE:
		cass_cluster_free(cass->cluster);
		cass->cluster = NULL;


#***********************************************************************************
#*
#* Session
#*
#***********************************************************************************

CassSession*
session_new(cass)
	Database::Cassandra::Client cass;
	
	CODE:
		RETVAL = cass_session_new();
	OUTPUT:
		RETVAL

void
session_free(cass, session)
	Database::Cassandra::Client cass;
	CassSession *session;
	
	CODE:
		cass_session_free(session);

CassFuture*
session_connect(cass, session)
	Database::Cassandra::Client cass;
	CassSession *session;
	
	CODE:
		RETVAL = cass_session_connect(session, cass->cluster);
	OUTPUT:
		RETVAL

CassFuture*
session_connect_keyspace(cass, session, keyspace)
	Database::Cassandra::Client cass;
	CassSession *session;
	const char* keyspace;
	
	CODE:
		RETVAL = cass_session_connect_keyspace(session, cass->cluster, keyspace);
	OUTPUT:
		RETVAL

CassFuture*
session_close(cass, session)
	Database::Cassandra::Client cass;
	CassSession *session;
	
	CODE: