Home
last modified time | relevance | path

Searched refs:writeTxn (Results 1 – 25 of 27) sorted by relevance

12

/dports/sysutils/istio/istio-1.6.7/vendor/github.com/open-policy-agent/opa/storage/inmem/
H A Dinmem_test.go483 writeTxn := storage.NewTransactionOrDie(ctx, store, storage.WriteParams)
500 _, err = store.Register(ctx, writeTxn, storage.TriggerConfig{
519 if err := store.UpsertPolicy(ctx, writeTxn, id, data); err != nil {
523 if err := store.Commit(ctx, writeTxn); err != nil {
545 writeTxn := storage.NewTransactionOrDie(ctx, store, storage.WriteParams)
550 _, err := store.Register(ctx, writeTxn, storage.TriggerConfig{
561 handle, err := store.Register(ctx, writeTxn, storage.TriggerConfig{
572 if err := store.Commit(ctx, writeTxn); err != nil {
576 writeTxn = storage.NewTransactionOrDie(ctx, store, storage.WriteParams)
580 handle.Unregister(ctx, writeTxn)
[all …]
/dports/www/pomerium/pomerium-0.8.3/vendor/github.com/open-policy-agent/opa/storage/inmem/
H A Dinmem_test.go483 writeTxn := storage.NewTransactionOrDie(ctx, store, storage.WriteParams)
500 _, err = store.Register(ctx, writeTxn, storage.TriggerConfig{
519 if err := store.UpsertPolicy(ctx, writeTxn, id, data); err != nil {
523 if err := store.Commit(ctx, writeTxn); err != nil {
545 writeTxn := storage.NewTransactionOrDie(ctx, store, storage.WriteParams)
550 _, err := store.Register(ctx, writeTxn, storage.TriggerConfig{
561 handle, err := store.Register(ctx, writeTxn, storage.TriggerConfig{
572 if err := store.Commit(ctx, writeTxn); err != nil {
576 writeTxn = storage.NewTransactionOrDie(ctx, store, storage.WriteParams)
580 handle.Unregister(ctx, writeTxn)
[all …]
/dports/databases/db5/db-5.3.28/test/csharp/
H A DLogConfigTest.cs87 Transaction writeTxn = env.BeginTransaction(); in TestFullLogBufferException()
98 new DatabaseEntry(byteArr), writeTxn); in TestFullLogBufferException()
99 writeTxn.Commit(); in TestFullLogBufferException()
103 writeTxn.Abort(); in TestFullLogBufferException()
179 Transaction writeTxn = env.BeginTransaction(); in TestLoggingSystemStats()
183 new DatabaseEntry(byteArr), writeTxn); in TestLoggingSystemStats()
184 writeTxn.Commit(); in TestLoggingSystemStats()
/dports/databases/db18/db-18.1.40/test/csharp/
H A DLogConfigTest.cs89 Transaction writeTxn = env.BeginTransaction(); in TestFullLogBufferException()
100 new DatabaseEntry(byteArr), writeTxn); in TestFullLogBufferException()
101 writeTxn.Commit(); in TestFullLogBufferException()
105 writeTxn.Abort(); in TestFullLogBufferException()
184 Transaction writeTxn = env.BeginTransaction(); in TestLoggingSystemStats()
188 new DatabaseEntry(byteArr), writeTxn); in TestLoggingSystemStats()
189 writeTxn.Commit(); in TestLoggingSystemStats()
/dports/databases/percona56-client/percona-server-5.6.51-91.0/storage/tokudb/PerconaFT/ftcxx/
H A Ddb.hpp317 DBTxn writeTxn; in open() local
319 writeTxn = DBTxn(env, DB_SERIALIZABLE); in open()
320 txnp = &writeTxn; in open()
333 writeTxn.commit(); in open()
/dports/databases/percona-pam-for-mysql/percona-server-5.6.51-91.0/storage/tokudb/PerconaFT/ftcxx/
H A Ddb.hpp317 DBTxn writeTxn; in open() local
319 writeTxn = DBTxn(env, DB_SERIALIZABLE); in open()
320 txnp = &writeTxn; in open()
333 writeTxn.commit(); in open()
/dports/databases/percona57-server/percona-server-5.7.36-39/storage/tokudb/PerconaFT/ftcxx/
H A Ddb.hpp317 DBTxn writeTxn; in open() local
319 writeTxn = DBTxn(env, DB_SERIALIZABLE); in open()
320 txnp = &writeTxn; in open()
333 writeTxn.commit(); in open()
/dports/databases/percona57-client/percona-server-5.7.36-39/storage/tokudb/PerconaFT/ftcxx/
H A Ddb.hpp317 DBTxn writeTxn; in open() local
319 writeTxn = DBTxn(env, DB_SERIALIZABLE); in open()
320 txnp = &writeTxn; in open()
333 writeTxn.commit(); in open()
/dports/databases/percona57-pam-for-mysql/percona-server-5.7.36-39/storage/tokudb/PerconaFT/ftcxx/
H A Ddb.hpp317 DBTxn writeTxn; in open() local
319 writeTxn = DBTxn(env, DB_SERIALIZABLE); in open()
320 txnp = &writeTxn; in open()
333 writeTxn.commit(); in open()
/dports/databases/percona56-server/percona-server-5.6.51-91.0/storage/tokudb/PerconaFT/ftcxx/
H A Ddb.hpp317 DBTxn writeTxn; in open() local
319 writeTxn = DBTxn(env, DB_SERIALIZABLE); in open()
320 txnp = &writeTxn; in open()
333 writeTxn.commit(); in open()
/dports/databases/mariadb104-server/mariadb-10.4.24/storage/tokudb/PerconaFT/ftcxx/
H A Ddb.hpp317 DBTxn writeTxn; in open() local
319 writeTxn = DBTxn(env, DB_SERIALIZABLE); in open()
320 txnp = &writeTxn; in open()
333 writeTxn.commit(); in open()
/dports/databases/mariadb104-client/mariadb-10.4.24/storage/tokudb/PerconaFT/ftcxx/
H A Ddb.hpp317 DBTxn writeTxn; in open() local
319 writeTxn = DBTxn(env, DB_SERIALIZABLE); in open()
320 txnp = &writeTxn; in open()
333 writeTxn.commit(); in open()
/dports/databases/mariadb105-client/mariadb-10.5.15/storage/tokudb/PerconaFT/ftcxx/
H A Ddb.hpp317 DBTxn writeTxn; in open() local
319 writeTxn = DBTxn(env, DB_SERIALIZABLE); in open()
320 txnp = &writeTxn; in open()
333 writeTxn.commit(); in open()
/dports/databases/mariadb103-client/mariadb-10.3.34/storage/tokudb/PerconaFT/ftcxx/
H A Ddb.hpp317 DBTxn writeTxn; in open() local
319 writeTxn = DBTxn(env, DB_SERIALIZABLE); in open()
320 txnp = &writeTxn; in open()
333 writeTxn.commit(); in open()
/dports/databases/mariadb103-server/mariadb-10.3.34/storage/tokudb/PerconaFT/ftcxx/
H A Ddb.hpp317 DBTxn writeTxn; in open() local
319 writeTxn = DBTxn(env, DB_SERIALIZABLE); in open()
320 txnp = &writeTxn; in open()
333 writeTxn.commit(); in open()
/dports/databases/mariadb105-server/mariadb-10.5.15/storage/tokudb/PerconaFT/ftcxx/
H A Ddb.hpp317 DBTxn writeTxn; in open() local
319 writeTxn = DBTxn(env, DB_SERIALIZABLE); in open()
320 txnp = &writeTxn; in open()
333 writeTxn.commit(); in open()
/dports/security/vault/vault-1.8.2/vendor/go.etcd.io/etcd/functional/tester/
H A Dstresser_key.go274 return writeTxn(cli, keys, txnOps)
277 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { func
/dports/security/certmgr/certmgr-3.0.3/vendor/github.com/google/certificate-transparency-go/certificate-transparency-go-1.0.21/vendor/github.com/coreos/etcd/functional/tester/
H A Dstresser_key.go257 return writeTxn(cli, keys, txnOps)
260 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { func
/dports/sysutils/istio/istio-1.6.7/vendor/github.com/coreos/etcd/functional/tester/
H A Dstresser_key.go256 return writeTxn(cli, keys, txnOps)
259 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { func
/dports/net-im/nextcloud-spreed-signaling/nextcloud-spreed-signaling-0.2.0/vendor/src/go.etcd.io/etcd/functional/tester/
H A Dstresser_key.go274 return writeTxn(cli, keys, txnOps)
277 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { func
/dports/devel/etcd33/etcd-3.3.23/vendor/github.com/coreos/etcd/functional/tester/
H A Dstresser_key.go256 return writeTxn(cli, keys, txnOps)
259 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { func
/dports/www/minio-client/etcd-3.5.0/tests/functional/tester/
H A Dstresser_key.go274 return writeTxn(cli, keys, txnOps)
277 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { func
/dports/devel/etcd33/etcd-3.3.23/functional/tester/
H A Dstresser_key.go256 return writeTxn(cli, keys, txnOps)
259 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { func
/dports/devel/etcd34/etcd-3.4.18/functional/tester/
H A Dstresser_key.go274 return writeTxn(cli, keys, txnOps)
277 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { func
/dports/sysutils/terraform/terraform-1.0.11/vendor/go.etcd.io/etcd/functional/tester/
H A Dstresser_key.go274 return writeTxn(cli, keys, txnOps)
277 func writeTxn(cli *clientv3.Client, keys []string, txnOps int) stressFunc { func

12