transaction

Documentation

Overview

Package transaction provides a transaction implementation

Index

• type Transaction
  • func NewTransaction(model model.DatabaseModel, dbName string, database database.Database, ...) Transaction
  • func (t *Transaction) Abort() ovsdb.OperationResult
  • func (t *Transaction) Assert(lock string) ovsdb.OperationResult
  • func (t *Transaction) Comment(comment string) ovsdb.OperationResult
  • func (t *Transaction) Commit(durable bool) ovsdb.OperationResult
  • func (t *Transaction) Delete(op *ovsdb.Operation) (ovsdb.OperationResult, *updates.ModelUpdates)
  • func (t *Transaction) Insert(op *ovsdb.Operation) (ovsdb.OperationResult, *updates.ModelUpdates)
  • func (t *Transaction) Mutate(op *ovsdb.Operation) (ovsdb.OperationResult, *updates.ModelUpdates)
  • func (t *Transaction) Select(table string, where []ovsdb.Condition, columns []string) ovsdb.OperationResult
  • func (t *Transaction) Transact(operations ...ovsdb.Operation) ([]*ovsdb.OperationResult, database.Update)
  • func (t *Transaction) Update(op *ovsdb.Operation) (ovsdb.OperationResult, *updates.ModelUpdates)
  • func (t *Transaction) Wait(table string, timeout *int, where []ovsdb.Condition, columns []string, ...) ovsdb.OperationResult

Types

type Transaction

type Transaction struct {
	ID          uuid.UUID
	Cache       *cache.TableCache
	DeletedRows map[string]struct{}
	Model       model.DatabaseModel
	DbName      string
	Database    database.Database
	// contains filtered or unexported fields
}

func NewTransaction

func NewTransaction(model model.DatabaseModel, dbName string, database database.Database, logger *logr.Logger) Transaction

func (*Transaction) Abort

func (t *Transaction) Abort() ovsdb.OperationResult

func (*Transaction) Assert

func (t *Transaction) Assert(lock string) ovsdb.OperationResult

func (*Transaction) Comment

func (t *Transaction) Comment(comment string) ovsdb.OperationResult

func (*Transaction) Commit

func (t *Transaction) Commit(durable bool) ovsdb.OperationResult

func (*Transaction) Delete

func (t *Transaction) Delete(op *ovsdb.Operation) (ovsdb.OperationResult, *updates.ModelUpdates)

func (*Transaction) Insert

func (t *Transaction) Insert(op *ovsdb.Operation) (ovsdb.OperationResult, *updates.ModelUpdates)

func (*Transaction) Mutate

func (t *Transaction) Mutate(op *ovsdb.Operation) (ovsdb.OperationResult, *updates.ModelUpdates)

func (*Transaction) Select

func (t *Transaction) Select(table string, where []ovsdb.Condition, columns []string) ovsdb.OperationResult

func (*Transaction) Transact

func (t *Transaction) Transact(operations ...ovsdb.Operation) ([]*ovsdb.OperationResult, database.Update)

func (*Transaction) Update

func (t *Transaction) Update(op *ovsdb.Operation) (ovsdb.OperationResult, *updates.ModelUpdates)

func (*Transaction) Wait

func (t *Transaction) Wait(table string, timeout *int, where []ovsdb.Condition, columns []string, until string, rows []ovsdb.Row) ovsdb.OperationResult