public class DbEnv
extends java.lang.Object
| Modifier and Type | Class and Description |
|---|---|
static class |
DbEnv.RepProcessMessage |
| Modifier and Type | Field and Description |
|---|---|
protected boolean |
swigCMemOwn |
Environment |
wrapper |
| Modifier | Constructor and Description |
|---|---|
|
DbEnv(int flags) |
protected |
DbEnv(long cPtr,
boolean cMemoryOwn) |
| Modifier and Type | Method and Description |
|---|---|
void |
backup(java.lang.String target,
int flags) |
DbTxn |
cdsgroup_begin() |
void |
close(int flags) |
void |
dbbackup(java.lang.String dbfile,
java.lang.String target,
int flags) |
void |
dbremove(DbTxn txnid,
java.lang.String file,
java.lang.String database,
int flags) |
void |
dbrename(DbTxn txnid,
java.lang.String file,
java.lang.String database,
java.lang.String newname,
int flags) |
void |
err(int ret,
java.lang.String message) |
void |
errx(java.lang.String message) |
void |
fileid_reset(java.lang.String file,
int flags) |
LogRecordHandler |
get_app_dispatch() |
int |
get_backup_config(int config_type) |
BackupHandler |
get_backup_handler() |
long |
get_cache_max() |
int |
get_cachesize_ncache() |
long |
get_cachesize() |
java.lang.String |
get_create_dir() |
java.lang.String[] |
get_data_dirs() |
int |
get_encrypt_flags() |
ErrorHandler |
get_errcall() |
java.io.OutputStream |
get_error_stream() |
java.lang.String |
get_errpfx() |
EventHandler |
get_event_notify() |
FeedbackHandler |
get_feedback() |
int |
get_flags() |
java.lang.String |
get_home() |
java.lang.String |
get_intermediate_dir_mode() |
int |
get_lg_bsize() |
java.lang.String |
get_lg_dir() |
int |
get_lg_filemode() |
int |
get_lg_max() |
int |
get_lg_regionmax() |
byte[][] |
get_lk_conflicts() |
int |
get_lk_detect() |
int |
get_lk_max_lockers() |
int |
get_lk_max_locks() |
int |
get_lk_max_objects() |
int |
get_lk_partitions() |
int |
get_lk_priority(int lockerid) |
int |
get_lk_tablesize() |
int |
get_memory_init(int config_type) |
long |
get_memory_max() |
java.io.OutputStream |
get_message_stream() |
java.lang.String |
get_metadata_dir() |
int |
get_mp_max_openfd() |
long |
get_mp_max_write_sleep() |
int |
get_mp_max_write() |
long |
get_mp_mmapsize() |
int |
get_mp_pagesize() |
int |
get_mp_tablesize() |
MessageHandler |
get_msgcall() |
int |
get_open_flags() |
PanicHandler |
get_paniccall() |
long |
get_shm_key() |
long |
get_timeout(int flag) |
java.lang.String |
get_tmp_dir() |
int |
get_tx_max() |
long |
get_tx_timestamp() |
boolean |
get_verbose(int which) |
static int |
get_version_family() |
static java.lang.String |
get_version_full_string() |
static int |
get_version_major() |
static int |
get_version_minor() |
static int |
get_version_patch() |
static int |
get_version_release() |
static java.lang.String |
get_version_string() |
protected static long |
getCPtr(DbEnv obj) |
boolean |
is_bigendian() |
int |
lock_detect(int flags,
int atype) |
DbLock |
lock_get(int locker,
int flags,
DatabaseEntry object,
int lock_mode) |
void |
lock_id_free(int id) |
int |
lock_id() |
void |
lock_put(DbLock lock) |
LockStats |
lock_stat(int flags) |
void |
lock_vec(int locker,
int flags,
LockRequest[] list,
int offset,
int count) |
java.lang.String[] |
log_archive(int flags) |
static int |
log_compare(LogSequenceNumber lsn0,
LogSequenceNumber lsn1) |
DbLogc |
log_cursor(int flags) |
java.lang.String |
log_file(LogSequenceNumber lsn) |
void |
log_flush(LogSequenceNumber lsn_or_null) |
boolean |
log_get_config(int which) |
void |
log_print(DbTxn txn,
java.lang.String msg) |
void |
log_put(LogSequenceNumber lsn,
DatabaseEntry data,
int flags) |
void |
log_set_config(int which,
boolean onoff) |
LogStats |
log_stat(int flags) |
int |
log_verify(java.lang.String envhome,
int cachesz,
java.lang.String dbfile,
java.lang.String dbname,
long stime,
long etime,
int stfile,
int stoffset,
int efile,
int eoffset,
int caf,
int verbose) |
void |
lsn_reset(java.lang.String file,
int flags) |
CacheFileStats[] |
memp_fstat(int flags) |
CacheStats |
memp_stat(int flags) |
void |
memp_sync(LogSequenceNumber lsn_or_null) |
int |
memp_trickle(int percent) |
int |
mutex_get_align() |
int |
mutex_get_increment() |
int |
mutex_get_init() |
int |
mutex_get_max() |
int |
mutex_get_tas_spins() |
void |
mutex_set_align(int align) |
void |
mutex_set_increment(int increment) |
void |
mutex_set_init(int mutex_init) |
void |
mutex_set_max(int mutex_max) |
void |
mutex_set_tas_spins(int tas_spins) |
MutexStats |
mutex_stat(int flags) |
void |
open(java.lang.String db_home,
int flags,
int mode) |
void |
remove(java.lang.String db_home,
int flags) |
void |
rep_elect(int nsites,
int nvotes,
int flags) |
void |
rep_flush() |
int |
rep_get_clockskew_fast() |
int |
rep_get_clockskew_slow() |
boolean |
rep_get_config(int which) |
long |
rep_get_limit() |
int |
rep_get_nsites() |
int |
rep_get_priority() |
int |
rep_get_request_max() |
int |
rep_get_request_min() |
int |
rep_get_timeout(int which) |
int |
rep_process_message(DatabaseEntry control,
DatabaseEntry rec,
int envid,
LogSequenceNumber ret_lsn) |
void |
rep_set_clockskew(int fast_clock,
int slow_clock) |
void |
rep_set_config(int which,
boolean onoff) |
void |
rep_set_limit(long bytes) |
void |
rep_set_nsites(int number) |
void |
rep_set_priority(int priority) |
void |
rep_set_request(int min,
int max) |
void |
rep_set_timeout(int which,
long timeout) |
void |
rep_set_transport(int envid,
ReplicationTransport send) |
void |
rep_start(DatabaseEntry cdata,
int flags) |
ReplicationStats |
rep_stat(int flags) |
void |
rep_sync(int flags) |
DbChannel |
repmgr_channel(int eid,
int flags) |
int |
repmgr_get_ack_policy() |
DbSite |
repmgr_local_site() |
void |
repmgr_set_ack_policy(int policy) |
void |
repmgr_set_dispatch(ReplicationManagerMessageDispatch dispatch,
int flags) |
DbSite |
repmgr_site_by_eid(int eid) |
ReplicationManagerSiteInfo[] |
repmgr_site_list() |
DbSite |
repmgr_site(java.lang.String host,
long port) |
void |
repmgr_start(int nthreads,
int flags) |
ReplicationManagerStats |
repmgr_stat(int flags) |
void |
set_app_dispatch(LogRecordHandler tx_recover) |
void |
set_backup_callbacks(BackupHandler backup_open_fcn,
BackupHandler backup_write_fcn,
BackupHandler backup_close_fcn) |
void |
set_backup_config(int config_type,
int value) |
void |
set_cache_max(long bytes) |
void |
set_cachesize(long bytes,
int ncache) |
void |
set_create_dir(java.lang.String dir) |
void |
set_data_dir(java.lang.String dir) |
void |
set_encrypt(java.lang.String passwd,
int flags) |
void |
set_errcall(ErrorHandler db_errcall_fcn) |
void |
set_error_stream(java.io.OutputStream stream) |
void |
set_errpfx(java.lang.String errpfx) |
void |
set_event_notify(EventHandler event_notify) |
void |
set_feedback(FeedbackHandler env_feedback_fcn) |
void |
set_flags(int flags,
boolean onoff) |
void |
set_intermediate_dir_mode(java.lang.String mode) |
void |
set_lg_bsize(int lg_bsize) |
void |
set_lg_dir(java.lang.String dir) |
void |
set_lg_filemode(int mode) |
void |
set_lg_max(int lg_max) |
void |
set_lg_regionmax(int lg_regionmax) |
void |
set_lk_conflicts(byte[][] conflicts) |
void |
set_lk_detect(int detect) |
void |
set_lk_max_lockers(int max) |
void |
set_lk_max_locks(int max) |
void |
set_lk_max_objects(int max) |
void |
set_lk_partitions(int partitions) |
void |
set_lk_priority(int lockerid,
int priority) |
void |
set_lk_tablesize(int size) |
void |
set_memory_init(int config_type,
int value) |
void |
set_memory_max(long bytes) |
void |
set_message_stream(java.io.OutputStream stream) |
void |
set_metadata_dir(java.lang.String dir) |
void |
set_mp_max_openfd(int maxopenfd) |
void |
set_mp_max_write(int maxwrite,
long maxwrite_sleep) |
void |
set_mp_mmapsize(long mp_mmapsize) |
void |
set_mp_pagesize(int mp_pagesize) |
void |
set_mp_tablesize(int mp_tablesize) |
void |
set_msgcall(MessageHandler db_msgcall_fcn) |
void |
set_paniccall(PanicHandler db_panic_fcn) |
void |
set_shm_key(long shm_key) |
void |
set_timeout(long timeout,
int flags) |
void |
set_tmp_dir(java.lang.String dir) |
void |
set_tx_max(int max) |
void |
set_tx_timestamp(java.util.Date timestamp) |
void |
set_verbose(int which,
boolean onoff) |
static java.lang.String |
strerror(int ret) |
int |
txn_applied(byte[] token,
int maxwait,
int flags) |
DbTxn |
txn_begin(DbTxn parent,
int flags) |
void |
txn_checkpoint(int kbyte,
int min,
int flags) |
PreparedTransaction[] |
txn_recover(long count,
long flags) |
TransactionStats |
txn_stat(int flags) |
protected boolean swigCMemOwn
public Environment wrapper
protected DbEnv(long cPtr,
boolean cMemoryOwn)
public DbEnv(int flags)
throws DatabaseException
DatabaseExceptionprotected static long getCPtr(DbEnv obj)
public void close(int flags)
throws DatabaseException
DatabaseExceptionpublic LogRecordHandler get_app_dispatch() throws DatabaseException
DatabaseExceptionpublic EventHandler get_event_notify() throws DatabaseException
DatabaseExceptionpublic FeedbackHandler get_feedback() throws DatabaseException
DatabaseExceptionpublic void set_errpfx(java.lang.String errpfx)
public java.lang.String get_errpfx()
public ErrorHandler get_errcall()
public MessageHandler get_msgcall()
public PanicHandler get_paniccall() throws DatabaseException
DatabaseExceptionpublic void lock_vec(int locker,
int flags,
LockRequest[] list,
int offset,
int count)
throws DatabaseException
DatabaseExceptionpublic void remove(java.lang.String db_home,
int flags)
throws DatabaseException,
java.io.FileNotFoundException
DatabaseExceptionjava.io.FileNotFoundExceptionpublic void set_error_stream(java.io.OutputStream stream)
public java.io.OutputStream get_error_stream()
public void set_message_stream(java.io.OutputStream stream)
public java.io.OutputStream get_message_stream()
public void set_tx_timestamp(java.util.Date timestamp)
throws DatabaseException
DatabaseExceptionpublic BackupHandler get_backup_handler() throws DatabaseException
DatabaseExceptionpublic void dbremove(DbTxn txnid, java.lang.String file, java.lang.String database, int flags) throws DatabaseException, java.io.FileNotFoundException
DatabaseExceptionjava.io.FileNotFoundExceptionpublic void dbrename(DbTxn txnid, java.lang.String file, java.lang.String database, java.lang.String newname, int flags) throws DatabaseException, java.io.FileNotFoundException
DatabaseExceptionjava.io.FileNotFoundExceptionpublic void err(int ret,
java.lang.String message)
public void errx(java.lang.String message)
public DbTxn cdsgroup_begin() throws DatabaseException
DatabaseExceptionpublic void fileid_reset(java.lang.String file,
int flags)
throws DatabaseException
DatabaseExceptionpublic java.lang.String[] get_data_dirs()
throws DatabaseException
DatabaseExceptionpublic int get_encrypt_flags()
throws DatabaseException
DatabaseExceptionpublic int get_flags()
throws DatabaseException
DatabaseExceptionpublic java.lang.String get_home()
throws DatabaseException
DatabaseExceptionpublic java.lang.String get_intermediate_dir_mode()
throws DatabaseException
DatabaseExceptionpublic int get_open_flags()
throws DatabaseException
DatabaseExceptionpublic java.lang.String get_metadata_dir()
throws DatabaseException
DatabaseExceptionpublic long get_shm_key()
throws DatabaseException
DatabaseExceptionpublic java.lang.String get_tmp_dir()
throws DatabaseException
DatabaseExceptionpublic boolean get_verbose(int which)
throws DatabaseException
DatabaseExceptionpublic boolean is_bigendian()
throws DatabaseException
DatabaseExceptionpublic void lsn_reset(java.lang.String file,
int flags)
throws DatabaseException
DatabaseExceptionpublic void open(java.lang.String db_home,
int flags,
int mode)
throws DatabaseException,
java.io.FileNotFoundException
DatabaseExceptionjava.io.FileNotFoundExceptionpublic void set_cachesize(long bytes,
int ncache)
throws DatabaseException
DatabaseExceptionpublic void set_cache_max(long bytes)
throws DatabaseException
DatabaseExceptionpublic void set_create_dir(java.lang.String dir)
throws DatabaseException
DatabaseExceptionpublic void set_data_dir(java.lang.String dir)
throws DatabaseException
DatabaseExceptionpublic void set_intermediate_dir_mode(java.lang.String mode)
throws DatabaseException
DatabaseExceptionpublic void set_encrypt(java.lang.String passwd,
int flags)
throws DatabaseException
DatabaseExceptionpublic void set_errcall(ErrorHandler db_errcall_fcn)
public void set_flags(int flags,
boolean onoff)
throws DatabaseException
DatabaseExceptionpublic void set_feedback(FeedbackHandler env_feedback_fcn) throws DatabaseException
DatabaseExceptionpublic void set_metadata_dir(java.lang.String dir)
throws DatabaseException
DatabaseExceptionpublic void set_mp_max_openfd(int maxopenfd)
throws DatabaseException
DatabaseExceptionpublic void set_mp_max_write(int maxwrite,
long maxwrite_sleep)
throws DatabaseException
DatabaseExceptionpublic void set_mp_mmapsize(long mp_mmapsize)
throws DatabaseException
DatabaseExceptionpublic void set_mp_pagesize(int mp_pagesize)
throws DatabaseException
DatabaseExceptionpublic void set_mp_tablesize(int mp_tablesize)
throws DatabaseException
DatabaseExceptionpublic void set_msgcall(MessageHandler db_msgcall_fcn)
public void set_paniccall(PanicHandler db_panic_fcn) throws DatabaseException
DatabaseExceptionpublic void set_shm_key(long shm_key)
throws DatabaseException
DatabaseExceptionpublic void set_timeout(long timeout,
int flags)
throws DatabaseException
DatabaseExceptionpublic void set_tmp_dir(java.lang.String dir)
throws DatabaseException
DatabaseExceptionpublic void set_tx_max(int max)
throws DatabaseException
DatabaseExceptionpublic void set_app_dispatch(LogRecordHandler tx_recover) throws DatabaseException
DatabaseExceptionpublic void set_event_notify(EventHandler event_notify) throws DatabaseException
DatabaseExceptionpublic void set_verbose(int which,
boolean onoff)
throws DatabaseException
DatabaseExceptionpublic byte[][] get_lk_conflicts()
throws DatabaseException
DatabaseExceptionpublic int get_lk_detect()
throws DatabaseException
DatabaseExceptionpublic int get_lk_max_locks()
throws DatabaseException
DatabaseExceptionpublic int get_lk_max_lockers()
throws DatabaseException
DatabaseExceptionpublic int get_lk_max_objects()
throws DatabaseException
DatabaseExceptionpublic int get_lk_partitions()
throws DatabaseException
DatabaseExceptionpublic int get_lk_priority(int lockerid)
throws DatabaseException
DatabaseExceptionpublic int get_lk_tablesize()
throws DatabaseException
DatabaseExceptionpublic int get_memory_init(int config_type)
throws DatabaseException
DatabaseExceptionpublic long get_memory_max()
throws DatabaseException
DatabaseExceptionpublic int lock_detect(int flags,
int atype)
throws DatabaseException
DatabaseExceptionpublic DbLock lock_get(int locker, int flags, DatabaseEntry object, int lock_mode) throws DatabaseException
DatabaseExceptionpublic int lock_id()
throws DatabaseException
DatabaseExceptionpublic void lock_id_free(int id)
throws DatabaseException
DatabaseExceptionpublic void lock_put(DbLock lock) throws DatabaseException
DatabaseExceptionpublic LockStats lock_stat(int flags) throws DatabaseException
DatabaseExceptionpublic void set_lk_conflicts(byte[][] conflicts)
throws DatabaseException
DatabaseExceptionpublic void set_lk_detect(int detect)
throws DatabaseException
DatabaseExceptionpublic void set_lk_max_lockers(int max)
throws DatabaseException
DatabaseExceptionpublic void set_lk_max_locks(int max)
throws DatabaseException
DatabaseExceptionpublic void set_lk_max_objects(int max)
throws DatabaseException
DatabaseExceptionpublic void set_lk_partitions(int partitions)
throws DatabaseException
DatabaseExceptionpublic void set_lk_priority(int lockerid,
int priority)
throws DatabaseException
DatabaseExceptionpublic void set_lk_tablesize(int size)
throws DatabaseException
DatabaseExceptionpublic void set_memory_init(int config_type,
int value)
throws DatabaseException
DatabaseExceptionpublic void set_memory_max(long bytes)
throws DatabaseException
DatabaseExceptionpublic int get_lg_bsize()
throws DatabaseException
DatabaseExceptionpublic java.lang.String get_lg_dir()
throws DatabaseException
DatabaseExceptionpublic int get_lg_filemode()
throws DatabaseException
DatabaseExceptionpublic int get_lg_max()
throws DatabaseException
DatabaseExceptionpublic int get_lg_regionmax()
throws DatabaseException
DatabaseExceptionpublic java.lang.String[] log_archive(int flags)
throws DatabaseException
DatabaseExceptionpublic static int log_compare(LogSequenceNumber lsn0, LogSequenceNumber lsn1)
public DbLogc log_cursor(int flags) throws DatabaseException
DatabaseExceptionpublic java.lang.String log_file(LogSequenceNumber lsn) throws DatabaseException
DatabaseExceptionpublic void log_flush(LogSequenceNumber lsn_or_null) throws DatabaseException
DatabaseExceptionpublic boolean log_get_config(int which)
throws DatabaseException
DatabaseExceptionpublic void log_put(LogSequenceNumber lsn, DatabaseEntry data, int flags) throws DatabaseException
DatabaseExceptionpublic void log_print(DbTxn txn, java.lang.String msg) throws DatabaseException
DatabaseExceptionpublic void log_set_config(int which,
boolean onoff)
throws DatabaseException
DatabaseExceptionpublic LogStats log_stat(int flags) throws DatabaseException
DatabaseExceptionpublic int log_verify(java.lang.String envhome,
int cachesz,
java.lang.String dbfile,
java.lang.String dbname,
long stime,
long etime,
int stfile,
int stoffset,
int efile,
int eoffset,
int caf,
int verbose)
throws DatabaseException
DatabaseExceptionpublic void set_lg_bsize(int lg_bsize)
throws DatabaseException
DatabaseExceptionpublic void set_lg_dir(java.lang.String dir)
throws DatabaseException
DatabaseExceptionpublic void set_lg_filemode(int mode)
throws DatabaseException
DatabaseExceptionpublic void set_lg_max(int lg_max)
throws DatabaseException
DatabaseExceptionpublic void set_lg_regionmax(int lg_regionmax)
throws DatabaseException
DatabaseExceptionpublic long get_cachesize()
throws DatabaseException
DatabaseExceptionpublic int get_cachesize_ncache()
throws DatabaseException
DatabaseExceptionpublic long get_cache_max()
throws DatabaseException
DatabaseExceptionpublic java.lang.String get_create_dir()
throws DatabaseException
DatabaseExceptionpublic int get_mp_max_openfd()
throws DatabaseException
DatabaseExceptionpublic int get_mp_max_write()
throws DatabaseException
DatabaseExceptionpublic long get_mp_max_write_sleep()
throws DatabaseException
DatabaseExceptionpublic long get_mp_mmapsize()
throws DatabaseException
DatabaseExceptionpublic int get_mp_pagesize()
throws DatabaseException
DatabaseExceptionpublic int get_mp_tablesize()
throws DatabaseException
DatabaseExceptionpublic CacheStats memp_stat(int flags) throws DatabaseException
DatabaseExceptionpublic CacheFileStats[] memp_fstat(int flags) throws DatabaseException
DatabaseExceptionpublic void memp_sync(LogSequenceNumber lsn_or_null) throws DatabaseException
DatabaseExceptionpublic int memp_trickle(int percent)
throws DatabaseException
DatabaseExceptionpublic int mutex_get_align()
throws DatabaseException
DatabaseExceptionpublic int mutex_get_increment()
throws DatabaseException
DatabaseExceptionpublic int mutex_get_init()
throws DatabaseException
DatabaseExceptionpublic int mutex_get_max()
throws DatabaseException
DatabaseExceptionpublic int mutex_get_tas_spins()
throws DatabaseException
DatabaseExceptionpublic void mutex_set_align(int align)
throws DatabaseException
DatabaseExceptionpublic void mutex_set_increment(int increment)
throws DatabaseException
DatabaseExceptionpublic void mutex_set_init(int mutex_init)
throws DatabaseException
DatabaseExceptionpublic void mutex_set_max(int mutex_max)
throws DatabaseException
DatabaseExceptionpublic void mutex_set_tas_spins(int tas_spins)
throws DatabaseException
DatabaseExceptionpublic MutexStats mutex_stat(int flags) throws DatabaseException
DatabaseExceptionpublic int get_tx_max()
throws DatabaseException
DatabaseExceptionpublic long get_tx_timestamp()
throws DatabaseException
DatabaseExceptionpublic long get_timeout(int flag)
throws DatabaseException
DatabaseExceptionpublic int txn_applied(byte[] token,
int maxwait,
int flags)
throws DatabaseException
DatabaseExceptionpublic DbTxn txn_begin(DbTxn parent, int flags) throws DatabaseException
DatabaseExceptionpublic void txn_checkpoint(int kbyte,
int min,
int flags)
throws DatabaseException
DatabaseExceptionpublic PreparedTransaction[] txn_recover(long count, long flags) throws DatabaseException
DatabaseExceptionpublic TransactionStats txn_stat(int flags) throws DatabaseException
DatabaseExceptionpublic long rep_get_limit()
throws DatabaseException
DatabaseExceptionpublic void rep_elect(int nsites,
int nvotes,
int flags)
throws DatabaseException
DatabaseExceptionpublic int rep_process_message(DatabaseEntry control, DatabaseEntry rec, int envid, LogSequenceNumber ret_lsn)
public void rep_flush()
throws DatabaseException
DatabaseExceptionpublic void rep_set_config(int which,
boolean onoff)
throws DatabaseException
DatabaseExceptionpublic void rep_set_clockskew(int fast_clock,
int slow_clock)
throws DatabaseException
DatabaseExceptionpublic int rep_get_clockskew_fast()
throws DatabaseException
DatabaseExceptionpublic int rep_get_clockskew_slow()
throws DatabaseException
DatabaseExceptionpublic void rep_start(DatabaseEntry cdata, int flags) throws DatabaseException
DatabaseExceptionpublic void rep_sync(int flags)
throws DatabaseException
DatabaseExceptionpublic boolean rep_get_config(int which)
throws DatabaseException
DatabaseExceptionpublic ReplicationStats rep_stat(int flags) throws DatabaseException
DatabaseExceptionpublic void rep_set_limit(long bytes)
throws DatabaseException
DatabaseExceptionpublic int rep_get_request_min()
throws DatabaseException
DatabaseExceptionpublic int rep_get_request_max()
throws DatabaseException
DatabaseExceptionpublic DbChannel repmgr_channel(int eid, int flags) throws DatabaseException
DatabaseExceptionpublic void rep_set_request(int min,
int max)
throws DatabaseException
DatabaseExceptionpublic void rep_set_transport(int envid,
ReplicationTransport send)
throws DatabaseException
DatabaseExceptionpublic int rep_get_nsites()
throws DatabaseException
DatabaseExceptionpublic int rep_get_priority()
throws DatabaseException
DatabaseExceptionpublic int rep_get_timeout(int which)
throws DatabaseException
DatabaseExceptionpublic void rep_set_nsites(int number)
throws DatabaseException
DatabaseExceptionpublic void rep_set_priority(int priority)
throws DatabaseException
DatabaseExceptionpublic void rep_set_timeout(int which,
long timeout)
throws DatabaseException
DatabaseExceptionpublic int repmgr_get_ack_policy()
throws DatabaseException
DatabaseExceptionpublic DbSite repmgr_local_site() throws DatabaseException
DatabaseExceptionpublic void repmgr_set_ack_policy(int policy)
throws DatabaseException
DatabaseExceptionpublic DbSite repmgr_site(java.lang.String host, long port) throws DatabaseException
DatabaseExceptionpublic DbSite repmgr_site_by_eid(int eid) throws DatabaseException
DatabaseExceptionpublic void repmgr_set_dispatch(ReplicationManagerMessageDispatch dispatch, int flags) throws DatabaseException
DatabaseExceptionpublic ReplicationManagerSiteInfo[] repmgr_site_list() throws DatabaseException
DatabaseExceptionpublic void repmgr_start(int nthreads,
int flags)
throws DatabaseException
DatabaseExceptionpublic ReplicationManagerStats repmgr_stat(int flags) throws DatabaseException
DatabaseExceptionpublic int get_backup_config(int config_type)
throws DatabaseException
DatabaseExceptionpublic void backup(java.lang.String target,
int flags)
throws DatabaseException
DatabaseExceptionpublic void dbbackup(java.lang.String dbfile,
java.lang.String target,
int flags)
throws DatabaseException
DatabaseExceptionpublic void set_backup_callbacks(BackupHandler backup_open_fcn, BackupHandler backup_write_fcn, BackupHandler backup_close_fcn) throws DatabaseException
DatabaseExceptionpublic void set_backup_config(int config_type,
int value)
throws DatabaseException
DatabaseExceptionpublic static java.lang.String strerror(int ret)
public static int get_version_family()
public static int get_version_release()
public static int get_version_major()
public static int get_version_minor()
public static int get_version_patch()
public static java.lang.String get_version_string()
public static java.lang.String get_version_full_string()