Documentation
¶
Overview ¶
Package transaction provides a transaction implementation
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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)
Source Files
Click to show internal directories.
Click to hide internal directories.