Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

txn

package

Go to main page

Versions in this module

v0

v0.2.0

Jan 22, 2024

Changes in this version

+ type Connector interface

+ ConditionalUpdate func(key string, value DataItem, doCreate bool) error

+ Connect func() error

+ Delete func(name string) error

+ Get func(name string) (string, error)

+ GetItem func(key string) (DataItem, error)

+ Put func(name string, value any) error

+ PutItem func(key string, value DataItem) error

+ type DataItem struct

+ IsDeleted bool

+ Key string

+ LinkedLen int

+ Prev string

+ TLease time.Time

+ TValid time.Time

+ TxnId string

+ TxnState config.State

+ Value string

+ Version int

+ func (m DataItem) GetKey() string

+ func (mi *DataItem) UnmarshalBSONValue(t bsontype.Type, raw []byte) error

+ func (mi DataItem) MarshalBSONValue() (bsontype.Type, []byte, error)

+ func (r *DataItem) Equal(other DataItem) bool

+ func (r DataItem) MarshalBinary() (data []byte, err error)

+ func (r DataItem) String() string

type Datastore

+ Name string

+ Txn *Transaction

+ func NewDatastore(name string, conn Connector) *Datastore

+ func (r *Datastore) DeleteTSR(txnId string) error

+ func (r *Datastore) ReadTSR(txnId string) (config.State, error)

+ func (r *Datastore) SetSerializer(se serializer.Serializer)

+ func (r *Datastore) WriteTSR(txnId string, txnState config.State) error

+ type Datastorer interface

+ Abort func(hasCommitted bool) error

+ Commit func() error

+ Copy func() Datastorer

+ Delete func(key string) error

+ GetName func() string

+ Prepare func() error

+ Read func(key string, value any) error

+ SetTxn func(txn *Transaction)

+ Start func() error

+ Write func(key string, value any) error

type TxnError

+ const DirtyRead

v0.1.1

Jan 16, 2024

Changes in this version

+ type BaseDataStore struct

+ Name string

+ Txn *Transaction

+ type Connection interface

+ type Datastore interface

+ Abort func(hasCommitted bool) error

+ Commit func() error

+ Copy func() Datastore

+ Delete func(key string) error

+ GetName func() string

+ Prepare func() error

+ Prev func(key string, record string)

+ Read func(key string, value any) error

+ Recover func(key string)

+ SetTxn func(txn *Transaction)

+ Start func() error

+ Write func(key string, value any) error

+ type Item interface

+ GetKey func() string

+ type SourceType string

+ const GLOBAL

+ const LOCAL

+ type StateMachine struct

+ func NewStateMachine() *StateMachine

+ func (st *StateMachine) CheckState(state config.State) error

+ func (st *StateMachine) GetState() config.State

+ func (st *StateMachine) SetState(state config.State) error

+ type TSRMaintainer interface

+ DeleteTSR func(txnId string) error

+ ReadTSR func(txnId string) (config.State, error)

+ WriteTSR func(txnId string, txnState config.State) error

+ type Transaction struct

+ TxnCommitTime time.Time

+ TxnId string

+ TxnStartTime time.Time

+ func NewTransaction() *Transaction

+ func (t *Transaction) Abort() error

+ func (t *Transaction) AddDatastore(ds Datastore) error

+ func (t *Transaction) Commit() error

+ func (t *Transaction) Delete(dsName string, key string) error

+ func (t *Transaction) DeleteTSR() error

+ func (t *Transaction) GetTSRState(txnId string) (config.State, error)

+ func (t *Transaction) Lock(key string, id string, duration time.Duration) error

+ func (t *Transaction) Read(dsName string, key string, value any) error

+ func (t *Transaction) SetGlobalDatastore(ds Datastore)

+ func (t *Transaction) SetGlobalTimeSource(url string)

+ func (t *Transaction) SetLocker(locker locker.Locker)

+ func (t *Transaction) Start() error

+ func (t *Transaction) Unlock(key string, id string) error

+ func (t *Transaction) Write(dsName string, key string, value any) error

+ func (t *Transaction) WriteTSR(txnId string, txnState config.State) error

+ type TxnError string

+ const DeserializeError

+ const KeyNotFound

+ const VersionMismatch

+ func (e TxnError) Error() string

v0.1.0

Jan 10, 2024