func()

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
}