in pkg/client/store.go [172:192]
func (c *storeClientTx) Commit(ctx context.Context) error {
if c.brokenErr != nil {
return ErrStoreTxBroken
}
if c.discarded {
return ErrStoreTxDiscarded
}
if c.committed {
return nil
}
_, err := c.client.client.storeClient.CommitTx(ctx, &proto.StoreCommitTxRequest{
Token: c.client.client.token,
TxId: c.txID,
})
if err != nil {
c.brokenErr = err
return err
}
c.committed = true
return nil
}