type go.etcd.io/bbolt.Tx
70 uses
go.etcd.io/bbolt (current package)
bucket.go#L31: tx *Tx // the associated transaction
bucket.go#L55: func newBucket(tx *Tx) Bucket {
bucket.go#L65: func (b *Bucket) Tx() *Tx {
db.go#L134: rwtx *Tx
db.go#L135: txs []*Tx
db.go#L540: func (db *DB) Begin(writable bool) (*Tx, error) {
db.go#L547: func (db *DB) beginTx() (*Tx, error) {
db.go#L566: t := &Tx{}
db.go#L585: func (db *DB) beginRWTx() (*Tx, error) {
db.go#L607: t := &Tx{writable: true}
db.go#L634: type txsById []*Tx
db.go#L641: func (db *DB) removeTx(tx *Tx) {
db.go#L677: func (db *DB) Update(fn func(*Tx) error) error {
db.go#L708: func (db *DB) View(fn func(*Tx) error) error {
db.go#L752: func (db *DB) Batch(fn func(*Tx) error) error {
db.go#L778: fn func(*Tx) error
db.go#L809: err := b.db.Update(func(tx *Tx) error {
db.go#L854: func safelyCall(fn func(*Tx) error, tx *Tx) (err error) {
tx.go#L24: type Tx struct {
tx.go#L44: func (tx *Tx) init(db *DB) {
tx.go#L65: func (tx *Tx) ID() int {
tx.go#L70: func (tx *Tx) DB() *DB {
tx.go#L75: func (tx *Tx) Size() int64 {
tx.go#L80: func (tx *Tx) Writable() bool {
tx.go#L88: func (tx *Tx) Cursor() *Cursor {
tx.go#L93: func (tx *Tx) Stats() TxStats {
tx.go#L100: func (tx *Tx) Bucket(name []byte) *Bucket {
tx.go#L107: func (tx *Tx) CreateBucket(name []byte) (*Bucket, error) {
tx.go#L114: func (tx *Tx) CreateBucketIfNotExists(name []byte) (*Bucket, error) {
tx.go#L120: func (tx *Tx) DeleteBucket(name []byte) error {
tx.go#L127: func (tx *Tx) ForEach(fn func(name []byte, b *Bucket) error) error {
tx.go#L134: func (tx *Tx) OnCommit(fn func()) {
tx.go#L141: func (tx *Tx) Commit() error {
tx.go#L225: func (tx *Tx) commitFreelist() error {
tx.go#L252: func (tx *Tx) Rollback() error {
tx.go#L262: func (tx *Tx) nonPhysicalRollback() {
tx.go#L273: func (tx *Tx) rollback() {
tx.go#L291: func (tx *Tx) close() {
tx.go#L328: func (tx *Tx) Copy(w io.Writer) error {
tx.go#L335: func (tx *Tx) WriteTo(w io.Writer) (n int64, err error) {
tx.go#L390: func (tx *Tx) CopyFile(path string, mode os.FileMode) error {
tx.go#L412: func (tx *Tx) Check() <-chan error {
tx.go#L418: func (tx *Tx) check(ch chan error) {
tx.go#L458: func (tx *Tx) checkBucket(b *Bucket, reachable map[pgid]*page, freed map[pgid]bool, ch chan error) {
tx.go#L497: func (tx *Tx) allocate(count int) (*page, error) {
tx.go#L514: func (tx *Tx) write() error {
tx.go#L585: func (tx *Tx) writeMeta() error {
tx.go#L609: func (tx *Tx) page(id pgid) *page {
tx.go#L622: func (tx *Tx) forEachPage(pgid pgid, depth int, fn func(*page, int)) {
tx.go#L639: func (tx *Tx) Page(id int) (*PageInfo, error) {
src.elv.sh/pkg/store
cmd.go#L11: initDB["initialize command history table"] = func(tx *bolt.Tx) error {
cmd.go#L20: err := s.db.View(func(tx *bolt.Tx) error {
cmd.go#L34: err = s.db.Update(func(tx *bolt.Tx) error {
cmd.go#L47: return s.db.Update(func(tx *bolt.Tx) error {
cmd.go#L56: err := s.db.View(func(tx *bolt.Tx) error {
cmd.go#L71: return s.db.View(func(tx *bolt.Tx) error {
cmd.go#L105: err := s.db.View(func(tx *bolt.Tx) error {
cmd.go#L124: err := s.db.View(func(tx *bolt.Tx) error {
db_store.go#L13: var initDB = map[string](func(*bolt.Tx) error){}
db_store.go#L60: err := db.Update(func(tx *bolt.Tx) error {
dir.go#L18: initDB["initialize directory history table"] = func(tx *bolt.Tx) error {
dir.go#L35: return s.db.Update(func(tx *bolt.Tx) error {
dir.go#L56: return s.db.Update(func(tx *bolt.Tx) error {
dir.go#L64: return s.db.Update(func(tx *bolt.Tx) error {
dir.go#L75: err := s.db.View(func(tx *bolt.Tx) error {
shared_var.go#L13: initDB["initialize shared variable table"] = func(tx *bolt.Tx) error {
shared_var.go#L22: err := s.db.View(func(tx *bolt.Tx) error {
shared_var.go#L36: return s.db.Update(func(tx *bolt.Tx) error {
shared_var.go#L44: return s.db.Update(func(tx *bolt.Tx) error {