Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EtcdTxnInterpreter ¶
type EtcdTxnInterpreter struct {
// contains filtered or unexported fields
}
func (*EtcdTxnInterpreter) Commit ¶
func (eti *EtcdTxnInterpreter) Commit(txn transaction.Txn) (TxnResponse, error)
type EtcdTxnResponse ¶
type EtcdTxnResponse clientv3.TxnResponse
func (*EtcdTxnResponse) IsSucceeded ¶
func (etr *EtcdTxnResponse) IsSucceeded() bool
type Interpreter ¶
type Interpreter interface {
Commit(txn transaction.Txn) (TxnResponse, error)
}
Interpreter is used to interpret the raw Transaction and do the real work inside a KV storage.
func NewEtcdTxnInterpreter ¶
func NewEtcdTxnInterpreter(ctx context.Context, client *clientv3.Client) Interpreter
NewEtcdTxnInterpreter create a new etcd transaction interpreter with the given etcd client.
type TxnResponse ¶
type TxnResponse interface {
IsSucceeded() bool
}
TODO: add more detailed response info.
Click to show internal directories.
Click to hide internal directories.