Documentation ¶
Overview ¶
Package local implements DB Transactions for the local "in memory" transport. This implementation uses a collection of transaction items that are propagated to registered GO channels.
Index ¶
Constants ¶
This section is empty.
Variables ¶
var DefaultRegistry = syncbase.NewRegistry()
DefaultRegistry is a default registry.
Functions ¶
Types ¶
type BytesTxn ¶
type BytesTxn struct {
// contains filtered or unexported fields
}
BytesTxn is just a concurrent map of Bytes messages. The intent is to collect the user data and propagate them when commit happens.
func NewBytesTxn ¶
NewBytesTxn is a constructor.
func (*BytesTxn) Commit ¶
Commit executes the transaction.
func (*BytesTxn) Delete ¶
Delete add delete operation into transaction.
type ProtoTxn ¶
type ProtoTxn struct {
// contains filtered or unexported fields
}
ProtoTxn is a concurrent map of proto messages. The intent is to collect the user data and propagate them when commit happens.
func NewProtoTxn ¶
NewProtoTxn is a constructor.
func (*ProtoTxn) Commit ¶
Commit executes the transaction.
func (*ProtoTxn) Delete ¶
Delete adds delete operation into transaction.