txn

Documentation

Overview

Package txn implements a full transaction interface on top of GoJournal.

Transactions in this package do not have to implement concurrency control, since the package uses two-phase locking to automatically synchronize transactions. Lock ordering is still up to the caller to avoid deadlocks.

Index

• type Log
  • func Init(d disk.Disk) *Log
  • func (tsys *Log) Flush()
• type Txn
  • func Begin(tsys *Log) *Txn
  • func (txn *Txn) Acquire(addr addr.Addr)
  • func (txn *Txn) Commit(wait bool) bool
  • func (txn *Txn) NDirty() uint64
  • func (txn *Txn) OverWrite(addr addr.Addr, sz uint64, data []byte)
  • func (txn *Txn) OverWriteBit(addr addr.Addr, data bool)
  • func (txn *Txn) ReadBuf(addr addr.Addr, sz uint64) []byte
  • func (txn *Txn) ReadBufBit(addr addr.Addr) bool
  • func (txn *Txn) ReleaseAll()

Types

type Log

type Log struct {
	// contains filtered or unexported fields
}

func Init

func Init(d disk.Disk) *Log

func (*Log) Flush

func (tsys *Log) Flush()

type Txn

type Txn struct {
	// contains filtered or unexported fields
}

func Begin

func Begin(tsys *Log) *Txn

Start a local transaction with no writes from a global Log.

func (*Txn) Acquire

func (txn *Txn) Acquire(addr addr.Addr)

func (*Txn) Commit

func (txn *Txn) Commit(wait bool) bool

func (*Txn) NDirty

func (txn *Txn) NDirty() uint64

NDirty reports an upper bound on the size of this transaction when committed.

TODO: number of locks acquired also bounds size of transaction

The caller cannot rely on any particular properties of this function for safety.

func (*Txn) OverWrite

func (txn *Txn) OverWrite(addr addr.Addr, sz uint64, data []byte)

OverWrite writes an object to addr

func (*Txn) OverWriteBit

func (txn *Txn) OverWriteBit(addr addr.Addr, data bool)

func (*Txn) ReadBuf

func (txn *Txn) ReadBuf(addr addr.Addr, sz uint64) []byte

func (*Txn) ReadBufBit

func (txn *Txn) ReadBufBit(addr addr.Addr) bool

func (*Txn) ReleaseAll

func (txn *Txn) ReleaseAll()