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 module

Go to main page

Versions in this module

v2

v2.1.1

Jun 7, 2023

v2.1.0

Jul 19, 2022

v2.0.1

Jul 18, 2022

v2.0.0

Jul 8, 2022

Changes in this version

+ var EOF = fmt.Errorf("end of transaction ids")

+ var ErrExcessiveContention = stderrors.New("state changing too quickly; try again soon")

+ var ErrNoOperations = stderrors.New("no transaction operations are available")

+ var ErrTransientFailure = stderrors.New("transient failure")

+ func NewCollectionCleaner(config CollectionConfig) *collectionCleaner

+ func NewStashCleaner(config CollectionConfig) *collectionCleaner

+ func SupportsServerSideTransactions(db *mgo.Database) bool

+ func TestHooks(runner Runner) chan ([]TestHook)

+ type CleanAndPruneArgs struct

+ MaxTime time.Time

+ MaxTransactionsToProcess int

+ Multithreaded bool

+ TxnBatchSize int

+ TxnBatchSleepTime time.Duration

+ Txns *mgo.Collection

+ TxnsCount int

+ type CleanupStats struct

+ CollectionsInspected int

+ DocsCleaned int

+ DocsInspected int

+ ShouldRetry bool

+ StashDocumentsRemoved int

+ TransactionsRemoved int

+ func CleanAndPrune(args CleanAndPruneArgs) (CleanupStats, error)

+ type Clock interface

+ Now func() time.Time

+ type CollectionConfig struct

+ LogInterval time.Duration

+ MaxRemoveQueue int

+ NumBatchTokens int

+ Oracle Oracle

+ Source *mgo.Collection

+ type CollectionStats struct

+ CompletedTokenCount int

+ CompletedTxnCount int

+ DocCount int

+ PulledTokenCount int

+ RemovedCount int

+ TokenCount int

+ UpdatedDocCount int

+ func (stats CollectionStats) Details() string

+ func (stats CollectionStats) HasChanges() bool

+ type DBOracle struct

+ func NewDBOracle(txns *mgo.Collection, thresholdTime time.Time, maxTxns int) (*DBOracle, func(), error)

+ func (o *DBOracle) CompletedTokens(tokens []string) (map[string]bool, error)

+ func (o *DBOracle) Count() int

+ func (o *DBOracle) IterTxns() (OracleIterator, error)

+ func (o *DBOracle) RemoveTxns(txnIds []bson.ObjectId) (int, error)

+ type IncrementalPruneArgs struct

+ MaxTime time.Time

+ ProgressChannel chan ProgressMessage

+ ReverseOrder bool

+ TxnBatchSize int

+ TxnBatchSleepTime time.Duration

+ type IncrementalPruner struct

+ ProgressChan chan ProgressMessage

+ func NewIncrementalPruner(args IncrementalPruneArgs) *IncrementalPruner

+ func (p *IncrementalPruner) Prune(txns *mgo.Collection) (PrunerStats, error)

+ type MemOracle struct

+ func NewMemOracle(txns *mgo.Collection, thresholdTime time.Time, maxTxns int) (*MemOracle, func(), error)

+ func (o *MemOracle) CompletedTokens(tokens []string) (map[string]bool, error)

+ func (o *MemOracle) Count() int

+ func (o *MemOracle) IterTxns() (OracleIterator, error)

+ func (o *MemOracle) RemoveTxns(txnIds []bson.ObjectId) (int, error)

+ type Oracle interface

+ CompletedTokens func(tokens []string) (map[string]bool, error)

+ Count func() int

+ IterTxns func() (OracleIterator, error)

+ RemoveTxns func(txnIds []bson.ObjectId) (int, error)

+ type OracleIterator interface

+ Next func() (bson.ObjectId, error)

+ type ProgressMessage struct

+ DocsCleaned int

+ TxnsRemoved int

+ type PruneOptions struct

+ BatchTransactionSleepTime time.Duration

+ MaxBatchTransactions int

+ MaxBatches int

+ MaxNewTransactions int

+ MaxTime time.Time

+ MinNewTransactions int

+ PruneFactor float32

+ SmallBatchTransactionCount int

+ type PrunerStats struct

+ CacheLookupTime time.Duration

+ CollectionQueries int64

+ DocCacheHits int64

+ DocCacheMisses int64

+ DocCleanupTime time.Duration

+ DocLookupTime time.Duration

+ DocMissingCacheHit int64

+ DocQueuesCleaned int64

+ DocReadTime time.Duration

+ DocReads int64

+ DocStillMissing int64

+ DocTokensCleaned int64

+ DocsAlreadyClean int64

+ DocsMissing int64

+ StashDocReads int64

+ StashDocsRemoved int64

+ StashLookupTime time.Duration

+ StashQueries int64

+ StashRemoveTime time.Duration

+ StrCacheHits int64

+ StrCacheMisses int64

+ TxnReadTime time.Duration

+ TxnRemoveTime time.Duration

+ TxnsNotRemoved int64

+ TxnsRemoved int64

+ func CombineStats(a, b PrunerStats) PrunerStats

+ func (ps PrunerStats) String() string

+ type Remover interface

+ Flush func() error

+ Remove func(id interface{}) error

+ Removed func() int

+ type Runner interface

+ MaybePruneTransactions func(pruneOpts PruneOptions) error

+ ResumeTransactions func() error

+ Run func(transactions TransactionSource) error

+ RunTransaction func(*Transaction) error

+ func NewRunner(params RunnerParams) Runner

+ type RunnerParams struct

+ ChangeLogName string

+ Clock Clock

+ Database *mgo.Database

+ MaxRetryAttempts int

+ PauseFunc func(duration time.Duration)

+ RetryBackoff time.Duration

+ RetryFuzzPercent int

+ RunTransactionObserver func(Transaction)

+ ServerSideTransactions bool

+ TransactionCollectionName string

+ type TestHook struct

+ After func()

+ Before func()

+ type Transaction struct

+ Attempt int

+ Duration time.Duration

+ Error error

+ Ops []txn.Op

+ type TransactionSource func(attempt int) ([]txn.Op, error)

Other modules containing this package

github.com/juju/txn/v3